Beego中需绕过其cache模块，直连redis.Client，用SET NX EX加锁并生成唯一value，解锁必须通过Lua脚本原子校验value，配合context超时控制与panic安全的defer释放。
Beego 里怎么用 Redis 实现分布式锁
Beego 本身不内置分布式锁，但可以无缝集成 go-redis/redis/v8 或 Redisson（需 Java 环境）的 Go 客户端。生产环境推荐直接用 go-redis + Lua 脚本封装，避免依赖外部 Java 服务。
关键点不是“能不能加锁”，而是加锁后能否防住并发、不误删、不提前过期。常见错误是只调 SET key value EX 10 NX 就完事，没做释放校验和续期，结果业务耗时 12 秒，第 10 秒锁自动过期，第 11 秒另一个请求进来，两个请求同时扣库存。
- 加锁必须带唯一 value（如随机 base64 字符串），不能写死成
"1"，否则解锁时无法判断归属 - 解锁必须用 Lua 脚本原子执行：
if redis.call("get", KEYS[1]) == ARGV[1] then return redis.call("del", KEYS[1]) else return 0 end - Beego 的 controller 方法里别直接阻塞等待锁，要用
context.WithTimeout控制最大等待时间，超时就返回503 Service Unavailable - 不要在
defer Unlock()里释放锁——如果业务 panic，defer可能不执行；应统一用defer+recover+ 显式Unlock
为什么不用 Beego 自带的 cache 模块做锁
Beego 的 cache 模块（如 memory、redis 驱动）只提供简单 Get/Put，不支持 SET NX PX 原子操作，也不保证解锁的归属校验。拿 cache.NewCache("redis", `{"conn":"127.0.0.1:6379"}`) 直接 Put("lock:order:123", "1", 10)，会导致：
- 加锁非原子：先
Get判断再Put，中间可能被其他节点抢占 - 解锁无校验：任何代码都能调
cache.Delete("lock:order:123")，等于裸奔 - 没有看门狗：业务慢于 TTL 就必然出问题，而 cache 模块不提供自动续期接口
所以哪怕用了 Beego 的 redis cache 配置，锁逻辑也得绕开它，直连 redis.Client 实例。
ZooKeeper 在 Beego 中实现分布式锁的坑
Beego 可以通过 github.com/samuel/go-zookeeper/zk 连 ZooKeeper，但要注意：InterProcessMutex 这类高级锁原语是 Curator（Java）提供的，Go 客户端只提供基础 session 和 node 操作。自己实现临时顺序节点 + watch 机制非常容易出错。
- ZooKeeper 的 EPHEMERAL_SEQUENTIAL 节点创建不是原子的，需配合
exists + create循环，网络抖动时可能创建失败却未感知 - watch 是一次性触发，必须在每次回调里重新
exists下一个节点，漏一次就失去锁感知能力 - Beego 默认不管理 zk 连接生命周期，若 controller 里每次新建
zk.Connect，会快速打满 zk 连接数（默认 60） - zk 的
session timeout通常设为 20–40 秒，比 Redis 的毫秒级响应慢一个数量级，不适合秒杀类低延迟场景
除非你已有稳定 ZooKeeper 集群且团队熟悉其 watcher 模型，否则在 Beego 中优先选 Redis 方案。
Beego Controller 里防并发的最小安全模式
一个典型订单创建接口，既要防重复提交，又要防库存超卖，不能只靠前端按钮禁用或防重 token——后端必须有分布式锁兜底。
示例结构（省略 error 处理）：
func (c *OrderController) Create() {
orderId := c.GetString("order_id")
lockKey := "lock:order:" + orderId
ctx, cancel := context.WithTimeout(c.Ctx.Request.Context(), 3*time.Second)
defer cancel()
dl := NewDistributedLock(c.redisClient, lockKey, 15*time.Second)
ok, _ := dl.TryLock(ctx)
if !ok {
c.Data["json"] = map[string]interface{}{"code": 409, "msg": "busy, retry later"}
c.ServeJSON()
return
}
defer func() {
if r := recover(); r != nil {
dl.Unlock(ctx)
panic(r)
}
dl.Unlock(ctx)
}()
// 执行扣库存、生成订单等业务
c.doCreateOrder(orderId)
}
注意：锁 key 必须包含业务标识（如 order_id），不能全局用一个 "global_lock"；过期时间必须 > 业务最长耗时 × 1.5，且建议开启独立 goroutine 调用 RefreshLock 做看门狗（尤其当业务含 HTTP 外部调用时）。
