fix: 동시 취소 시 수강인원 갱신 유실 수정

.claude/resources/concurrency/98/delete-registered-course/burst-script.js

@@ -0,0 +1,172 @@
+// CONC-98 delete-registered-course 폭발 부하 스크립트.
+//
+// 실행:
+//   k6 run -e SUMMARY_OUT=$TARGET_DIR/k6-burst-summary-{n}.json $TARGET_DIR/burst-script.js
+//
+// {n}은 후보 번호다. 0 = 아무 제어도 없는 원본, n = 후보 n을 단독 적용한 상태.
+// 부하 직전에 되돌리기 SQL을 반드시 실행한다. 스크립트는 DB를 건드리지 않는다.
+//
+// **취소 대상의 되돌리기는 "비우기"가 아니라 "다시 채우기"다.** 신청 대상은 등록 0건에서
+// 출발하지만 여기는 만석에서 출발한다. 되돌리기를 건너뛰면 등록이 없는 상태로 부하가 들어가
+// 전 요청이 404로 끝나고, 그 결과는 "위반 0건"으로 보이지만 아무것도 검증하지 못한 것이다.
+
+import http from 'k6/http';
+import { Counter } from 'k6/metrics';
+
+const BASE_URL = __ENV.BASE_URL || 'http://localhost:8080';
+
+// 이 측정이 무엇이었는지 요약 파일만 보고 알 수 있게 한다.
+const TARGET = 'delete-registered-course';
+const ENDPOINT = 'DELETE /api/v1/registration/{courseId}';
+const TARGET_COURSE_ID = 990001;
+// 취소 단독 측정에서 상한은 정원이 아니라 **시드가 꽂아둔 등록 행 수**다.
+// VU마다 자기 등록 하나씩을 취소하므로 성공 수가 정확히 이 값이어야 한다.
+const CAPACITY = 500;
+const VU_COUNT = 500;
+
+// 이 대상에는 기대되는 거절이 없다. VU마다 서로 다른 회원이 자기 등록 하나를 취소하므로
+// 500건 전부 성공해야 한다. 이 코드가 잡히면 시드가 만석이 아니었거나
+// 한 회원이 두 VU에 걸린 것이다. 정상 측정이라면 0건이다.
+// ExceptionCode.REGISTERED_COURSE_NOT_FOUND(NOT_FOUND, 4003)
+const EXPECTED_REJECT_CODE = 4003;
+
+const tokens = JSON.parse(open('../tokens.json'));
+
+if (tokens.length !== VU_COUNT) {
+    throw new Error(
+        `토큰 ${tokens.length}건 / 필요 ${VU_COUNT}건. VU와 회원이 1대1로 묶이지 않는다. ` +
+        'mint-tokens.sh의 --count와 시드 회원 수를 VU 수에 맞추고 다시 만들어라.'
+    );
+}
+
+const succeeded = new Counter('req_succeeded');
+const rejectedAsExpected = new Counter('req_rejected_expected');
+const rejectedOther4xx = new Counter('req_rejected_other_4xx');
+const failed5xx = new Counter('req_failed_5xx');
+const unparsable = new Counter('req_unparsable');
+
+export const options = {
+    scenarios: {
+        burst: {
+            executor: 'per-vu-iterations',
+            vus: VU_COUNT,
+            iterations: 1,
+            // 전 VU가 요청 하나씩만 보내므로 길게 잡을 이유가 없다.
+            // 여기에 걸리면 경합이 아니라 락 대기 타임아웃을 재고 있는 것이다.
+            maxDuration: '60s',
+        },
+    },
+    summaryTrendStats: ['avg', 'min', 'med', 'p(90)', 'p(95)', 'p(99)', 'max'],
+    // thresholds 없음. 실패율로 성공을 판정하지 않는다. 정합성 판정은 DB의 불변식 검증이 한다.
+};
+
+// 비JSON 응답에서 예외를 던지지 않는다. 파싱 실패는 null로 떨어뜨려 카운터로 드러낸다.
+function errorCodeOf(res) {
+    if (res.body === null || res.body.length <= 2) {
+        return null;
+    }
+    try {
+        const body = res.json();
+        return body && body.code !== undefined ? body.code : null;
+    } catch (e) {
+        return null;
+    }
+}
+
+export default function () {
+    // VU 번호로 회원을 고정한다. __VU는 1부터 시작한다.
+    const token = tokens[__VU - 1];
+
+    // 이 서버는 access-token 헤더 하나만 요구한다.
+    const params = {
+        headers: { 'access-token': token.accessToken },
+    };
+
+    const res = http.del(`${BASE_URL}/api/v1/registration/${TARGET_COURSE_ID}`, null, params);
+
+    if (res.status >= 200 && res.status < 300) {
+        succeeded.add(1);
+        return;
+    }
+
+    if (res.status >= 500) {
+        failed5xx.add(1);
+        return;
+    }
+
+    const code = errorCodeOf(res);
+
+    if (code === null) {
+        unparsable.add(1);
+        return;
+    }
+
+    if (code === EXPECTED_REJECT_CODE) {
+        rejectedAsExpected.add(1);
+        return;
+    }
+
+    rejectedOther4xx.add(1);
+}
+
+export function handleSummary(data) {
+    const m = data.metrics || {};
+    const val = (name, key) => (m[name] && m[name].values[key] !== undefined ? m[name].values[key] : null);
+    const count = (name) => val(name, 'count') || 0;
+    const trend = (name) => ({
+        med: val(name, 'med'),
+        p95: val(name, 'p(95)'),
+        p99: val(name, 'p(99)'),
+        max: val(name, 'max'),
+    });
+
+    const summary = {
+        target: TARGET,
+        endpoint: ENDPOINT,
+        condition: {
+            executor: 'per-vu-iterations (iterations=1, ramp 없음)',
+            vus: VU_COUNT,
+            target_course_id: TARGET_COURSE_ID,
+            capacity: CAPACITY,
+            expected_reject_code: EXPECTED_REJECT_CODE,
+            db_cache: 'warm (InnoDB 버퍼 풀은 재기동 없이 비울 수 없다)',
+            app_cache: '없음',
+        },
+        requests: val('http_reqs', 'count'),
+        rps: val('http_reqs', 'rate'),
+        // 응답 분포. 정합성 판정은 DB의 불변식 검증으로 하고, 이 값은 응답 품질 판정에 쓴다.
+        outcome: {
+            succeeded: count('req_succeeded'),
+            rejected_expected: count('req_rejected_expected'),
+            rejected_other_4xx: count('req_rejected_other_4xx'),
+            failed_5xx: count('req_failed_5xx'),
+            unparsable: count('req_unparsable'),
+        },
+        // 취소는 초과가 없다. 성공 수가 등록 행 수와 **정확히 같아야** 하며,
+        // 음수면 취소되지 못한 등록이 남았다는 뜻이다.
+        succeeded_over_capacity: count('req_succeeded') - CAPACITY,
+        duration_ms: trend('http_req_duration'),
+        waiting_ms: trend('http_req_waiting'),
+    };
+
+    // 아래 반올림은 터미널 한 줄 출력에만 쓴다. summary 객체의 값은 손대지 않는다.
+    const num = (x, d) => (typeof x === 'number' ? x.toFixed(d) : '-');
+    const o = summary.outcome;
+    const line = [
+        `[burst] ${TARGET}`,
+        `요청 ${summary.requests}건`,
+        `성공 ${o.succeeded}/${CAPACITY} (차이 ${summary.succeeded_over_capacity})`,
+        `기대거절 ${o.rejected_expected}`,
+        `기타4xx ${o.rejected_other_4xx}`,
+        `5xx ${o.failed_5xx}`,
+        `p99 ${num(summary.duration_ms.p99, 1)}ms`,
+    ].join(' / ');
+
+    const out = { stdout: `\n${line}\n\n` };
+
+    if (__ENV.SUMMARY_OUT) {
+        out[__ENV.SUMMARY_OUT] = JSON.stringify(summary, null, 2);
+    }
+
+    return out;
+}

.claude/resources/concurrency/98/delete-registered-course/invariant-0.txt

@@ -0,0 +1,35 @@
++--------------------------+
+|                          |
++--------------------------+
+| === 불변식 검증 === |
++--------------------------+
++-----------------------------------------------+----------+--------+------------+
+| invariant                                     | expected | actual | violations |
++-----------------------------------------------+----------+--------+------------+
+| I1. current_enrollment = COUNT(registrations) |        0 |    497 |        497 |
++-----------------------------------------------+----------+--------+------------+
++-----------------------------+----------+--------+------------+
+| invariant                   | expected | actual | violations |
++-----------------------------+----------+--------+------------+
+| I2. current_enrollment >= 0 | >= 0     |    497 |          0 |
++-----------------------------+----------+--------+------------+
++----------------+
+|                |
++----------------+
+| === 참고 === |
++----------------+
++--------------------------------+--------------+-----------+---------------+
+| metric                         | max_capacity | rows_left | over_capacity |
++--------------------------------+--------------+-----------+---------------+
+| ref. 등록 행 수 대 정원 |          500 |         0 |             0 |
++--------------------------------+--------------+-----------+---------------+
++------------------------------+----------------+
+| metric                       | max_per_member |
++------------------------------+----------------+
+| ref. 회원당 중복 등록 |              0 |
++------------------------------+----------------+
++----------------------------------------+--------------------+
+| metric                                 | courses_with_drift |
++----------------------------------------+--------------------+
+| ref. 카운터가 어긋난 강의 수 |                  1 |
++----------------------------------------+--------------------+

.claude/resources/concurrency/98/delete-registered-course/invariant-1.txt

@@ -0,0 +1,35 @@
++--------------------------+
+|                          |
++--------------------------+
+| === 불변식 검증 === |
++--------------------------+
++-----------------------------------------------+----------+--------+------------+
+| invariant                                     | expected | actual | violations |
++-----------------------------------------------+----------+--------+------------+
+| I1. current_enrollment = COUNT(registrations) |        0 |      0 |          0 |
++-----------------------------------------------+----------+--------+------------+
++-----------------------------+----------+--------+------------+
+| invariant                   | expected | actual | violations |
++-----------------------------+----------+--------+------------+
+| I2. current_enrollment >= 0 | >= 0     |      0 |          0 |
++-----------------------------+----------+--------+------------+
++----------------+
+|                |
++----------------+
+| === 참고 === |
++----------------+
++--------------------------------+--------------+-----------+---------------+
+| metric                         | max_capacity | rows_left | over_capacity |
++--------------------------------+--------------+-----------+---------------+
+| ref. 등록 행 수 대 정원 |          500 |         0 |             0 |
++--------------------------------+--------------+-----------+---------------+
++------------------------------+----------------+
+| metric                       | max_per_member |
++------------------------------+----------------+
+| ref. 회원당 중복 등록 |              0 |
++------------------------------+----------------+
++----------------------------------------+--------------------+
+| metric                                 | courses_with_drift |
++----------------------------------------+--------------------+
+| ref. 카운터가 어긋난 강의 수 |                  0 |
++----------------------------------------+--------------------+

.claude/resources/concurrency/98/delete-registered-course/invariant-check.sql

@@ -0,0 +1,67 @@
+-- [CONC-98] deleteRegisteredCourse 불변식 검증
+-- Phase 1에서 확정. Phase 4와 7에서 **그대로** 재사용한다. 후보마다 바꾸지 마라.
+--
+-- 실행:
+--   mysqlc -t < .claude/resources/concurrency/98/delete-registered-course/invariant-check.sql \
+--     | tee $TARGET_DIR/invariant-{n}.txt
+
+-- 대상 자원. 이슈 공용 경합 대상 강의. Phase 3의 시드가 이 id를 그대로 쓴다.
+SET @target_course_id = 990001;
+
+SELECT '=== 불변식 검증 ===' AS '';
+
+-- I1. 집계 컬럼이 실제 등록 행 수와 일치한다.
+--     violations != 0 이면 갱신이 유실된 것이다. lost update의 직접 증거다.
+--     취소 두 건이 같은 값을 읽고 같은 절대값을 쓰면 감소 하나가 사라지고,
+--     카운터가 실제 등록 행 수보다 크게 남아 자리가 안 풀린 것처럼 보인다.
+SELECT 'I1. current_enrollment = COUNT(registrations)'         AS invariant,
+       (SELECT COUNT(*) FROM registrations r
+         WHERE r.course_id = c.id)                             AS expected,
+       c.current_enrollment                                    AS actual,
+       ABS(c.current_enrollment - (SELECT COUNT(*) FROM registrations r
+                                    WHERE r.course_id = c.id))  AS violations
+FROM courses c
+WHERE c.id = @target_course_id;
+
+-- I2. 집계 컬럼은 음수가 되지 않는다.
+--     decrementEnrollment()에 하한이 없고 컬럼에도 CHECK 제약이 없다.
+--     I1이 0이어도 이 값이 0이 아닐 수 있다. 반드시 함께 본다.
+SELECT 'I2. current_enrollment >= 0'                           AS invariant,
+       '>= 0'                                                  AS expected,
+       c.current_enrollment                                    AS actual,
+       IF(c.current_enrollment < 0, 1, 0)                      AS violations
+FROM courses c
+WHERE c.id = @target_course_id;
+
+-- 참고 자료. 불변식은 아니지만 판정에 쓴다.
+SELECT '=== 참고 ===' AS '';
+
+-- 등록 행 수와 정원. Phase 1에서 불변식으로 채택하지 않았다.
+-- 취소 단독 부하로는 깨지지 않고, 신청과 취소를 섞은 부하에서만 의미가 생긴다.
+-- 혼합 부하를 쓰게 되면 이 값으로 카운터 오차가 정원 초과로 번졌는지 확인한다.
+SELECT 'ref. 등록 행 수 대 정원'                                AS metric,
+       c.max_capacity                                          AS max_capacity,
+       (SELECT COUNT(*) FROM registrations r
+         WHERE r.course_id = c.id)                             AS rows_left,
+       GREATEST(0, (SELECT COUNT(*) FROM registrations r
+                     WHERE r.course_id = c.id) - c.max_capacity) AS over_capacity
+FROM courses c
+WHERE c.id = @target_course_id;
+
+-- 중복 등록이 실제로 들어갔는지. uk_member_course가 있으면 항상 1 이하여야 한다.
+-- 2 이상이면 UNIQUE 제약이 없거나 깨진 것이다.
+SELECT 'ref. 회원당 중복 등록'                                  AS metric,
+       COALESCE(MAX(cnt), 0)                                   AS max_per_member
+FROM (
+    SELECT COUNT(*) AS cnt
+    FROM registrations
+    WHERE course_id = @target_course_id
+    GROUP BY member_id
+) g;
+
+-- 전체 강의로 넓혀 카운터가 어긋난 행이 또 있는지 본다.
+-- 대상 강의만 보다가 다른 곳의 오염을 놓치지 않기 위한 것이다.
+SELECT 'ref. 카운터가 어긋난 강의 수'                            AS metric,
+       COUNT(*)                                                AS courses_with_drift
+FROM courses c
+WHERE c.current_enrollment <> (SELECT COUNT(*) FROM registrations r WHERE r.course_id = c.id);

.claude/resources/concurrency/98/delete-registered-course/invariant-final.txt

@@ -0,0 +1,35 @@
++--------------------------+
+|                          |
++--------------------------+
+| === 불변식 검증 === |
++--------------------------+
++-----------------------------------------------+----------+--------+------------+
+| invariant                                     | expected | actual | violations |
++-----------------------------------------------+----------+--------+------------+
+| I1. current_enrollment = COUNT(registrations) |        0 |      0 |          0 |
++-----------------------------------------------+----------+--------+------------+
++-----------------------------+----------+--------+------------+
+| invariant                   | expected | actual | violations |
++-----------------------------+----------+--------+------------+
+| I2. current_enrollment >= 0 | >= 0     |      0 |          0 |
++-----------------------------+----------+--------+------------+
++----------------+
+|                |
++----------------+
+| === 참고 === |
++----------------+
++--------------------------------+--------------+-----------+---------------+
+| metric                         | max_capacity | rows_left | over_capacity |
++--------------------------------+--------------+-----------+---------------+
+| ref. 등록 행 수 대 정원 |          500 |         0 |             0 |
++--------------------------------+--------------+-----------+---------------+
++------------------------------+----------------+
+| metric                       | max_per_member |
++------------------------------+----------------+
+| ref. 회원당 중복 등록 |              0 |
++------------------------------+----------------+
++----------------------------------------+--------------------+
+| metric                                 | courses_with_drift |
++----------------------------------------+--------------------+
+| ref. 카운터가 어긋난 강의 수 |                  0 |
++----------------------------------------+--------------------+

.claude/resources/concurrency/98/delete-registered-course/k6-burst-summary-0.json

@@ -0,0 +1,35 @@
+{
+  "target": "delete-registered-course",
+  "endpoint": "DELETE /api/v1/registration/{courseId}",
+  "condition": {
+    "executor": "per-vu-iterations (iterations=1, ramp 없음)",
+    "vus": 500,
+    "target_course_id": 990001,
+    "capacity": 500,
+    "expected_reject_code": 4003,
+    "db_cache": "warm (InnoDB 버퍼 풀은 재기동 없이 비울 수 없다)",
+    "app_cache": "없음"
+  },
+  "requests": 500,
+  "rps": 58.9483890348451,
+  "outcome": {
+    "succeeded": 500,
+    "rejected_expected": 0,
+    "rejected_other_4xx": 0,
+    "failed_5xx": 0,
+    "unparsable": 0
+  },
+  "succeeded_over_capacity": 0,
+  "duration_ms": {
+    "med": 6502.228999999999,
+    "p95": 8074.8233,
+    "p99": 8175.550560000001,
+    "max": 8214.385
+  },
+  "waiting_ms": {
+    "med": 6501.814,
+    "p95": 8074.20725,
+    "p99": 8168.525449999999,
+    "max": 8214.313
+  }
+}