memcache之CAS实现全局同步锁

yanhuanhero

　　在项目过程中，需要一个全局的锁。在原本的项目中往往是通过锁数据库的表来实现的。
　　在高并发的需求下，我们往往要需要对非常多的表进行加锁。加锁的表越少，锁资源越少，竞争越严重。
　　不过好在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能够保证同时只有一个请求设置成功,其它失败.
　　
　　在开发程序的过程中,对并发的处理一定要谨慎.