memcached测试代码(包含memcached_cas的用法)

谁借莪１个温暖的怀抱￠ 2022-07-10 07:58 130阅读 0赞

\#include<stdio.h> \#include <iostream> \#include <string> \#include <map> \#include "libmemcached/memcached.h" using namespace std; int main() \{ char szIp\[\] = "10.0.0.1"; int iPort = 11211; memcached\_st \*pstMCache = memcached\_create(NULL); int iResult = memcached\_server\_add(pstMCache, szIp, iPort); //支持多台cache的分布式 //使用二进制协议传输 iResult = memcached\_behavior\_set(pstMCache, MEMCACHED\_BEHAVIOR\_BINARY\_PROTOCOL, 1); if (iResult != MEMCACHED\_SUCCESS) \{ printf("memcached\_server\_add fail %s:%d", szIp, iPort); return -1; \} //使用Consistent hashing算法将key分配到不同机器的不同位置 iResult = memcached\_behavior\_set(pstMCache, MEMCACHED\_BEHAVIOR\_KETAMA\_WEIGHTED, 1); if (iResult != MEMCACHED\_SUCCESS) \{ printf("\[%s\]Error:memcached\_behavior\_set MEMCACHED\_BEHAVIOR\_KETAMA\_WEIGHTED fail", \_\_FUNCTION\_\_); return -2; \} //使用NO-BLOCK，防止memcache倒掉时挂死 iResult = memcached\_behavior\_set(pstMCache,MEMCACHED\_BEHAVIOR\_NO\_BLOCK, 1); if (iResult != MEMCACHED\_SUCCESS) \{ printf("\[%s\]Error:memcached\_behavior\_set MEMCACHED\_BEHAVIOR\_KETAMA\_WEIGHTED fail", \_\_FUNCTION\_\_); return -3; \} memcached\_return rc; string key = "10000"; string val = "测试内容1"; rc = memcached\_set(pstMCache, key.c\_str(), key.size(), val.c\_str(), val.size(), 0, 0); if (rc == MEMCACHED\_SUCCESS) \{ //set成功，进行get unsigned int flags = 0; char \*mc\_val = NULL; size\_t val\_len = 0; mc\_val = memcached\_get(pstMCache, key.c\_str(), key.size(), &val\_len, &flags, &rc); if (rc == MEMCACHED\_SUCCESS) \{ printf("buffer:%s|len:%Zd|cas:%ld/n", mc\_val, val\_len, pstMCache->result.item\_cas); if ( mc\_val != NULL )\{ free(mc\_val); mc\_val = NULL; \} \} else \{ if ( mc\_val != NULL )\{ free(mc\_val); mc\_val = NULL; \} string err = memcached\_strerror(pstMCache, rc); printf("err:%s/n", err.c\_str()); return -4; \} string val1 = "测试内容2"; //做了并发容错的memcached\_cas 写操作，服务器维持了一个cas序列号，每次调用memcached\_cas时，会判断之前get出来的cas是否发生了变化，变化了的话，说明已经被其他程序给修改了 rc= memcached\_cas(pstMCache, key.c\_str(), key.size(), val1.c\_str(), val1.size(),0, 0, pstMCache->result.item\_cas/\*这个值是唯一序列\*/); if (rc == MEMCACHED\_SUCCESS) \{ printf("rc:%d/n", rc); \} else \{ string err = memcached\_strerror(pstMCache, rc); printf("err:%s/n", err.c\_str()); \} mc\_val = memcached\_get(pstMCache, key.c\_str(), key.size(), &val\_len, &flags, &rc); if (rc == MEMCACHED\_SUCCESS) \{ printf("buffer:%s|len:%Zd/n", mc\_val, val\_len); \} else \{ string err = memcached\_strerror(pstMCache, rc); printf("err:%s/n", err.c\_str()); return -4; \} \} else \{ string err = memcached\_strerror(pstMCache, rc); printf("err:%s/n", err.c\_str()); return -5; \} return 0; \}