redis在.net架構中的應用(2)--併發和原子操做不可兼得

時間 2019-12-13

標籤 redis 架構應用併發原子不可兼得欄目 Redis 简体版

原文原文鏈接

在上一篇文章中，我主要向你們介紹了利用servicestack鏈接redis以及一些redis的基本數據類型，傳送門html

本文中，我將經過一個具體應用場景爲你們介紹redis中的併發和原子操做redis

其中用到的redis命令，請你們去redis官網查詢http://www.redis.io/commandssql

一 一個投票統計的應用場景數據庫

假設我要作一個實時統計投票數的應用，這個投票總共有A、B、C、D四個選項，由於是一個高併發的場景，因此我準備用redis來存儲投票數多線程

咱們首先利用redis-cli模擬這個過程，打開命令終端，新建一個hash類型的key，叫作TicketCount, 編號爲1，而後咱們將選項做爲其field值,併發

redis命令以下：nosql

而後咱們利用servicestack模擬投票場景，代碼以下：ide

 1  static void Main(string[] args)
 2         {
 3 
 4             RedisClient[] redisCli = new RedisClient[8]{
 5                 new RedisClient("192.168.101.165", 6379),
 6                 new RedisClient("192.168.101.165", 6379),
 7                 new RedisClient("192.168.101.165", 6379),
 8                 new RedisClient("192.168.101.165", 6379),
 9                 new RedisClient("192.168.101.165", 6379),
10                 new RedisClient("192.168.101.165", 6379),
11                 new RedisClient("192.168.101.165", 6379),
12                 new RedisClient("192.168.101.165", 6379)
13               };
14             ThreadPool.QueueUserWorkItem(o =>
15              {
16                  testTicketCount(redisCli[0], "A");
17              });
18             ThreadPool.QueueUserWorkItem(o =>
19             {
20                 testTicketCount(redisCli[1], "A");
21             });
22             ThreadPool.QueueUserWorkItem(o =>
23             {
24                 testTicketCount(redisCli[2], "B");
25             });
26             ThreadPool.QueueUserWorkItem(o =>
27             {
28                 testTicketCount(redisCli[3], "B");
29             });
30             ThreadPool.QueueUserWorkItem(o =>
31             {
32                 testTicketCount(redisCli[4], "C");
33             });
34             ThreadPool.QueueUserWorkItem(o =>
35             {
36                 testTicketCount(redisCli[5], "C");
37             });
38             ThreadPool.QueueUserWorkItem(o =>
39             {
40                 testTicketCount(redisCli[6], "D");
41             });
42             ThreadPool.QueueUserWorkItem(o =>
43             {
44                 testTicketCount(redisCli[7], "D");
45             });
46           
47             Console.Read();
48         }
49         /// <summary>
50         /// 對某個選項進行投票，投票數加1
51         /// </summary>
52         /// <param name="rediscli"></param>
53         /// <param name="field"></param>
54         internal static void testTicketCount(IRedisClient rediscli, string field)
55         {
56             int k = 0;
57             for (int i = 0; i <= 99; i++)
58             {
59 
60                 k = int.Parse(rediscli.GetValueFromHash("TicketCount", field))+1;
61                 rediscli.SetEntryInHash("TicketCount", field, k.ToString());
62             }
63         }

View Code

咱們設想的結果是A、B、C、D四個選項各得到了200票，可是對多線程比較熟悉的同窗立刻就能看出問題了，函數

事實上最終的結果是高併發

沒錯，在一個線程執行GetValueFromHash和SetEntryInHash兩條命令的時候，另外一個線程修改了key的值，破壞了操做的原子性

這個過程當中，A選項明顯丟掉了一張投票。

二 Nosql中的原子性

要保證數據操做的原子性，在傳統的RDBMS應用中，咱們首先想到的就是事物和鎖，可是在這個場景中，咱們須要得到保證{get key;set key}這兩步

操做的原子性，咱們須要得到key的值，因此沒法用到事物。

讓咱們回到nosql的本質上來，來談談鎖的運用，有興趣的同窗能夠看看關於nosql的CAP原則和傳統的RDBMS的ACID原則：

從上圖中，咱們能夠看到，NoSQL系統更加註重性能，是不保證一客戶端的兩個操做的原子性保證的

（redis中的事物比較特殊，我將會在下一篇文章中討論）

三利用hincrby

幸好redis還提供hincrby命令，也就是直接對hset某個字段的值加上某個整數

也就是對某個hash key中的某個value 值提供加一操做。咱們能夠將TicketCount函數修改一下：

 1     internal static void testTicketCount(IRedisClient rediscli, string field)
 2         {
 3             int k = 0;
 4             for (int i = 0; i <= 99; i++)
 5             {
 6                 rediscli.IncrementValueInHash("TicketCount", field, 1);
 7                 //k = int.Parse(rediscli.GetValueFromHash("TicketCount", field))+1;
 8                 //rediscli.SetEntryInHash("TicketCount", field, k.ToString());
 9             }
10         }