memcache之CAS實現全局同步鎖

在項目過程當中，須要一個全局的鎖。在本來的項目中每每是經過鎖數據庫的表來實現的。

在高併發的需求下，咱們每每要須要對很是多的表進行加鎖。加鎖的表越少，鎖資源越少，競爭越嚴重。

不過好在mysql數據還提供了一種不須要表的加鎖方式。

加鎖："SELECT GET_LOCK('{$key}', {$timeout}) AS get_lock";
解鎖："SELECT RELEASE_LOCK('{$key}') AS release_lock";

 

此次打算換個方式。其實一開始有想到兩種方式。

1）zookeeper的鎖服務

zookeeper是些分佈式軟件的好幫手.功能強大,提供分佈式索,命名服務等功能.

2）memcache之CAS 

重點介紹memcache如何實bool get_lock(unsigned uin, int item_id)

 1 bool get_lock(unsigned uin, int item_id)
 2 {
 5     time(&expiration);
 6     expiration += 5;
 7     memc = memcached_create(NULL);
 8 　　//添加server list
 9     server = memcached_server_list_append(NULL,"IP",PORT,&rc);
10     rc=memcached_server_push(memc,server);
11     memcached_server_list_free(server);
12     memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL, 1);
13 
14 
15     std::stringstream key_ss;
16     key_ss <<uin<<"-"<< __FILE__ <<"-"<<item_id ;
17     string key = key_ss.str();
18     string value = "0";
19     size_t value_length = value.length();
20     size_t key_length = key.length();
21 
22     //獲取數據
23     char* result = memcached_get(memc,key.c_str(),key_length,&value_length,&flags,&rc);
24     if(rc == MEMCACHED_SUCCESS)
25     {
26 　　　　//根據value值 0鎖空閒  >0表示鎖正在被其它人持有
27         if( strcmp(result, "0") != 0)
28             return false;
29     }
30     else
31     {
32         value = "0";
33         rc = memcached_add(memc,key.c_str(),key.length(),value.c_str(),value.length(),expiration,flags);
34         if(rc!=MEMCACHED_SUCCESS)
35         {
36             return false;
37         }
38 
39     }
40 
41     char pid[64];
42     bzero(pid, sizeof(pid));
43     value = getpid();
44     snprintf(pid, 64, "%d", getpid());
45 
46     //設置value爲一個非0值(此處設置爲當前的進程ID) 併發的請求調用memcached_cas只有一請求可以返回成功
47     rc = memcached_cas(memc, key.c_str(), key.length(),pid, 64, 0, 0,  memc->result.item_cas);
48     if(rc == MEMCACHED_SUCCESS)
49     {
50         //此處略顯多餘 由於只有設置成功的請求才能到達此處
51         result = memcached_get(memc,key.c_str(),key_length,&value_length,&flags,&rc);if(rc == MEMCACHED_SUCCESS)
52         {
53       
54             if( strcmp(result, pid) == 0)
55                 return true;//
56 　　　　　　  else
57 　　　　　　　　　return false;
58 
59         }
60 
61         return false;
62     }else
63     {
64         return  false;
65     }
66 
67 }

 

 

上述代碼,實際上是藉助memecache<key,value>對併發設置value的併發處理來實現鎖的邏輯.memcache可以保證同時只有一個請求設置成功,其它失敗.

 

在開發程序的過程當中,對併發的處理必定要謹慎.