menuTicketing

Ticketing Go 库

GitHub

代码仓库

示例

基础示例

这是连接到一台服务器后获取 key 并立即释放的最简示例。由于 Go 没有 async/await, 这里以阻塞式 API 结合后台 goroutine 的形式提供。

go
wait := 5 * time.Second
lease := 30 * time.Second

broker := Connect("127.0.0.1:5225")
defer broker.Close()
broker.WaitReady(5 * time.Second)

ticket, err := broker.Acquire("key", wait, lease)
if err != nil {
    log.Fatalf("acquire: %v", err)
}
if _, err := ticket.Release(); err != nil {
    log.Fatalf("release: %v", err)
}

fmt.Println("pass")

并发示例(分布式锁)

这是一个验证示例:多个 goroutine 通过账户级锁互斥地反复存取款,确认余额最终总能回到初始值。

go
transaction := func(account int, delta int64) {
    key := fmt.Sprintf("account-%d", account)
    ticket, err := broker.Acquire(key, bankWait, bankLease)
    if err != nil {
        log.Printf("account %d acquire failed: %v", account, err)
        return
    }
    before := balances[account]
    runtime.Gosched()
    after := before + delta
    balances[account] = after
    ticket.Close() // 后台自动释放

    action, sign := "deposit", "+"
    if delta < 0 {
        action, sign = "withdraw", "-"
    }
    log.Printf("account %d %s %s$%d -> $%d", account, action, sign, bankAmount, after)
}

完整示例请参阅 example_test.gobank_example_test.gobench_test.go