ACID Transactions và Database Locking: Chống race condition khi chuyển tiền

ACID Transactions và Database Locking: Chống race condition khi chuyển tiền | Shanverse

Codeplain text

1BEGIN2  claim idempotency key3  validate accounts and currency4  lock rows or perform versioned CAS5  debit source6  credit destination7  append balanced ledger entries8  mark transfer committed9  insert outbox event10COMMIT11publish outbox asynchronously

Codesql

1CREATE TABLE accounts (2  id UUID PRIMARY KEY,3  balance_minor BIGINT NOT NULL CHECK (balance_minor >= 0),4  version BIGINT NOT NULL DEFAULT 0,5  updated_at TIMESTAMPTZ NOT NULL DEFAULT now()6);78CREATE TABLE transfers (9  id UUID PRIMARY KEY,10  idempotency_key TEXT NOT NULL UNIQUE,11  from_account_id UUID NOT NULL REFERENCES accounts(id),12  to_account_id UUID NOT NULL REFERENCES accounts(id),13  amount_minor BIGINT NOT NULL CHECK (amount_minor > 0),14  status TEXT NOT NULL CHECK (status IN ('pending', 'committed', 'failed')),15  created_at TIMESTAMPTZ NOT NULL DEFAULT now(),16  CHECK (from_account_id <> to_account_id)17);1819CREATE TABLE ledger_entries (20  id UUID PRIMARY KEY,21  transfer_id UUID NOT NULL REFERENCES transfers(id),22  account_id UUID NOT NULL REFERENCES accounts(id),23  direction TEXT NOT NULL CHECK (direction IN ('debit', 'credit')),24  amount_minor BIGINT NOT NULL CHECK (amount_minor > 0),25  UNIQUE (transfer_id, account_id, direction)26);

Codesql

1BEGIN;23SELECT id, balance_minor4FROM accounts5WHERE id IN ($1, $2)6ORDER BY id7FOR UPDATE;89-- Ứng dụng kiểm tra tài khoản nguồn còn đủ tiền.1011UPDATE accounts12SET balance_minor = balance_minor - $3,13    version = version + 1,14    updated_at = now()15WHERE id = $1;1617UPDATE accounts18SET balance_minor = balance_minor + $3,19    version = version + 1,20    updated_at = now()21WHERE id = $2;2223INSERT INTO ledger_entries (...); -- một debit và một credit24UPDATE transfers SET status = 'committed' WHERE id = $4;2526COMMIT;

ACID Transactions và Database Locking: Chống race condition khi chuyển tiền

Bài toán: hai request cùng tiêu một số dư

Bình luận

ACID trong ngữ cảnh chuyển tiền

Mô hình dữ liệu tối thiểu

Phương án 1: Pessimistic Lock

Vì sao phải khóa theo thứ tự cố định?

Ưu điểm

Nhược điểm

Phương án 2: Optimistic Lock

Ưu điểm

Nhược điểm

Một lựa chọn rất mạnh: cập nhật có điều kiện nguyên tử

Pessimistic hay Optimistic?

Isolation level: Read Committed chưa giải quyết mọi thứ

Idempotency: retry không được chuyển tiền lần hai

Transaction boundary chuẩn

Các lỗi triển khai thường gặp

Kiểm thử race condition đúng cách

Quan sát trong production

Checklist production

Kết luận

Idempotency Key trong thanh toán: Bấm 10 lần vẫn chỉ trừ tiền một lần

Event Sourcing và CQRS trong Core Banking: Vì sao Ledger là nguồn sự thật?

Tích hợp VietQR và QR động: Xử lý Webhook/IPN để tự động xác nhận đơn hàng

Bài toán: hai request cùng tiêu một số dư

Bình luận

ACID trong ngữ cảnh chuyển tiền

Mô hình dữ liệu tối thiểu

Phương án 1: Pessimistic Lock

Vì sao phải khóa theo thứ tự cố định?

Ưu điểm

Nhược điểm

Phương án 2: Optimistic Lock

Ưu điểm

Nhược điểm

Một lựa chọn rất mạnh: cập nhật có điều kiện nguyên tử

Pessimistic hay Optimistic?

Isolation level: Read Committed chưa giải quyết mọi thứ

Idempotency: retry không được chuyển tiền lần hai

Transaction boundary chuẩn

Các lỗi triển khai thường gặp

Kiểm thử race condition đúng cách

Quan sát trong production

Checklist production

Kết luận

Bài viết liên quan

Idempotency Key trong thanh toán: Bấm 10 lần vẫn chỉ trừ tiền một lần

Event Sourcing và CQRS trong Core Banking: Vì sao Ledger là nguồn sự thật?

Tích hợp VietQR và QR động: Xử lý Webhook/IPN để tự động xác nhận đơn hàng