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;
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 returnfalse;
65 }
66
67 }
上述代码,其实是借助memecache<key,value>对并发设置value的并发处理来实现锁的逻辑.memcache能够保证同时只有一个请求设置成功,其它失败.
在开发程序的过程中,对并发的处理一定要谨慎.
页:
[1]