-
Notifications
You must be signed in to change notification settings - Fork 0
/
redis_connection.hpp
88 lines (74 loc) · 1.71 KB
/
redis_connection.hpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
/**
* 描述:封装hiredis连接
* 作者:guchenfeng
* 日期:2022/12/11
*
*/
#ifndef REDIS_CONNECTION_HPP
#define REDIS_CONNECTION_HPP
#include <hiredis/hiredis.h>
#include <cstring>
#include <iostream>
#include <vector>
#include <cstring>
//redis连接类
class RedisConnection {
public:
/*redis地址*/
struct redis_addr {
std::string host = "127.0.0.1";
unsigned int port = 6379;
};
/*构造函数*/
RedisConnection() {
}
/*析构函数*/
~RedisConnection() {
//如果连接存在,关闭连接
if (m_conn) {
close();
}
}
/*连接*/
bool connect() {
m_conn = redisConnect(m_addr.host.c_str(), m_addr.port);
//连接失败
if (m_conn->err) {
close();
std::cout << "RedisConnection: redis server connection fail!" << std::endl;
return false;
}
return true;
}
/*执行查询命令*/
std::string query(std::string cmd) {
std::string res = "";
//无连接
if (!m_conn) {
std::cout << "RedisConnection: redis server no connection!" << std::endl;
return res;
}
//获取查询结果
redisReply* ret = (redisReply*)redisCommand(m_conn, cmd.c_str());
if (ret->str) {
res = ret->str;
}
//释放结果集内存
freeReplyObject(ret);
return res;
}
/*断开连接*/
void close() {
//连接存在则关闭
if (m_conn) {
redisFree(m_conn);
m_conn = NULL;
}
}
private:
//redis连接
redisContext* m_conn;
//redis地址
redis_addr m_addr;
};
#endif