Ticketing Javascript / Typescript 库 ​

仓库 ​

示例 ​

基础示例 ​

应用启动时创建一个broker并共享。wait=0是不入队的一次立即尝试，最大255秒；lease为1–250秒。最后的minimum-work budget为必填，可为0。客户端将不足一秒的值向上取整，并在发送前拒绝越界值或大于规范化lease的budget，绝不clamp。

import { TicketBroker } from 'saro-ticketing'

const broker = TicketBroker.connect('127.0.0.1:5225')
await broker.waitReady(5)

const ticket = await broker.acquire('key', 5, 30, 2)
const token = ticket.token
// In the same DB transaction: verify/update token high-water and perform the business write.
await ticket.release()

自动close/drop只是bounded best-effort release；需要确认结果时使用explicit release API。token必须在同一DB transaction中fence受保护写入。

需要了解的行为 ​

• 只要request可能已发送一个byte而丢失确定响应，结果就是Indeterminate。客户端不以相同owner自动重发A，caller不得进入critical section。
• 发送前cancel为unsent；possible-send后cancel关闭session。若并发parse到grant token，则尝试bounded exact-token补偿release。
• M、所有E、malformed/oversized/unknown response均为session-fatal；未确定的possible-send acquire为Indeterminate。
• B是capacity的确定拒绝并立即返回。内部不retry；caller可在application backoff后用新owner开始新acquire。
• explicit/compensating release仅在call/enqueue起绝对5秒内重试exact token。R成功，N表示已不存在或不是current token；没有最终响应是error，不能推定成功。
• 只有保守剩余时间为正且足够required work budget时才返回Ticket。超过250秒的work在发送前unsupported。
• DB fencing强制使用token：在同一DB transaction中拒绝token <= stored_high_water，更新high-water并执行business write，commit/rollback结束后release。

安全选项(Token · TLS) ​

所有选项都是可选的。token 应与服务器的 client_tokens 一致,TLS 有四种模式: 关闭 / 系统信任存储 / 指定 CA / 跳过校验(仅测试用)。

const broker = new TicketBroker({
    addrs: ['10.0.0.1:5225', '10.0.0.2:5225', '10.0.0.3:5225'],
    token: '123',
    tls: 'system-roots', // 'off' | 'system-roots' | 'insecure-skip-verify' | { ca: 'ca.crt' }
})

服务器端的令牌、TLS、集群配置可以在 Ticketing 服务器部署页面生成。