zoukankan      html  css  js  c++  java
  • redis 分布式锁

    分布式锁的主要目的就是 在分布式系统中,多机部署并发场景下,保证一个方法在同一时间内只能被同一个线程执行。

    下面是我用 .net core + csredis 简单实现的分布式锁。

     1   IRedisClient redis = new RedisClient("192.168.199.145", 6379);
     2   var styleNo = "styleNo";
     3   string[] keys = new string[1] { $"Goods:Stock:Lock:{styleNo}" };
     4   string[] argvs = new string[1] { Guid.NewGuid().ToString() };
     5   while (redis.Set(keys[0], argvs[0], 5, RedisExistence.Nx)!="OK")//如果不存在该键,写入该键值对,并设置过期时间,在同一个方法中判断设置,
                                                保证获取锁操作的多个命令的原子性,防止并发多处获取到锁。
    6 { 7 Thread.Sleep(50); 8 } 9 //业务逻辑 10 string script = "if redis.call('GET',KEYS[1])== ARGV[1] then return redis.call('del',KEYS[1]) else return 0 end"; 11 redis.Eval(script, keys, argvs);//此处用lua脚本保证删除操作的原子性,只删除自己的锁。

    用redis实现分布式锁,需要注意的几个问题:

    1,获取锁时,一定要用 命令 “set key value ex 5 nx ”。

        有人会用setnx先获取锁 ,然后expire去设置过期时间,这种情况如果程序在获取锁之后挂掉,没有设置上过期时间,就会导致死锁。

    2,删除锁时,需要判断当前的锁是否是自己设置的锁,因为可能存在业务处理时间超时,自己的锁被释放,已经有其他的人获取到了锁,这个时候如果误删了他人的锁,

      就会导致方法重入,出现数据错误等问题。

      这里用到lua脚本保证删除操作的原子性。

    3,如果redis挂掉了,业务就全部瘫痪了,所以要保证redis的高可用性。对于redis的高可用,我还没有太多的理解,暂时就不谈了。

  • 相关阅读:
    Zabbix 配置笔记
    Centos7安装MySQL5.7和Redis6.0流水账
    Elasticsearch, Kibana安装
    服务治理 Service Mesh & Kubernetes & Spring Cloud的异同 侵入式 非侵入式
    文思海辉 华为 银行 ODS (oCRM)
    Java Profiler JavaMemoryLeak Arthas
    动物:人类、熊类、马类 团队精神 与 鼓励
    BPMN Sketch Miner https://design.inf.usi.ch/bpmn-sketch-miner/#
    Architecture, Design and Web Information Systems Engineering
    Cloud design patterns
  • 原文地址:https://www.cnblogs.com/jasonbourne3/p/11286085.html
Copyright © 2011-2022 走看看