c# redis 利用锁(StackExchange.Redis LockTake)来保证数据在高并发情况下的正确性
2018-05-07 11:35
615 查看
之前有写过一篇介绍c#操作redis的文章 http://www.cnblogs.com/axel10/p/8459434.html ,这篇文章中的案例使用了StringIncrement来实现了高并发情况下key值的稳定增加,但如果要用锁的方式而不是StringIncrement方法,那该怎么做呢?
LockTake涉及到三个参数:key,token和TimeSpan,分别表示redis数据库中该锁的名称、锁的持有者标识和有效时间。下面将用一个多线程增加key值的案例来演示LockTake/LockRelease的用法。
using StackExchange.Redis; using StackExchange.Redis.Extensions.Core; using StackExchange.Redis.Extensions.Core.Configuration; using StackExchange.Redis.Extensions.Newtonsoft; using System; using System.Threading; namespace RedisTest { class Program { static RedisValue Token = Environment.MachineName; static RedisKey Key = "lock"; static void Ins() { Thread thread = new Thread(() => { for (int i = 0; i < 100; i++) { if (client.Database.LockTake(Key, Token, TimeSpan.MaxValue)) //key表示的是redis数据库中该锁的名称,不可重复。 Token用来标识谁拥有该锁并用来释放锁。TimeSpan表示该锁的有效时间。 { try { int key = client.Get<int>("key"); client.Add("key", key + 10); } catch (Exception e) { Console.WriteLine(e); throw; } finally { client.Database.LockRelease(Key, Token); } } else { Console.WriteLine("locking"); while (!TryAgain(10)) { Thread.Sleep(1); } } } }); thread.Start(); } private static StackExchangeRedisCacheClient client; static void Main(string[] args) { var redisConfiguration = new RedisConfiguration() //配置 { Hosts = new RedisHost[] { new RedisHost() {Host = "127.0.0.1", Port = 6379} } }; client = new StackExchangeRedisCacheClient(new NewtonsoftSerializer(), redisConfiguration); client.Add("key", 0); for (int j = 0; j < 10; j++) { Ins(); } Thread.Sleep(2000); int i = client.Get<int>("key"); Console.WriteLine(i); Console.ReadKey(); } static bool TryAgain(int value) { if (client.Database.LockTake(Key, Token, TimeSpan.MaxValue)) { try { int key = client.Get<int>("key"); client.Add("key", key + value); } catch (Exception e) { Console.WriteLine(e); throw; } finally { client.Database.LockRelease(Key, Token); } return true; } else { return false; } } } }
相关文章推荐
- C# 基于StackExchange.Redis.dll利用Redis实现分布式Session
- 利用事物(隔离级别)+锁方式串行化保证在高并发环境下数据的一致性代码
- [C#] ServiceStack.Redis如何批量的pop数据?
- 多线程,高并发的情况下操作redis当中的数据,如何加锁?
- [C#] ServiceStack.Redis如何批量的pop数据?
- 【redis学习总结】C# StackExchange Redis
- 并发下,使用redis防止数据重复插入(数据库未对表字段设置唯一情况下)
- Redis中的StackExchange.redis在C#中的应用
- c# redis 操作类库推荐:StackExchange.Redis.Extensions
- C#中使用 StackExchange.Redis 封装属于自己的 RedisHelper
- c#使用 StackExchange.Redis 封装 RedisHelper
- Redis C# 驱动 StackExchange.Redis 应用实例
- C# Redis使用之StackExchange
- StackExchange.Redis 使用-配置 (四)
- C#利用ODP.NET往oracle中高效插入百万数据
- 利用R将本地数据文件读入redis数据库中
- 利用java代码操作线上redis数据(增删改查)
- 利用run-as命令在不root情况下读取data下面的sqlite数据
- (转)如何利用书签向word文档读取或写入数据[C#]
- 关于网站大并发情况下的数据的初始化如何处理。