使用Java操作Redis（一）

布满荆棘的人生 2022-08-05 12:15 157阅读 0赞

Redis是一款基于key-value的数据库服务器，安装完成后我们可以通过redis-cli使用Redis提供的命令完成各种操作。redis-cli实际上就是一款客户端，和redis-server建立网络连接，然后以一定的格式（称为网络协议）向服务器端发送数据，redis-server根据客户端的请求进行处理并返回相应的结果。  
使用Java操作Redis，本质上就是编写Redis的客户端应用，因此我们必须了解Redis自定义的网络协议。

Redis协议官方地址：[http://redis.io/topics/protocol][http_redis.io_topics_protocol]  
请求协议的一般格式为：

*<参数的个数> CR LF
    $<参数1字节数> CR LF
     <参数1> CR LF
    ...
    $<参数n字节数> CR LF
     <参数n> CR LF

举个例子：set name Jane命令应该对应的以下形式

*3 CR LF //三个参数
    $3 CR LF //第一个参数set有3个字节
    SET CR LF //参数内容set
    $4 CR LF //第二个参数name占4个字节
    name CR LF //参数二内容 name
    $4 CR LF //第三个参数有4个字节
    Jane CR LF//参数三内容 Jane

对应的字符串形式为`"*3\r\n$3\r\nset$4\r\nname$4\r\nJane\r\n`。

Redis命令会返回多种不同类型的回复，通过检查返回数据的第一个字节可以确定具体的类型：

*  状态回复（status reply）的第一个字节是 “+”
 *  错误回复（error reply）的第一个字节是 “-“
 *  整数回复（integer reply）的第一个字节是 “:”
 *  批量回复（bulk reply）的第一个字节是 “$”
 *  多条批量回复（multi bulk reply）的第一个字节是 “\*”

了解了这些后我们就可以在Java中和Redis服务器建立Socket连接，然后將指令按照Redis协议格式发送到服务器端，从而达到操作Redis的目的。

代码如下：

try {
                Socket sock = new Socket("127.0.0.1",6379);
    
                OutputStream out = sock.getOutputStream();
                InputStream in = sock.getInputStream(); 
                //set name rongbo_j
                String sendStr = 
                    "*3\r\n$3\r\nSET\r\n$4\r\nname\r\n$8\r\nrongbo_j\r\n";
                out.write(sendStr.getBytes());
                //get name
                sendStr = "*2\r\n$3\r\nGET\r\n$5\r\nname\r\n";
                out.write(sendStr.getBytes());
    
                byte[] buffer = new byte[512];
                in.read(buffer);
                System.out.println(new String(buffer));
    
            } catch (Exception e) {
                e.printStackTrace();
            }

可以看到如果不对代码进行封装，使用起来是相当繁琐的，下一篇文章介绍如何使用Jedis工具来简化操作。

[http_redis.io_topics_protocol]: http://redis.io/topics/protocol