Inventory ManagementInventory Management

SKU trên 12 khoSKUs across 12 warehouses

2M

SKU trên 12 khoSKUs across 12 warehouses

request lúc flash salerequests during a flash sale

40k/s

request lúc flash salerequests during a flash sale

thời hạn giữ hàngreservation lifetime

15 min

thời hạn giữ hàngreservation lifetime

đơn bán vượt tồnoversold orders

0

đơn bán vượt tồnoversold orders

Order Service điều phối saga: giữ hàng ở Inventory Service, gọi thanh toán, rồi xác nhận hoặc bù trừ. Inventory DB là nguồn sự thật; Redis chỉ lọc bớt request lúc flash sale. Bật “Flash sale” hoặc “Thanh toán lỗi” để xem các nhánh còn lại.The Order Service runs the saga: reserve in the Inventory Service, take payment, then confirm or compensate. The inventory database is the source of truth; Redis only sheds load during a flash sale. Turn on “Flash sale” or “Payment fails” to see the other paths.

1. 1

   Bán vượt do đọc rồi trừOverselling from read-then-decrement

   Hai request cùng đọc available = 1 rồi cùng trừ. Dùng một câu UPDATE … SET available = available - n WHERE available >= n và kiểm tra số dòng bị đổi; thêm CHECK (available >= 0) làm lưới an toàn.Two requests read available = 1 and both decrement. Use one UPDATE … SET available = available - n WHERE available >= n, check the affected row count, and add CHECK (available >= 0) as a safety net.

   Unit of WorkSemaphore
2. 2

   Hàng bị giữ mãi bởi đơn bỏ dởStock stuck in abandoned orders

   Reservation có expires_at gắn với đơn. Expirer quét PENDING quá hạn bằng SKIP LOCKED, trả lại available và báo Order Service huỷ đơn.Each reservation has an expires_at tied to its order. The expirer picks stale PENDING rows with SKIP LOCKED, returns the units to available and tells the Order Service to cancel.

   StateWorker Pool
3. 3

   Flash sale dồn vào một dòngA flash sale hammers one row

   Hàng nghìn transaction chờ khoá cùng một dòng stock_level. Đặt Redis DECRBY (Lua) phía trước để chỉ khoảng số lượng hàng đi tới database; database vẫn kiểm tra lại. Có thể chia tồn thành nhiều bucket để giảm tranh chấp.Thousands of transactions queue on the lock of one stock_level row. Put a Redis DECRBY (Lua) in front so only about as many requests as units reach the database, which still re-checks. Splitting stock into buckets reduces contention further.

   SemaphoreRate Limiter
4. 4

   Thanh toán lỗi sau khi đã giữ hàngPayment fails after the reservation

   Không có transaction chung giữa Inventory và Payment. Saga phát lệnh bù trừ ReleaseReservation; lệnh idempotent nhờ điều kiện status = 'PENDING'. Sự kiện đi qua outbox để không mất.Inventory and Payment share no transaction. The saga issues a ReleaseReservation compensation, made idempotent by the status = 'PENDING' condition. Events go through an outbox so none are lost.

   SagaTransactional Outbox
5. 5

   Lệch giữa hệ thống và kho thậtDrift between system and shelf

   Hàng hỏng, mất, nhập sai. Mọi thay đổi đi qua bảng stock_movement chỉ thêm; job đối soát so tổng sổ với stock_level và với số kiểm kê của WMS, chênh lệch thành phiếu ADJUST có người duyệt.Damage, loss, mis-scans. Every change goes through an append-only stock_movement table; a reconciliation job compares the ledger sum with stock_level and with WMS counts, and turns differences into an approved ADJUST document.

   RepositorySpecification
6. 6

   Đơn lấy hàng từ nhiều khoOrders served from several warehouses

   Chọn kho theo quy tắc (gần nhất, đủ hàng, phí giao) bằng Specification. Giữ hàng ở từng kho theo thứ tự cố định (warehouse_id tăng dần) để tránh deadlock.Choose warehouses by rules (nearest, enough stock, shipping cost) through a Specification. Reserve in each warehouse in a fixed order (ascending warehouse_id) to avoid deadlocks.

   SpecificationRead-Write Lock

Java: giữ hàng bằng UPDATE có điều kiện và bù trừ idempotent. Go: cửa Redis cho flash sale, database kiểm tra lại và trả token khi thất bại.Java: reserve with a conditional UPDATE and an idempotent compensation. Go: the Redis gate for a flash sale, with the database re-checking and the token returned on failure.

@Service
@RequiredArgsConstructor
public class InventoryService {
    private final JdbcTemplate jdbc;
    private final ReservationRepository reservations;
    private final Clock clock;

    @Transactional
    public Reservation reserve(UUID orderId, String sku, long wh, int qty) {
        int rows = jdbc.update("""
            UPDATE stock_level
               SET available = available - ?, reserved = reserved + ?
             WHERE sku = ? AND warehouse_id = ? AND available >= ?""",1
            qty, qty, sku, wh, qty);
        if (rows == 0) {2
            throw new OutOfStockException(sku, wh, qty);
        }
        movement(sku, wh, -qty, "RESERVE", orderId);
        return reservations.save(Reservation.pending(orderId, sku, wh, qty,
                clock.instant().plus(Duration.ofMinutes(15))));
    }

    @Transactional                                   // saga compensation
    public void release(UUID orderId) {
        for (Reservation r : reservations.lockPendingByOrder(orderId)) {3
            jdbc.update("""
                UPDATE stock_level
                   SET available = available + ?, reserved = reserved - ?
                 WHERE sku = ? AND warehouse_id = ?""",
                r.getQty(), r.getQty(), r.getSku(), r.getWarehouseId());
            r.markReleased();
            movement(r.getSku(), r.getWarehouseId(), r.getQty(), "RELEASE", orderId);
        }
    }

    private void movement(String sku, long wh, int delta, String type, UUID ref) {
        jdbc.update("""4
            INSERT INTO stock_movement (sku, warehouse_id, delta, type, ref_id)
            VALUES (?, ?, ?, ?, ?)""", sku, wh, delta, type, ref);
    }
}

var ErrSoldOut = errors.New("inventory: sold out")

// Runs atomically inside Redis: no other command interleaves.
var gate = redis.NewScript(`
local left = redis.call("DECRBY", KEYS[1], ARGV[1])1
if left < 0 then
  redis.call("INCRBY", KEYS[1], ARGV[1])
  return -1
end
return left`)

type FlashSale struct {
	rdb *redis.Client
	db  *pgxpool.Pool
}

func (f *FlashSale) Reserve(ctx context.Context, orderID uuid.UUID, sku string, wh int64, qty int) error {
	key := "stock:" + sku
	left, err := gate.Run(ctx, f.rdb, []string{key}, qty).Int()
	if err != nil {
		return fmt.Errorf("redis gate: %w", err)
	}
	if left < 0 {
		return ErrSoldOut // rejected without touching PostgreSQL2
	}
	err = pgx.BeginFunc(ctx, f.db, func(tx pgx.Tx) error {
		tag, err := tx.Exec(ctx, `
			UPDATE stock_level SET available = available - $1, reserved = reserved + $1
			WHERE sku = $2 AND warehouse_id = $3 AND available >= $1`, qty, sku, wh)3
		if err != nil {
			return err
		}
		if tag.RowsAffected() == 0 {
			return ErrSoldOut // Redis said yes, the database says no
		}
		_, err = tx.Exec(ctx, `
			INSERT INTO reservation (order_id, sku, warehouse_id, qty, status, expires_at)
			VALUES ($1, $2, $3, $4, 'PENDING', now() + interval '15 minutes')`,
			orderID, sku, wh, qty)
		return err
	})
	if err != nil {
		f.rdb.IncrBy(context.WithoutCancel(ctx), key, int64(qty)) // return the token4
		return err
	}
	return nil
}

Mỗi pattern mở bài học tương ứng trong menu Pattern.Each one opens its lesson in the Patterns menu.