/**
* @file redis_op.c
* @brief redis 操作基本接口和key的操作实现
*/
#include "redis_op.h"
/* -------------------------------------------*/
/**
* @brief 选择redis一个数据库
*
* @param conn 已链接的数据库链接
* @param db_no redis数据库编号
*
* @returns
* -1 失败
* 0 成功
*/
/* -------------------------------------------*/
int rop_selectdatabase(redisContext *conn, unsigned int db_no)
{
int retn = 0;
redisReply *reply = NULL;
/* 选择一个数据库 */
reply = redisCommand(conn, "select %d", db_no);
if (reply == NULL) {
fprintf(stderr, "[-][GMS_REDIS]Select database %d error!\n", db_no);
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[-][GMS_REDIS]Select database %d error!%s\n", db_no, conn->errstr);
retn = -1;
goto END;
}
printf("[+][GMS_REDIS]Select database %d SUCCESS!\n", db_no);
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[+][GMS_REDIS]Select database %d SUCCESS!\n", db_no);
END:
freeReplyObject(reply);
return retn;
}
/* -------------------------------------------*/
/**
* @brief 清空当前数据库所有信息(慎用)
*
* @param conn 已链接的数据库链接
*
* @returns
* -1 失败
* 0 成功
*/
/* -------------------------------------------*/
int rop_flush_database(redisContext *conn)
{
int retn = 0;
redisReply *reply = NULL;
reply = redisCommand(conn, "FLUSHDB");
if (reply == NULL) {
fprintf(stderr, "[-][GMS_REDIS]Clear all data error\n");
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[-][GMS_REDIS]Clear all data error\n");
retn = -1;
goto END;
}
printf("[+][GMS_REDIS]Clear all data!!\n");
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC,"[+][GMS_REDIS]Clear all data!!\n");
END:
freeReplyObject(reply);
return retn;
}
/* -------------------------------------------*/
/**
* @brief 判断key值是否存在
*
* @param conn 已经建立的链接
* @param key 需要寻找的key值
*
* @returns
* -1 失败
* 1 存在
* 0 不存在
*/
/* -------------------------------------------*/
int rop_is_key_exist(redisContext *conn, char* key)
{
int retn = 0;
redisReply *reply = NULL;
reply = redisCommand(conn, "EXISTS %s", key);
//rop_test_reply_type(reply);
if (reply->type != REDIS_REPLY_INTEGER) {
fprintf(stderr, "[-][GMS_REDIS]is key exist get wrong type!\n");
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[-][GMS_REDIS]is key exist get wrong type! %s\n", conn->errstr);
retn = -1;
goto END;
}
if (reply->integer == 1) {
retn = 1;
}
else {
retn = 0;
}
END:
freeReplyObject(reply);
return retn;
}
/* -------------------------------------------*/
/**
* @brief 删除一个key
*
* @param conn 已经建立的链接
* @param key
*
* @returns
* -1 失败
* 0 成功
*/
/* -------------------------------------------*/
int rop_del_key(redisContext *conn, char *key)
{
int retn = 0;
redisReply *reply = NULL;
reply = redisCommand(conn, "DEL %s", key);
if (reply->type != REDIS_REPLY_INTEGER) {
fprintf(stderr, "[-][GMS_REDIS] DEL key %s ERROR\n", key);
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[-][GMS_REDIS] DEL key %s ERROR %s\n", key, conn->errstr);
retn = -1;
goto END;
}
if (reply->integer > 0) {
retn = 0;
}
else {
retn = -1;
}
END:
freeReplyObject(reply);
return retn;
}
/* -------------------------------------------*/
/**
* @brief 设置一个key的删除时间 ，系统到达一定时间
* 将会自动删除该KEY
*
* @param conn 已经建立好的链接
* @param delete_time 到期事件 time_t 日历时间
*
* @returns
* 0 SUCC
* -1 FAIL
*/
/* -------------------------------------------*/
int rop_set_key_lifecycle(redisContext *conn, char *key, time_t delete_time)
{
int retn = 0;
redisReply *reply = NULL;
reply = redisCommand(conn, "EXPIREAT %s %d", key, delete_time);
if (reply->type != REDIS_REPLY_INTEGER) {
fprintf(stderr, "[-][GMS_REDIS]Set key:%s delete time ERROR!\n", key);
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[-][GMS_REDIS]Set key:%s delete time ERROR! %s\n", key, conn->errstr);
retn = -1;
}
if (reply->integer == 1) {
/* 成功 */
retn = 0;
}
else {
/* 错误 */
retn = -1;
}
freeReplyObject(reply);
return retn;
}
/* -------------------------------------------*/
/**
* @brief 打印库中所有匹配pattern的key
*
* @param conn 已建立好的链接
* @param pattern 匹配模式，pattern支持glob-style的通配符格式，
* 如 *表示任意一个或多个字符，
* ?表示任意字符，
* [abc]表示方括号中任意一个字母。
*/
/* -------------------------------------------*/
void rop_show_keys(redisContext *conn, char* pattern)
{
int i = 0;
redisReply *reply = NULL;
reply = redisCommand(conn, "keys %s", pattern);
if (reply->type != REDIS_REPLY_ARRAY) {
fprintf(stderr, "[-][GMS_REDIS]show all keys and data wrong type!\n");
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[-][GMS_REDIS]show all keys and data wrong type! %s\n", conn->errstr);
goto END;
}
for (i = 0; i < reply->elements; ++i) {
printf("======[%s]======\n", reply->element[i]->str);
}
END:
freeReplyObject(reply);
}
/* -------------------------------------------*/
/**
* @brief 批量执行已经封装好的redis 命令
*
* @param conn 已建立好的链接
* @param cmds 封装好的命令数组
* @param cmd_num 命令个数
*
* @returns
* 0 succ
* -1 FAIL
*/
/* -------------------------------------------*/
int rop_redis_append(redisContext *conn, RCOMMANDS cmds, int cmd_num)
{
int retn = 0;
int i = 0;
redisReply *reply = NULL;
/* 批量插入命令到缓冲命令管道 */
for (i = 0; i < cmd_num; ++i) {
retn = redisAppendCommand(conn, cmds[i]);
if (retn != REDIS_OK) {
fprintf(stderr, "[-][GMS_REDIS]Append Command: %s ERROR!\n", cmds[i]);
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[-][GMS_REDIS]Append Command: %s ERROR! %s\n", cmds[i], conn->errstr);
retn = -1;
goto END;
}
retn = 0;
}
/* 提交命令 */
for (i = 0; i < cmd_num; ++i) {
retn = redisGetReply(conn, (void**)&reply);
if (retn != REDIS_OK) {
retn = -1;
fprintf(stderr, "[-][GMS_REDIS]Commit Command:%s ERROR!\n", cmds[i]);
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[-][GMS_REDIS]Commit Command:%s ERROR! %s\n", cmds[i], conn->errstr);
freeReplyObject(reply);
break;
}
freeReplyObject(reply);
retn = 0;
}
END:
return retn;
}
/* -------------------------------------------*/
/**
* @brief 执行单向命令 无返回值 命令自行输入
*
* @param conn 已建立的链接
* @param cmd 封装好的命令
*
* @returns
* 0 succ
* -1 FAIL
*/
/* -------------------------------------------*/
int rop_redis_command(redisContext *conn, char *cmd)
{
int retn = 0;
redisReply *reply = NULL;
reply = redisCommand(conn, cmd);
if (reply == NULL) {
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[-][GMS_REDIS]Command : %s ERROR!%s\n", cmd, conn->errstr);
retn = -1;
}
freeReplyObject(reply);
return retn;
}
/* -------------------------------------------*/
/**
* @brief 测试一个reply的结果类型
* 得到对应的类型用对应的方法获取数据
*
* @param reply 返回的命令结果
*/
/* -------------------------------------------*/
void rop_test_reply_type(redisReply *reply)
{
switch (reply->type) {
case REDIS_REPLY_STATUS:
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[+][GMS_REDIS]=REDIS_REPLY_STATUS=[string] use reply->str to get data, reply->len get data len\n");
break;
case REDIS_REPLY_ERROR:
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[+][GMS_REDIS]=REDIS_REPLY_ERROR=[string] use reply->str to get data, reply->len get date len\n");
break;
case REDIS_REPLY_INTEGER:
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[+][GMS_REDIS]=REDIS_REPLY_INTEGER=[long long] use reply->integer to get data\n");
break;
case REDIS_REPLY_NIL:
LOG(REDIS_LOG_MODULE, REDIS_LOG_PROC, "[+][GMS_REDIS]=REDIS_REPLY_NIL=[] data not exist\n");
break;
case REDIS
基于c++实现的分布式文件传输系统源代码+项目说明+exe可执行程序(课程大作业).zip （136个子文件） 
redis_op.c 35KB cJSON.c 27KB des.c 25KB dealfile_cgi.c 22KB upload_cgi.c 19KB sharefiles_cgi.c 18KB dealsharefile_cgi.c 17KB myfiles_cgi.c 15KB md5_cgi.c 11KB login_cgi.c 8KB reg_cgi.c 7KB make_log.c 7KB util_cgi.c 6KB md5.c 6KB deal_mysql.c 5KB fdfs_api.c 3KB cfg.c 3KB base64.c 3KB fdfs_upload_file.c 3KB redis_example.c 2KB echo.c 2KB fastcgi_demo.c 2KB myredis.c 862B main.c 442B redis.conf 46KB storage.conf 8KB tracker.conf 7KB nginx.conf 3KB client.conf 1KB main.cpp 476KB dealfile 82KB dealsharefile 82KB
main.exe 97KB redis_op.h 17KB cJSON.h 7KB util_cgi.h 2KB deal_mysql.h 2KB md5.h 1KB redis_keys.h 1KB des.h 1KB cfg.h 749B make_log.h 587B base64.h 470B fdfs_api.h 181B cfg.json 373B redis-13.log 66KB myfiles-12.log 35KB redis-27.log 23KB redis-12.log 18KB redis-12.log 17KB redis-14.log 13KB redis-16.log 12KB redis-11.log 12KB redis-23.log 10KB redis-22.log 10KB redis-24.log 10KB redis-26.log 9KB redis-25.log 8KB redis-04.log 7KB redis-25.log 6KB redis-11.log 5KB redis-30.log 5KB redis-31.log 4KB redis-06.log 4KB redis-29.log 4KB login-12.log 3KB redis-14.log 3KB upload-12.log 2KB md5-12.log 2KB redis-15.log 2KB login-17.log 1KB redis-05.log 1KB md5-17.log 1KB redis-17.log 1KB myfiles-17.log 1KB reg-17.log 1KB redis-31.log 880B dealsharefile-13.log 764B sharefiles-13.log 740B dealfile-13.log 724B redis-24.log 704B redis-28.log 704B sharefiles-12.log 572B dealsharefile-16.log 561B dealsharefile-17.log 561B sharefiles-17.log 543B sharefiles-16.log 543B dealfile-16.log 531B dealfile-17.log 531B dealfile-12.log 451B myfiles-13.log 388B login-16.log 386B upload-13.log 384B md5-13.log 372B redis.log 294B myfiles-16.log 279B upload-17.log 276B upload-16.log 276B md5-16.log 267B redis-03.log 176B共 136 条
- 1
- 2
资源评论
qq_480863282024-09-30资源不错，对我启发很大，获得了新的灵感，受益匪浅。
