Configured stress test, added metrics for Tomcat requests queue

Author: Mikalai Alimenkou

compose.yaml

@@ -88,4 +88,38 @@ services:
     ports:
       - "3000:3000"
     depends_on:
-      - prometheus
+      - prometheus
+
+  library-app:
+    profiles: ["perftest"]
+    image: xpinjection.com/library:perf-test
+    container_name: library-app
+    environment:
+      - SPRING_PROFILES_ACTIVE=admin,perftest
+      - SPRING_SECURITY_USER_NAME=admin
+      - SPRING_SECURITY_USER_PASSWORD=xpinjection
+      - SERVER_TOMCAT_THREADS_MAX=200
+      - SERVER_TOMCAT_MAX_CONNECTIONS=1000
+      - JAVA_TOOL_OPTIONS=-XX:InitialRAMPercentage=80.0 -XX:MaxRAMPercentage=80.0 -XX:MaxMetaspaceSize=128m
+    ports:
+      - "8080:8080"
+    deploy:
+      resources:
+        limits:
+          cpus: '2.0'
+          memory: 2G
+        reservations:
+          memory: 2G
+    healthcheck:
+      test: ["CMD", "wget", "--no-verbose", "--tries=1", "--spider", "http://localhost:8080/admin/health/readiness"]
+      interval: 10s
+      timeout: 5s
+      retries: 3
+      start_period: 30s
+    depends_on:
+      db:
+        condition: service_started
+      jaeger:
+        condition: service_started
+      elastic:
+        condition: service_healthy

k6/search-books-test.js

@@ -0,0 +1,142 @@
+import http from 'k6/http';
+import {check} from 'k6';
+
+const BASE_URL = __ENV.BASE_URL || 'http://localhost:8080';
+const SCENARIO = __ENV.SCENARIO || 'load';
+const TARGET_RPS = parseInt(__ENV.TARGET_RPS || '50');
+const DURATION = __ENV.DURATION || '2m';
+
+const AUTHORS = [
+    'Martin Fowler',
+    'Robert Martin',
+    'Kent Beck',
+    'Eric Evans',
+    'Michael Feathers',
+    'Joshua Bloch',
+    'Erich Gamma',
+    'Gang of Four',
+    'Steve McConnell',
+    'Andrew Hunt',
+];
+
+export const options = {
+    scenarios: {
+        smoke: {
+            executor: 'constant-vus',
+            vus: 1,
+            duration: '30s',
+            exec: 'searchBooks',
+            tags: {test_type: 'smoke'},
+            gracefulStop: '5s',
+        },
+        load: {
+            executor: 'constant-arrival-rate',
+            rate: TARGET_RPS,
+            timeUnit: '1s',
+            duration: DURATION,
+            preAllocatedVUs: 50,
+            maxVUs: 500,
+            exec: 'searchBooks',
+            tags: {test_type: 'load'},
+            gracefulStop: '10s',
+        },
+        ramp: {
+            executor: 'ramping-arrival-rate',
+            startRate: 10,
+            timeUnit: '1s',
+            preAllocatedVUs: 50,
+            maxVUs: 500,
+            exec: 'searchBooks',
+            tags: {test_type: 'ramp'},
+            gracefulStop: '10s',
+            stages: [
+                {duration: '1m', target: TARGET_RPS},
+                {duration: '3m', target: TARGET_RPS},
+                {duration: '1m', target: TARGET_RPS * 1.5},
+                {duration: '2m', target: TARGET_RPS * 1.5},
+                {duration: '1m', target: TARGET_RPS * 2},
+                {duration: '1m', target: TARGET_RPS * 2},
+                {duration: '1m', target: 10},
+            ],
+        },
+        stress: {
+            executor: 'ramping-arrival-rate',
+            startRate: 10,
+            timeUnit: '1s',
+            preAllocatedVUs: 20,
+            maxVUs: 1000,
+            exec: 'searchBooks',
+            tags: {test_type: 'stress'},
+            gracefulStop: '15s',
+            stages: [
+                {duration: '1m', target: TARGET_RPS},
+                {duration: '2m', target: TARGET_RPS * 2},
+                {duration: '2m', target: TARGET_RPS * 4},
+                {duration: '2m', target: TARGET_RPS * 6},
+                {duration: '1m', target: TARGET_RPS * 8},
+                {duration: '2m', target: 10},
+            ],
+        },
+    },
+
+    thresholds: {
+        'http_req_duration': ['p(95)<500', 'p(99)<1000', 'avg<300'],
+
+        'http_req_failed': ['rate<0.01'],
+        'http_req_duration{test_type:load}': ['p(95)<500'],
+        'http_req_duration{test_type:stress}': ['p(95)<1000'],
+    },
+};
+
+// Only run the scenario specified by SCENARIO env variable
+if (SCENARIO !== 'all') {
+    for (const key of Object.keys(options.scenarios)) {
+        if (key !== SCENARIO) {
+            delete options.scenarios[key];
+        }
+    }
+}
+
+export function setup() {
+    console.log(`Starting performance test with scenario: ${SCENARIO}`);
+    console.log(`Target RPS: ${TARGET_RPS}`);
+    console.log(`Base URL: ${BASE_URL}`);
+    console.log(`Duration: ${DURATION}`);
+
+    const healthCheck = http.get(`${BASE_URL}/admin/health`);
+    if (healthCheck.status !== 200) {
+        throw new Error(`Application health check failed: ${healthCheck.status}`);
+    }
+    console.log('Application health check passed');
+
+    return {startTime: new Date()};
+}
+
+export function searchBooks() {
+    const author = AUTHORS[Math.floor(Math.random() * AUTHORS.length)];
+
+    const response = http.get(`${BASE_URL}/books?author=${encodeURIComponent(author)}`, {
+        headers: {
+            'Accept': 'application/json',
+        },
+        tags: {
+            endpoint: 'search-books',
+            author: author
+        },
+    });
+
+    check(response, {
+        'status is 200': (r) => r.status === 200,
+        'response time < 500ms': (r) => r.timings.duration < 500,
+        'response time < 1000ms': (r) => r.timings.duration < 1000,
+        'content-type is JSON': (r) => r.headers['Content-Type']?.includes('application/json'),
+        'response body is valid': (r) => {
+            try {
+                const body = JSON.parse(r.body);
+                return Array.isArray(body);
+            } catch (e) {
+                return false;
+            }
+        },
+    });
+}