서버 하나에 접속해 키를 획득하고 바로 반납합니다.
const wait = 5000;
const lease = 30000;
const broker = TicketBroker.connect("127.0.0.1:5225");
try {
await broker.waitReady(5000);
const ticket = await broker.acquire("key", wait, lease);
await ticket.release();
console.log("pass");
} finally {
broker.close();
}여러 트랜잭션이 계좌별 락으로 상호배제하며 입금/출금을 동시에 실행해도 잔액이 항상 시작값으로 돌아오는지 검증하는 예제입니다.
async function transaction(broker: TicketBroker, account: number, delta: number): Promise<void> {
const key = `account-${account}`;
let ticket: Ticket;
try {
ticket = await broker.acquire(key, WAIT_MS, LEASE_MS);
} catch (e) {
console.error(`account ${account} acquire failed: ${e}`);
return;
}
const before = balances[account];
await new Promise((resolve) => setImmediate(resolve));
const after = before + delta;
balances[account] = after;
const [action, sign] = delta < 0 ? ["withdraw", "-"] : ["deposit", "+"];
console.info(`account ${account} ${action} ${sign}$${AMOUNT} -> $${after}`);
ticket.close(); // 백그라운드 자동 반납
}전체 예제는 example.test.ts, bank.test.ts, bench.test.ts에서 확인하세요.