• 企业400电话
  • 微网小程序
  • AI电话机器人
  • 电商代运营
  • 全 部 栏 目

    企业400电话 网络优化推广 AI电话机器人 呼叫中心 网站建设 商标✡知产 微网小程序 电商运营 彩铃•短信 增值拓展业务
    redis分布式锁的go-redis实现方法详解

    在分布式的业务中 , 如果有的共享资源需要安全的被访问和处理 , 那就需要分布式锁

    分布式锁的几个原则;

    1.「锁的互斥性」:在分布式集群应用中,共享资源的锁在同一时间只能被一个对象获取。

    2. 「可重入」:为了避免死锁,这把锁是可以重入的,并且可以设置超时。

    3. 「高效的加锁和解锁」:能够高效的加锁和解锁,获取锁和释放锁的性能也好。

    4. 「阻塞、公平」:可以根据业务的需要,考虑是使用阻塞、还是非阻塞,公平还是非公平的锁。

    redis实现分布式锁主要靠setnx命令

    1. 当key存在时失败 , 保证互斥性

    2.设置了超时 , 避免死锁

    3.利用mutex保证当前程序不存在并发冲突问题

    package redis
    
    import (
     "context"
     "github.com/go-redis/redis/v8"
     "github.com/taoshihan1991/miaosha/setting"
     "log"
     "sync"
     "time"
    )
    
    var rdb *redis.Client
    var ctx = context.Background()
    var mutex sync.Mutex
    
    func NewRedis() {
     rdb = redis.NewClient(redis.Options{
      Addr:  setting.Redis.Ip + ":" + setting.Redis.Port,
      Password: "", // no password set
      DB:  0, // use default DB
     })
    }
    func Lock(key string) bool {
     mutex.Lock()
     defer mutex.Unlock()
     bool, err := rdb.SetNX(ctx, key, 1, 10*time.Second).Result()
     if err != nil {
      log.Println(err.Error())
     }
     return bool
    }
    func UnLock(key string) int64 {
     nums, err := rdb.Del(ctx, key).Result()
     if err != nil {
      log.Println(err.Error())
      return 0
     }
     return nums
    }

    到此这篇关于redis分布式锁的go-redis实现方法的文章就介绍到这了,更多相关redis分布式锁内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

    您可能感兴趣的文章:
    • 详解一种用django_cache实现分布式锁的方式
    • go如何利用orm简单实现接口分布式锁
    • mongo分布式锁Java实现方法(推荐)
    • 浅谈Redis分布式锁的正确实现方式
    • Java使用Redisson分布式锁实现原理
    • Redis Template实现分布式锁的实例代码
    • Go 语言下基于Redis分布式锁的实现方式
    上一篇:从零搭建SpringBoot2.X整合Redis框架的详细教程
    下一篇:Redis 缓存实现存储和读取历史搜索关键字的操作方法
  • 相关文章
  • 

    © 2016-2020 巨人网络通讯 版权所有

    《增值电信业务经营许可证》 苏ICP备15040257号-8

    redis分布式锁的go-redis实现方法详解 redis,分布式,锁,的,go-redis,