linux搭建redis数据库实现远程c语言访问

⌚Time: 2022-11-26 15:16:13

👨‍💻Author: Jack Ge

linux安装reidis数据库

linux安装reidis数据库


sudo apt-get install redis-server

使用systemctl命令查看redis服务运行状态


sudo systemctl status redis-server

redis默认绑定本地用户访问,如果需要使远程用户访问,编辑redis配置文件


vi /etc/redis/redis.conf


bind 127.0.0.1

注释

重启redis服务


systemctl restart redis-server

查看linux系统ip地址


ip addr show

测试远程访问,直接访问本机ip地址


redis-cli -h 192.168.10.144 -p 6379

c语言使用hiredis库实现redis数据库的操作

hiredis库同步api


/**连接数据库*/

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

/**发送命令请求*/

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

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

void redisAppendCommand(redisContext *c, const char *format, ...);

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

/*释放资源*/

void freeReplyObject(void *reply);

void redisFree(redisContext *c);


链接数据库


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

port:为redis数据监听的端口号,redis默认监听的端口号为6379

ip:为redis数据库的IP地址,可以是远程的,也可以是本地的127.0.0.1

返回值是一个指向redisContext对象,下面是redisContext对象的定义。

redisContext对象定义


typedef struct redisContext {

    int err; /* Error flags, 0 when there is no error */

    char errstr[128]; /* String representation of error when applicable */

    int fd;

    int flags;

    char *obuf; /* Write buffer */

    redisReader *reader; /* Protocol reader */

    enum redisConnectionType connection_type;

    struct timeval *timeout;

    struct {

        char *host;

        char *source_addr;

        int port;

    } tcp;

    struct {

        char *path;

    } unix_sock;

} redisContext;


这个redisContext不是一个线程安全的对象,也就是说,多个线程同时访问这一个对象可能会出现问题。

使用redisCommand()执行命令


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

这个函数是一个带有不定参数的。可以按着format格式给出对应的参数,这就和printf函数类似。

c 是reidsConnect函数返回的一个对象。

返回值是一个void类型的指针,实际为指向一个redisReply类型的指针,redisReply的定义如下:

redisReply定义


/* This is the reply object returned by redisCommand() */

typedef struct redisReply {

    /*命令执行结果的返回类型*/

    int type; /* REDIS_REPLY_* */

    /*存储执行结果返回为整数*/

    long long integer; /* The integer when type is REDIS_REPLY_INTEGER */

    /*字符串值的长度*/

    size_t len; /* Length of string */

    /*存储命令执行结果返回是字符串*/

    char *str; /* Used for both REDIS_REPLY_ERROR and REDIS_REPLY_STRING */

    /*返回结果是数组的大小*/

    size_t elements; /* number of elements, for REDIS_REPLY_ARRAY */

    /*存储执行结果返回是数组*/

    struct redisReply **element; /* elements vector for REDIS_REPLY_ARRAY */

} redisReply;

返回结果的类型reply->type,reply 为一个redisReply* 类型的对象。

REDIS_REPLY_STRING == 1:返回值是字符串,字符串储存在redis->str当中,字符串长度为redis->len。

REDIS_REPLY_ARRAY == 2:返回值是数组,数组大小存在redis->elements里面,数组值存储在redis->element[i]里面。数组里面存储的是指向redisReply的指针,数组里面的返回值可以通过redis->element[i]->str来访问,数组的结果里全是type==REDIS_REPLY_STRING的redisReply对象指针。

REDIS_REPLY_INTEGER == 3:返回值为整数 long long。

REDIS_REPLY_NIL==4:返回值为空表示执行结果为空。

REDIS_REPLY_STATUS ==5:返回命令执行的状态,比如set foo bar 返回的状态为OK,存储在str当中 reply->str == “OK”。

REDIS_REPLY_ERROR ==6 :命令执行错误,错误信息存放在 reply->str当中。

释放资源


void freeReplyObject(void *reply);

void redisFree(redisContext *c);

异步api


//连接redis服务器

redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379);

if (c->err) {

        printf("Error: %s\n", c->errstr);

            // handle error

}



//设置连接、断开的钩子函数

int redisAsyncSetConnectCallback(redisAsyncContext *ac, redisConnectCallback *fn);

int redisAsyncSetDisconnectCallback(redisAsyncContext *ac, redisDisconnectCallback *fn);



//插入命令信息

int redisAsyncCommand(redisAsyncContext *ac, redisCallbackFn *fn, void *privdata,const char *format, ...);

int redisAsyncCommandArgv( redisAsyncContext *ac, redisCallbackFn *fn, void *privdata, int argc, const char **argv, const size_t *argvlen);



//关闭连接

void redisAsyncDisconnect(redisAsyncContext *ac);


包含头文件


#include <hiredis.h>

测试代码

RedisDemo.c


#include <stdio.h>

#include <string.h>

#include <hiredis.h>





int main() {



        //连接redis

        redisContext *pContext = redisConnect("192.168.10.144",6379);

        if(pContext==NULL){

            printf("connect failed!\n");

            return -1;

        }

        if(pContext->err){

            printf("connection error:%s\n", pContext->errstr);

            return -1;

        }

        printf("connect success!\n");

        //set

        redisReply *pReply;

        pReply = (struct redisReply *)redisCommand(pContext,"set %s %s","kk1","123apple");

        printf("设置键值:%s\n",pReply->str);

        //释放reply对象

        freeReplyObject(pReply);

        //get

        pReply = (struct redisReply *)redisCommand(pContext,"get %s","kk1");

        printf("%s键值:%s\n","kk1",pReply->str);

        //释放reply对象

        freeReplyObject(pReply);

        //释放连接

        redisFree(pContext);

 

        return 0;

}


windows下编译链接


gcc RedisDemo.c -D_FILE_OFFSET_BITS=64 -ID:/libs/hiredis/include/hiredis -ID:/libs/hiredis/include  -LD:/libs/hiredis/lib -lhiredis

运行时需要libhiredis.dll动态库的支撑

使用hiredis库制作一个redis数据库管理系统