Ticketing Javascript / Typescript 库 ​

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(); // 后台自动释放
}