Part 16 · Capstone & Mock Interview

Banking capstone: từ repository đến production evidence

Một vertical slice chuyển tiền kết nối Java, Spring, JPA, PostgreSQL, security, messaging, observability và AWS Auto Scaling. Mỗi phase có failure gate; không chỉ hoàn thành happy path.

1. Repository và modules

banking-capstone/
  transfer-domain/        # Money, AccountId, Transfer state machine
  transfer-application/   # use cases, ports, transaction boundaries
  transfer-adapters/      # REST, JPA, broker, security
  transfer-boot/          # Spring Boot wiring
  infrastructure/         # Compose, Terraform, dashboards
  runbooks/               # stuck transfer, DB saturation, rollback

Khởi đầu modular monolith để giữ ledger invariant trong một local transaction. Tách service chỉ sau khi có evidence về ownership/scale/release cadence; ports không có nghĩa bắt buộc microservices.

2. PostgreSQL schema và migration

accounts(id, currency, available_balance, version)
transfers(id, idempotency_key, request_hash, status, amount, currency, version)
ledger_entries(id, transfer_id, account_id, direction, amount, created_at)
outbox(id, aggregate_id, event_type, payload, created_at, published_at)
inbox(consumer, event_id, processed_at)

3. JPA/query exercise

  1. Derived query cho idempotency lookup.
  2. JPQL projection cho transfer summary.
  3. @Lock(PESSIMISTIC_WRITE) hoặc @Version cho concurrent debit.
  4. @Modifying conditional transition PENDING -> POSTED, assert affected rows bằng 1.
  5. Native PostgreSQL query cho reconciliation/reporting; so sánh với JdbcTemplate.
  6. Chứng minh bulk update làm entity đang managed bị stale và sửa bằng clear/refresh/boundary.

4. Transaction evidence matrix

CaseExpected evidence
Return bình thườngDebit, credit, transfer và Outbox cùng commit.
Runtime exception sau debitKhông có partial ledger row.
Checked exceptionSo sánh mặc định với rollbackFor.
Catch-and-swallowChứng minh commit ngoài ý muốn rồi sửa.
Self-invocationREQUIRES_NEW không chạy; tách bean và retest.
saveAndFlush() rồi throwSQL xuất hiện nhưng transaction rollback.
Inner rollback-onlyOuter nhận UnexpectedRollbackException.

5. Correct transfer flow

@Transactional
public TransferId transfer(TransferCommand cmd) {
  IdempotencyRecord existing = idempotency.find(cmd.key(), cmd.hash());
  if (existing != null) return existing.outcome();
  AccountPair pair = accounts.lockInStableOrder(cmd.from(), cmd.to());
  pair.debitCredit(cmd.money());
  Transfer transfer = transfers.post(cmd);
  outbox.append(TransferPosted.from(transfer));
  return transfer.id();
}

Lock order ổn định tránh deadlock phổ biến; unique constraint là guard cuối cho duplicate. Không dùng floating point, không gửi Kafka/email trong transaction và không trả success trước commit.

6. Security banking

7. Messaging và reconciliation

Outbox relay có thể publish duplicate; consumer ghi Inbox/effect atomically. DLQ không phải nơi chôn message: có reason, owner, replay tool và audit. Reconciliation so transfer, ledger, Outbox/Inbox và external reference; repair idempotently hoặc đưa MANUAL_REVIEW.

8. AWS/IaC Auto Scaling lab

ALB -> ECS/Fargate service across 2+ AZ
             |-> Aurora/RDS PostgreSQL
             |-> SQS transfer-events
CloudWatch alarms -> Application Auto Scaling
Terraform: VPC, SG, IAM, ALB, ECS, RDS parameters, dashboards

9. Observability và acceptance

SLI: valid transfer đạt terminal correct outcome trong latency target. Dashboard gồm rate/error/p95-p99, active requests, Hikari wait, DB locks/connections, Outbox age, SQS backlog age, reconciliation mismatch và desired/running task count. Trace REST → transaction → Outbox → consumer; deployment marker nối regression với release.

10. Definition of Done