Redis C++编程实例

基本功能步骤：

1，下载安装Redis，下载地址：http://www.redis.cn/download.html。

2，下载安装hiredis，下载地址：https://github.com/redis/hiredis。

将libhiredis.so放到/usr/lib/目录下。

3，在hiredis-master目录下编写客户端程序。

[cpp] view plain copy

1. #include <stdio.h>
2. #include "hiredis.h"
3. int main()
4. {
5. redisContext *conn  = redisConnect("127.0.0.1",6379);
6. if(conn != NULL && conn->err)
7. {
8. printf("connection error: %s\n",conn->errstr);
9. return 0;
10. }
11. redisReply *reply = (redisReply*)redisCommand(conn,"set foo 1234");
12. freeReplyObject(reply);
13. reply = redisCommand(conn,"get foo");
14. printf("%s\n",reply->str);
15. freeReplyObject(reply);
16. redisFree(conn);
17. return 0;
18. }

编译命令：gcc -o redistest redistest.c -lhiredis

4，启动服务器，运行客户端程序。

Redis pub/sub功能实现。

发布pub功能：

[cpp] view plain copy

1. #include <stdio.h>
2. #include <sys/time.h>
3. #include "hiredis.h"
4. int main()
5. {
6. struct timeval begin;
7. redisContext *conn  = redisConnect("127.0.0.1",6379);
8. if(conn != NULL && conn->err)
9. {
10. printf("connection error: %s\n",conn->errstr);
11. return 0;
12. }
13. gettimeofday(&begin, NULL);
14. redisReply *reply = (redisReply*)redisCommand(conn,"publish foo 1234");
15. int sec, usec;
16. sec = begin.tv_sec;
17. usec = begin.tv_usec;
18. printf("%d\t%d\n", sec, usec);
19. freeReplyObject(reply);
20. reply = redisCommand(conn,"get foo");
21. printf("%s\n",reply->str);
22. freeReplyObject(reply);
23. redisFree(conn);
24. return 0;
25. }

订阅sub功能：

[cpp] view plain copy

1. #include <sys/time.h>
2. #include <stdio.h>
3. #include <stdlib.h>
4. #include <string.h>
5. #include <signal.h>
6. #include "hiredis.h"
7. #include "async.h"
8. #include "adapters/libevent.h"
9. void subCallback(redisAsyncContext *c, void *r, void *priv) {
10. struct timeval end;
11. int sec, usec;
12. redisReply *reply = r;
13. if (reply == NULL) return;
14. if ( reply->type == REDIS_REPLY_ARRAY && reply->elements == 3 ) {
15. if ( strcmp( reply->element[0]->str, "subscribe" ) != 0 ) {
16. gettimeofday(&end,NULL);
17. sec = end.tv_sec;
18. usec = end.tv_usec;
19. printf("%d\t%d\n", sec, usec);
20. printf( "Received[%s] channel %s: %s\n",
21. (char*)priv,
22. reply->element[1]->str,
23. reply->element[2]->str );
24. }
25. }
26. }
27. void connectCallback(const redisAsyncContext *c, int status) {
28. if (status != REDIS_OK) {
29. printf("Error: %s\n", c->errstr);
30. return;
31. }
32. printf("Connected...\n");
33. }
34. void disconnectCallback(const redisAsyncContext *c, int status) {
35. if (status != REDIS_OK) {
36. printf("Error: %s\n", c->errstr);
37. return;
38. }
39. printf("Disconnected...\n");
40. }
41. int main (int argc, char **argv) {
42. signal(SIGPIPE, SIG_IGN);
43. struct event_base *base = event_base_new();
44. redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379);
45. if (c->err) {
46. /* Let *c leak for now... */
47. printf("Error: %s\n", c->errstr);
48. return 1;
49. }
50. redisLibeventAttach(c,base);
51. redisAsyncSetConnectCallback(c,connectCallback);
52. redisAsyncSetDisconnectCallback(c,disconnectCallback);
53. redisAsyncCommand(c, subCallback, (char*) "sub", "SUBSCRIBE foo");
54. event_base_dispatch(base);
55. return 0;
56. }

pub编译命令同上，sub编译命令：gcc -o sub sub.c -lhiredis -levent

注意：

1，编译基本程序时可能需要建立链接：ln -s libhiredis.so libhiredis.so.0.12

2，1，订阅sub需要安装libevent-dev。