当前位置: 首页 > news >正文

CentOS 编译安装Redis

一、编译配置hiredis.h

C++来操作redis数据库。通过hiredis接口来实现,目前只能在Linux环境使用。

  •  下载hiredis.h

  •  hiredis的下载地址为:https://github.com/redis/hiredis

  •   解压并编译hiredis

[root@localhost source_code]# pwd
/usr/local/source_code
[root@localhost source_code]# ll
总用量 5296
drwxr-xr-x. 2 root root       42 9月  18 17:32 c_demo
-rw-r--r--. 1 root root   126216 10月 10 09:42 hiredis-1.2.0.tar.gz
drwxr-xr-x. 5  500 users    8192 9月   4 15:28 jpeg-9e
-rw-r--r--. 1 root root  1046935 9月   4 15:23 jpegsrc.v9e.tar.gz
-rw-r--r--. 1 root root  4234219 8月  31 16:22 release-3.4.13.tar.gz
drwxrwxr-x. 8 root root      259 8月  31 16:33 zookeeper-release-3.4.13
[root@localhost source_code]# tar -zxvf hiredis-1.2.0.tar.gz
hiredis-1.2.0/
hiredis-1.2.0/.github/
hiredis-1.2.0/.github/release-drafter-config.yml
******
  • 执行make && make install(自动把libhiredis.so放到/usr/local/lib/中,把hiredis.h放到/usr/local/inlcude/hiredis/中)
[root@localhost source_code]# cd hiredis-1.2.0
[root@localhost hiredis-1.2.0]# make && make install
cc -std=c99 -c -O3 -fPIC   -Wall -Wextra -Werror -Wstrict-prototypes -Wwrite-strings -Wno-missing-field-initializers -g -ggdb  -pedantic alloc.c
cc -std=c99 -c -O3 -fPIC   -Wall -Wextra -Werror -Wstrict-prototypes -Wwrite-strings -Wno-missing-field-initializers -g -ggdb  -pedantic net.c
cc -std=c99 -c -O3 -fPIC   -Wall -Wextra -Werror -Wstrict-prototypes -Wwrite-strings -Wno-missing-field-initializers -g -ggdb  -pedantic hiredis.c
******
# 生成hredis 相关信息
mkdir -p /usr/local/include/hiredis /usr/local/include/hiredis/adapters /usr/local/lib
-- hiredis 头文件生成地址
cp -pPR hiredis.h async.h read.h sds.h alloc.h sockcompat.h /usr/local/include/hiredis
cp -pPR adapters/*.h /usr/local/include/hiredis/adapters
-- hiredis 动态库文件生成地址
cp -pPR libhiredis.so /usr/local/lib/libhiredis.so.1.1.0
cd /usr/local/lib && ln -sf libhiredis.so.1.1.0 libhiredis.so && ln -sf libhiredis.so.1.1.0 libhiredis.so.1
cp -pPR libhiredis.a /usr/local/lib
mkdir -p /usr/local/lib/pkgconfig
cp -pPR hiredis.pc /usr/local/lib/pkgconfig

在程序中包含#include <hiredis/hiredis.h>即可 

[root@localhost ~]# cd /usr/local/source_code/
[root@localhost source_code]# ll
总用量 5300
drwxr-xr-x. 2 root root       42 9月  18 17:32 c_demo
drwxrwxr-x. 6 root root     4096 10月 10 09:44 hiredis-1.2.0
-rw-r--r--. 1 root root   126216 10月 10 09:42 hiredis-1.2.0.tar.gz
drwxr-xr-x. 2 root root       50 10月 10 10:37 hiredis_demo
drwxr-xr-x. 5  500 users    8192 9月   4 15:28 jpeg-9e
-rw-r--r--. 1 root root  1046935 9月   4 15:23 jpegsrc.v9e.tar.gz
-rw-r--r--. 1 root root  4234219 8月  31 16:22 release-3.4.13.tar.gz
drwxr-xr-x. 2 root root        6 10月 10 10:58 zookeeper_demo
drwxrwxr-x. 8 root root      259 8月  31 16:33 zookeeper-release-3.4.13
[root@localhost source_code]# cd hiredis_demo/
[root@localhost hiredis_demo]# ll
总用量 16
-rwxr-xr-x. 1 root root 8608 10月 10 10:37 hiredis_demo
-rw-r--r--. 1 root root  697 10月 10 10:26 hiredis_demo.cpp
[root@localhost hiredis_demo]# cat hiredis_demo.cpp
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <hiredis/hiredis.h>int main() {redisContext *c;redisReply *reply;struct timeval timeout = { 1, 500000 }; // 1.5 secondsc = redisConnectWithTimeout((char*)"192.168.43.80", 6379, timeout);if (c != NULL && c->err){printf("Connection error: %s", c->errstr);redisFree(c);exit(1);}reply = (redisReply *)redisCommand(c, "SET %s %s", "foo", "bar");freeReplyObject(reply);reply = (redisReply *)redisCommand(c, "GET foo");printf("foo: %s", reply->str);freeReplyObject(reply);redisFree(c);return 0;
}
[root@localhost hiredis_demo]#
  • 编译代码的时候需要加链接的库及库的路径,那么编译命令如下
g++ hiredis_demo.cpp -o hiredis_demo -L/usr/local/lib/ -lhiredis 
  • 在执行的时候如果出现动态库无法加载。
    [root@localhost hiredis_demo]# ./hiredis_demo
    ./hiredis_demo: error while loading shared libraries: libhiredis.so.1.1.0: cannot open shared object file: No such file or directory

    那么需要进行如下配置。

  • 在 /etc/ld.so.conf.d/ 目录下新建文件 usr-libs.conf ,内容是: /usr/local/lib
vim /etc/ld.so.conf.d/usr-libs.conf
  • 然后使用命令 /sbin/ldconfig 更新一下配置即可。
sbin/ldconfig

二、hiredis.h核心方法

第一步:查看hiredis.h 头文件定义:

[root@localhost lib]# cd /usr/local/include/hiredis/
[root@localhost hiredis]# ll
总用量 56
drwxr-xr-x. 2 root root   197 10月 10 09:44 adapters
-rw-rw-r--. 1 root root  3130 7月  12 15:31 alloc.h
-rw-rw-r--. 1 root root  6288 7月  12 15:31 async.h
-rw-rw-r--. 1 root root 14319 7月  12 15:31 hiredis.h
-rw-rw-r--. 1 root root  4918 7月  12 15:31 read.h
-rw-rw-r--. 1 root root  9238 7月  12 15:31 sds.h
-rw-rw-r--. 1 root root  4409 7月  12 15:31 sockcompat.h
[root@localhost hiredis]# cat hiredis.h

 

核心方法定义

1.建立链接:redisConnect

redisContext* redisConnect(const char *ip, int port)

 函数说明:

  • 函数用来连接redis数据库, 两个参数分别是redis数据库的ip和端口,端口号一般为6379
  • 该函数redisConnect用于创建所谓的redisContext。上下文是Hiredis保持连接状态的地方。
  • 当连接处于错误状态时,该redisContext 结构具有一个err非零的整数字段该字段errstr将包含带有错误描述的字符串
  • 使用尝试连接到Redis后redisConnect,应检查该err字段以查看建立连接是否成功

 还提供了一个函数,供连接超时限定,即

redisContext* redisConnectWithTimeout(const char *ip, int port, timeval tv)。

 Demo 示例:

 c = redisConnectWithTimeout((char*)"192.168.43.80", 6379, timeout);if (c != NULL && c->err){printf("Connection error: %s", c->errstr);redisFree(c);exit(1);}

解释说明:

当函数调用不成功时,取决于函数NULL还是REDIS_ERR返回。err上下文中的字段将为非零值,并设置为以下常量之一:

  • REDIS_ERR_IO:创建连接,尝试写入套接字或从套接字读取时发生I /O错误。如果您包含errno.h在应用程序中,则可以使用全局errno变量来找出问题所在。
  • REDIS_ERR_EOF:服务器关闭了连接,导致读取为空。
  • REDIS_ERR_PROTOCOL:解析协议时出错。
  • REDIS_ERR_OTHER:其他任何错误。当前,仅在无法解析要连接的指定主机名时使用。

在每种情况下,errstr上下文中的字段都将设置为包含错误的字符串表示形式。
 

2. 执行redis命令:redisCommand

void *redisCommand(redisContext *c, const char *format...)

函数说明:

  • 该函数用于执行redis数据库中的命令,第一个参数为连接数据库返回的redisContext,剩下的参数为变参。 

  • 此函数的返回值为void*,但是一般会强制转换为redisReply类型,以便做进一步的处理。

 const char *format... 动态参数关联方法定义:

void * redisCommandArgv(redisContext * c,int argc,const  char ** argv,const  size_t * argvlen);

 函数说明:

  • 它需要参数的数量,argc字符串数组argv和参数的长度argvlen。
  • 为了方便起见,argvlen可以将设置为NULL,并且函数将strlen(3)在每个参数上使用以确定其长度。
  • 显然,当任何一个参数需要二进制安全时,argvlen都应提供整个长度数组。
  • 返回值的语义与相同redisCommand。

 Demo 示例:

 reply = (redisReply *)redisCommand(c, "SET %s %s", "foo", "bar");

3.释放redisCommand

void freeReplyObject(void *reply)

函数说明:

  • 释放redisCommand执行后返回的的redisReply所占用的内存。
  • redisCommand成功执行命令后,的返回值将保留答复。
  • 发生错误时,返回值为NULL并且err将设置上下文中的字段。返回错误后,上下文context将无法重用,您应该建立一个新的连接。

Demo 示例:

 freeReplyObject(reply);

4.断开连接:redisFree

void redisFree(redisContext *c)

函数说明:

  • 此函数立即关闭套接字,然后释放在创建上下文时完成的分配。

三、Hiredis 基于C++ 封装

redis_handler.h

#ifndef __REDIS_HANDLER_H__
#define __REDIS_HANDLER_H__#include <hiredis/hiredis.h>
#include <string>using namespace std;enum
{M_REDIS_OK = 0, //执行成功M_CONNECT_FAIL = -1, //连接redis失败M_CONTEXT_ERROR = -2, //RedisContext返回错误M_REPLY_ERROR = -3, //redisReply错误M_EXE_COMMAND_ERROR = -4 //redis命令执行错误
};class RedisHandler
{
public:RedisHandler();~RedisHandler();int connect(const string &addr, int port, const string &pwd = ""); //连接redis数据库:addr:IP地址,port:端口号,pwd:密码(默认为空)int disConnect(); //断开连接int setValue(const string &key, const string &value); //添加或修改键值对,成功返回0,失败<0int getValue(const string &key, string &value); //获取键对应的值,成功返回0,失败<0int delKey(const string &key); //删除键,成功返回影响的行数,失败<0int printAll(); //打印所有的键值对string getErrorMsg(); //获取错误信息
private:string m_addr; //IP地址int m_port; //端口号string m_pwd; //密码redisContext* pm_rct; //redis结构体redisReply* pm_rr; //返回结构体string error_msg; //错误信息int connectAuth(const string &pwd); //使用密码登录int handleReply(void* value = NULL, redisReply ***array = NULL); //处理返回的结果
};#endif

redis_handler.cpp

#include "redis_handler.h"
#include <string>
#include <cstring>
#include <iostream>
using namespace std;RedisHandler::RedisHandler()
{m_addr = "";m_port = 0;m_pwd = "";pm_rct = NULL;pm_rr = NULL;error_msg = "";
}RedisHandler::~RedisHandler()
{disConnect();pm_rct = NULL;pm_rr = NULL;
}/*
连接redis数据库
addr: 地址,port:端口号,pwd:密码
成功返回M_REDIS_OK,失败返回M_CONNECT_FAIL
*/
int RedisHandler::connect(const string &addr = "127.0.0.1", int port = 6379, const string &pwd) {m_addr = addr;m_port = port;m_pwd = pwd;pm_rct = redisConnect(m_addr.c_str(), m_port);if (pm_rct->err){error_msg = pm_rct->errstr;return M_CONNECT_FAIL;}if (!m_pwd.empty()){return connectAuth(m_pwd);}return M_REDIS_OK;
}/*
断开redis连接
*/
int RedisHandler::disConnect()
{redisFree(pm_rct);freeReplyObject(pm_rr);
}/*
添加或插入键值对
key:键,value:值
成功返回M_REDIS_OK,失败返回<0
*/
int RedisHandler::setValue(const string &key, const string &value)
{string cmd = "set " + key + " " + value;pm_rr = (redisReply*)redisCommand(pm_rct, cmd.c_str());return handleReply();
}/*
获取键对应的值
key:键,value:值引用
成功返回M_REDIS_OK,失败返回<0
*/
int RedisHandler::getValue(const string &key, string &value)
{string cmd = "get " + key;pm_rr = (redisReply*)redisCommand(pm_rct, cmd.c_str());int ret = handleReply(&value);
}/*
删除键
key:键
成功返回影响的行数(可能为0),失败返回<0
*/
int RedisHandler::delKey(const string &key)
{string cmd = "del " + key;pm_rr = (redisReply*)redisCommand(pm_rct, cmd.c_str());int rows = 0;int ret = handleReply(&rows);if (ret == M_REDIS_OK)return rows;elsereturn ret;
}/*
打印所有键值对到屏幕上
*/
int RedisHandler::printAll()
{string cmd = "keys *";pm_rr = (redisReply*)redisCommand(pm_rct, cmd.c_str());int len ;redisReply **array;int ret = handleReply(&len, &array);if (ret == M_REDIS_OK){for (int i = 0; i < len; i++)cout << string(array[i]->str) << endl;}elsereturn 0;
}/*
返回错误信息
*/
string RedisHandler::getErrorMsg()
{return error_msg;
}/*
使用密码登录
psw:登录密码
成功返回M_REDIS_OK,失败返回<0
*/
int RedisHandler::connectAuth(const string &psw)
{string cmd = "auth " + psw;pm_rr = (redisReply*)redisCommand(pm_rct, cmd.c_str());return handleReply();
}/*
处理redis返回的信息
value:数据指针,用于保存redis返回的基本类型(value指针指向该数据)
array:数组指针,用于保存redis返回的数组
成功返回M_REDIS_OK,失败返回<0
*/
int RedisHandler::handleReply(void* value, redisReply*** array)
{if (pm_rct->err){error_msg = pm_rct->errstr;return M_CONTEXT_ERROR;}if (pm_rr == NULL){error_msg = "auth redisReply is NULL";return M_REPLY_ERROR;}switch (pm_rr->type){case REDIS_REPLY_ERROR:error_msg = pm_rr->str;return M_EXE_COMMAND_ERROR;case REDIS_REPLY_STATUS:if (!strcmp(pm_rr->str, "OK"))return M_REDIS_OK;else{error_msg = pm_rr->str;return M_EXE_COMMAND_ERROR;}case REDIS_REPLY_INTEGER:*(int*)value = pm_rr->integer;return M_REDIS_OK;case REDIS_REPLY_STRING:*(string*)value = pm_rr->str;return M_REDIS_OK;case REDIS_REPLY_NIL:*(string*)value = "";return M_REDIS_OK;case REDIS_REPLY_ARRAY:*(int*)value = pm_rr->elements;*array = pm_rr->element;return M_REDIS_OK;default:error_msg = "unknow reply type";return M_EXE_COMMAND_ERROR;}
}

Demo 示例:

redis_main.cpp

#include <iostream>
#include <string>
#include "redis_handler.h"
using namespace std;int main()
{RedisHandler* rh = new RedisHandler();int ret;//连接测试cout << "错误测试: " << "地址错误" << endl;ret = rh->connect("34.15.14.15", 6379, "linesum");if (ret != M_REDIS_OK)cout << "redis error: " << rh->getErrorMsg() << endl;cout << "错误测试: " << "端口错误" << endl;ret = rh->connect("127.0.0.1", 1234, "linesum");if (ret != M_REDIS_OK)cout << "redis error: " << rh->getErrorMsg() << endl;cout << "错误测试: " << "密码错误" << endl;ret = rh->connect("127.0.0.1", 6479, "linsum");if (ret != M_REDIS_OK)cout << "redis error: " << rh->getErrorMsg() << endl;ret = rh->connect("127.0.0.1", 6479, "linesum");if (ret != M_REDIS_OK){cout << "redis error: " << rh->getErrorMsg() << endl;return ret;}//set测试cout << "错误测试: " << "set不带value参数" << endl;ret = rh->setValue("key11", "");if (ret != M_REDIS_OK)cout << "redis error: " << rh->getErrorMsg() << endl;ret = rh->setValue("key11", "value11");if (ret != M_REDIS_OK){cout << "redis error: " << rh->getErrorMsg() << endl;return ret;}ret = rh->setValue("key22", "value22");if (ret != M_REDIS_OK){cout << "redis error: " << rh->getErrorMsg() << endl;return ret;}//get测试string str;cout << "错误测试: " << "get不带key参数" << endl;ret = rh->getValue("key1111", str);if (ret != M_REDIS_OK)cout << "redis error: " << rh->getErrorMsg() << endl;ret = rh->getValue("key11", str);if (ret != M_REDIS_OK){cout << "redis error: " << rh->getErrorMsg() << endl;return ret;}elsecout << "value : " << str << endl;//print测试ret = rh->printAll();if (ret != M_REDIS_OK){cout << "redis error: " << rh->getErrorMsg() << endl;return ret;}//del测试cout << "错误测试: " << "删除不存在的key" << endl;ret = rh->delKey("key1111");if (ret != M_REDIS_OK)cout << "redis error: " << rh->getErrorMsg() << endl;ret = rh->delKey("key11");if (ret != M_REDIS_OK){cout << "redis error: " << rh->getErrorMsg() << endl;return ret;}delete rh;return 0;
}

http://www.lryc.cn/news/187372.html

相关文章:

  • 可拓展的低代码全栈框架
  • C++11 智能指针
  • 二、WebGPU阶段间变量(inter-stage variables)
  • 【Linux】31个普通信号
  • Mac电脑交互式原型设计 Axure RP 8汉化最新 for mac
  • 在线免费无时长限制录屏工具 - 录猎在线版
  • c语言文件操作详解:fgetc,fputc,fgets,fputs,fscanf,,fprintf,fread,fwrite的使用和区别
  • Harmony装饰器
  • 如何加快Chrome谷歌浏览器下载速度?
  • 使用kubectl连接远程Kubernetes(k8s)集群
  • Kubernetes革命:云原生时代的应用编排和自动化
  • mysql.mongoDb,neo4j数据库对比
  • unity使用UniStorm 5.1.0.unitypackage增加天气
  • Flink实现kafka到kafka、kafka到doris的精准一次消费
  • Outlook屏蔽Jira AI提醒
  • 毛玻璃 has 选择器卡片悬停效果
  • [hive]解决group by 字段超过系统规定64个
  • 生成老年人的声音sox
  • DC2DC电源设计注意事项--1,Feedback
  • 计算机视觉处理的开源框架
  • 最新AI智能创作系统源码AI绘画系统/支持GPT联网提问/支持Prompt应用
  • 2019架构真题案例(四十八)
  • zabbix自定义监控内容和自动发现
  • 导引服务机器人 通用技术条件
  • 今日头条文章采集ChatGPT3.5/4.0驱动浏览器改写文章软件说明文档
  • Mac系统清理工具BuhoCleaner
  • SpringBoot集成WebSocket讲解
  • GNOME 45 动态三层缓存补丁更新
  • [论文笔记]Poly-encoder
  • vs2022中配置PCL1.13.1(附带提供属性表.props文件)