Redis协议具体用法详解
前言
我们用过很多redis的客户端，有没有相过自己撸一个redis客户端？其实很简单，基于socket，监听6379端口，解析数据就可以了。
redis协议
解析数据的过程主要依赖于redis的协议了。我们写个简单例子看下redis的协议：
publicclassRedisTest{publicstaticvoidmain(String[]args){Jedisjedis=newJedis("127.0.0.1",6379);jedis.set("eat","Iwanttoeat");}}
监听socket：
publicstaticvoidmain(String[]args)throwsIOException{ServerSocketserver=newServerSocket(6379);Socketsocket=server.accept();byte[]chars=newbyte[64];socket.getInputStream().read(chars);System.out.println(newString(chars));}
看下数据：
*3$3SET$3eat$13Iwanttoeat
参照官方协议文档https://redis.io/topics/protocol，解析下数据。
（1）简单字符串SimpleStrings,以"+"加号开头（2）错误Errors,以"-"减号开头（3）整数型Integer，以":"冒号开头（4）大字符串类型BulkStrings,以"$"美元符号开头，长度限制512M（5）组类型Arrays，以"*"星号开头并且，协议的每部分都是以"\r\n"(CRLF)结尾的。
所以上面的数据的含义是：
*3数组包含3个元素，分别是SET、eat、Iwanttoeat$3是一个字符串，且字符串长度为3SET字符串的内容$3是一个字符串，且字符串长度为3eat字符串的内容$13是一个字符串，且字符串长度为13Iwanttoeat字符串的内容
执行get'eat'的数据如下：
*2$3GET$3eat
撸一个客户端
掌握了redis协议，socket之后，我们就可以尝试撸一个客户端了。
socket：
publicRedisClient(Stringhost,intport){try{this.socket=newSocket(host,port);this.outputStream=this.socket.getOutputStream();this.inputStream=this.socket.getInputStream();}catch(IOExceptione){//TODOAuto-generatedcatchblocke.printStackTrace();}}
set协议：
publicStringset(finalStringkey,Stringvalue){StringBuildersb=newStringBuilder();//虽然输出的时候，会被转义，然而我们传送的时候还是要带上\r\nsb.append("*3").append("\r\n");sb.append("$3").append("\r\n");sb.append("SET").append("\r\n");sb.append("$").append(key.length()).append("\r\n");sb.append(key).append("\r\n");sb.append("$").append(value.length()).append("\r\n");sb.append(value).append("\r\n");byte[]bytes=newbyte[1024];try{outputStream.write(sb.toString().getBytes());inputStream.read(bytes);}catch(IOExceptione){//TODOAuto-generatedcatchblocke.printStackTrace();}returnnewString(bytes);}
测试：
RedisClientredisClient=newRedisClient("127.0.0.1",6379);Stringresult=redisClient.set("eat","pleaseeat");System.out.println(result);
执行结果：
+OK
更多Redis相关技术文章，请访问Redis教程栏目进行学习！