Redis锁的简单应用

本文版权归博客园和作者本人吴双共同所有。转载爬虫请注明地址，博客园蜗牛 http://www.cnblogs.com/tdws/p/5712835.html

蜗牛Redis系列文章目录http://www.cnblogs.com/tdws/tag/NoSql/

Redis Cluster http://www.cnblogs.com/tdws/p/7710545.html

其实说多线程修改数据也不合适，毕竟redis服务端是单线程的，所有命令串行执行，只是在客户端并发发送命令的时候，导致串行的命令一些排列问题和网络时间差等造成数据不一致。本文虽然是数字的加减，但是为了说明锁的情况，故意不是用原子命令incr。也并非分布式锁的正确实现，没有考虑一些重入性等，稍后会整理一篇分布式锁的实践。

Redis分布式锁 http://www.cnblogs.com/tdws/p/5808528.html

ZK+curator 分布式锁 http://www.cnblogs.com/tdws/p/5874686.html

先配上一个简易的RedisHelper，一个set值，一个get值，一个设置并发锁，以便在我后面的操作中，你能清楚我究竟做了什么。

public class RedisHelper{public RedisClient client = new RedisClient("127.0.0.1", 6379);public void Set<T>(string key, T val){client.Set(key, val);}public T Get<T>(string key){var result = client.Get<T>(key);return result;}public IDisposable Acquire(string key){return  client.AcquireLock(key);}}

下面看一下并发代码，我只new了两个Thread。两个线程同时想访问同一个key,分别访问五万次，在并发条件下，我们很难保证数据的准确性，请比较输出结果。

static void Main(string[] args){RedisHelper rds = new RedisHelper();rds.Set<int>("mykey1", 0);Thread myThread1 = new Thread(AddVal);Thread myThread2 = new Thread(AddVal);myThread1.Start();myThread2.Start();Console.WriteLine("等待两个线程结束");Console.ReadKey();}public static void AddVal(){RedisHelper rds = new RedisHelper();for (int i = 0; i < 50000; i++){int result = rds.Get<int>("mykey1");rds.Set<int>("mykey1", result + 1);}Console.WriteLine("线程结束，输出" + rds.Get<int>("mykey1"));}

是的，和我们单线程，跑两个50000,会输出100000。现在是两个并发线程同时跑在由于并发造成的数据结果往往不是我们想要的。那么如何解决这个问题呢，Redis已经为我们准备好了！

你可以看到我RedisHelper中有个方法是 public IDisposable Acquire(string key)。 也可以看到他返回的是IDisposable，证明我们需要手动释放资源。方法内部的 AcquireLock正是关键之处，它像redis中索取一把锁头，被锁住的资源，只能被单个线程访问，不会被两个线程同时get或者set,这两个线程一定是交替着进行的，当然这里的交替并不是指你一次我一次，也可能是你多次，我一次，下面看代码。

static void Main(string[] args){RedisHelper rds = new RedisHelper();rds.Set<int>("mykey1", 0);Thread myThread1 = new Thread(AddVal);Thread myThread2 = new Thread(AddVal);myThread1.Start();myThread2.Start();Console.WriteLine("等待两个线程结束");Console.ReadKey();}public static void AddVal(){RedisHelper rds = new RedisHelper();for (int i = 0; i < 50000; i++){using (rds.Acquire("lock")){int result = rds.Get<int>("mykey1");rds.Set<int>("mykey1", result + 1);}}Console.WriteLine("线程结束，输出" + rds.Get<int>("mykey1"));}

可以看到我使用了using,调用我的Acquire方法获取锁。

输出结果最后是100000，正是我们要的正确结果。前面的8W+是因为两个线程之一先执行结束了。

还有，在正式使用的过程中，建议给我们的锁，使用后删除掉，并加上一个过期时间，使用expire。

以免程序执行期间意外退出，导致锁一直存在，今后可能无法更新或者获取此被锁住的数据。

你也可以尝试一下不设置expire，在程序刚开始执行时，关闭console,重新运行程序，并且在redis-cli的操作控制台，get你锁住的值，将会永远获取不到。

所有连接此redis实例的机器，同一时刻，只能有一个获取指定name的锁.

下面是StackExchange.Redis的写法

var info = "name-"+Environment.MachineName;//如果5秒不释放锁 自动释放。避免死锁if (db.LockTake("name", info, TimeSpan.FromSeconds(5))){try{}catch (Exception ex){}finally{db.LockRelease("name", token);}}

转载于:https://www.cnblogs.com/williamjie/p/11250578.html

Redis锁的简单应用相关推荐

【求锤得锤的故事】Redis锁从面试连环炮聊到神仙打架。
来自:why技术又到了一周一次的分享时间啦,老规矩,还是先荒腔走板的聊聊生活. 有上面的图是读大学的时候,一次自行车骑行途中队友抓拍的我的照片.拍照的地方,名字叫做牛背山,一个名字很 low,实际很 ...
解锁redis锁的正确姿势
解锁redis锁的正确姿势 redis是php的好朋友,在php写业务过程中,有时候会使用到锁的概念,同时只能有一个人可以操作某个行为.这个时候我们就要用到锁.锁的方式有好几种,php不能在内存中用锁 ...
必看企业级Redis锁资产巡检扫描业务场景实现（加锁限制扫描次数）
Redis实现资产巡检扫描前言一.需求一:限制扫描次数 1.1 业务分析 1.2 代码实现二.需求二:限制同一个位置同一时间只能有一个人扫描 1.1 业务分析 1.2 伪代码实现 1.3 具体代 ...
java加redis锁
redis锁的作用: 防止接口重复提交数据 maven包: <dependency><groupId>org.redisson</groupId><artif ...
线上故障之-redis锁处理幂等性失效和幂等性问题解决方案
线上故障之-redis锁处理幂等性失效和幂等性问题解决方案 redis锁处理幂等性失效事务传播bug try bug 幂等性设计方法 1. insert前先select 2. 加悲观锁 3. 加乐观 ...
通过Expire实现Redis锁机制
在我们的业务系统中,可能因为某种原因,用户会不断的点击表单提交按钮,为了较少对系统的无意义访问.暴力提交以及用户体验,我们利用redis的过期时间简单的实现了一种Redis锁当用户提交表单的时候 ...
线上故障之-雪花算法重复、序列化、redis锁失效、double精准计算
线上故障之-雪花算法重复.序列化.redis锁失效.double精准计算雪花算法重复问题发现定位影响范围解决方案扩展-雪花算法原理分析: 序列化运营商 POP 裸机搭售自营套餐事故分析 ...
RedisTemplate实现Redis锁
Redis锁项目中使用redis锁主要是依据 redis setnx命令的特性(SETNX:在指定的 key 不存在时,为 key 设置指定的值. 设置成功,返回 1 设置失败,返回 0 ) 实现R ...
redis锁处理并发问题
redis锁处理并发问题 redis锁处理高并发问题十分常见,使用的时候常见有几种错误,和对应的解决办法,在此进行自己的总结和整理. set方式 setnx方式 setnx+getset方式 set方 ...

Redis锁的简单应用

Redis锁的简单应用相关推荐

最新文章

热门文章