Ticketing Rust 库 ​

仓库 ​

示例 ​

基础示例 ​

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

use std::time::Duration;
use ticketing::TicketBroker;

let broker = TicketBroker::connect(["127.0.0.1:5225"]);
broker.wait_ready(Duration::from_secs(5)).await;

let ticket = broker.acquire(
    "key",
    Duration::from_secs(5),
    Duration::from_secs(30),
    Duration::from_secs(2),
).await?;
let token = ticket.token();
// In the same DB transaction: verify/update token high-water and perform the business write.
ticket.release().await?;

自动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 / 跳过校验(仅测试用)。

use ticketing::{TicketBroker, TlsMode};

let broker = TicketBroker::builder()
    .addrs(["10.0.0.1:5225", "10.0.0.2:5225", "10.0.0.3:5225"])
    .token("123")
    .tls(TlsMode::SystemRoots)
    // .tls(TlsMode::Ca("ca.crt".into()))
    // .tls(TlsMode::InsecureSkipVerify)
    .connect()?;

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