xsync

分布式锁

基于Redis实现分布式锁

推荐阅读

• https://segmentfault.com/a/1190000038988087
• http://kaito-kidd.com/2021/06/08/is-redis-distributed-lock-really-safe/

使用说明

1. 锁必须设置过期时间，默认是1s，可以根据接口的超时时间设置
2. 常见的并发都是用户维度的，例如在两个平台发起同样的请求，因此锁的key一般需要与uid绑定
3. 对于Redis宕机导致锁丢失带来的不可控影响没有保证(如果redis可以提供高可用服务，基本可以忽略此情况)

使用方式

import "github.com/SigmaGavin/slardar/pkg/xsync"


// 经典场景，每日签到，一个用户只能签一次，签到会送积分和发券和累计
name := "default"                                                    // 使用默认的redis集群
key := fmt.Sprintf("test_%d_%s", uid, time.Now.Format("20060102"))   // 分布式锁的key格式

async := xsync.New(name, key)
// async.SetExp(锁超时时间,单位为秒，默认1s)

err = async.Run(ctx, func(ctx context.Context) error {
    // 1. 送积分 
    err := db.AddIntegration(ctx, uid, 10)
    if err != nil {
        return	
    }
    
    // 2. 发券
    err := db.AddCoupon(ctx, uid, 1)
    if err != nil {
        return
    }
    
    // 3. 累计签到
    err := db.AddCheck(ctx, uid)
    
    // 4. 其他业务逻辑
})


if IsMissingLockErr(err) {
    // 说明并发时未获得锁
    fmt.Println("系统繁忙，请重试~~~雅蠛蝶~~~")
    return
}

if err != nil {
    // 出现的其他错误
	return
}