1.IO（阻塞IO）和NIO（非阻塞IO）的概念

1.jdk1.4引入了NIO，但也有很多人在用阻塞IO，这两者有什么区别呢?假设线程1现在要从服务端读取1个10个字节的数据，但是只读到了5个字节，没有读完，那么线程1就会进入到阻塞状态。NIO就是线程1即使只读到了5个字节也会直接将这读到的5个字节返回，不会阻塞，等剩下5个字节加载进来后，再去读取。

2.redis的线程模型

1.redis虽然是基于单线程的，但是其效率高，是为什么呢？

2.原因：
1）redis中所有数据都是基于内存的，所有的计算都是内存级别的计算，所以很快
2）redis在处理并发的客户端连接时，使用的是NIO（非阻塞IO），那么它是如何通过非阻塞的方式来不断地读取数据的呢，其实这里要提一个多路复用这个概念，本质是一个时间轮询的API，过一段时间就不断地来读取数据
3）redis会给每一个客户端指令通过队列来进行排队处理
4）rredis做出响应时，也会有一个响应队列
5）redis是单线程的，所以一些时间复杂度高的指令，比如keys，可能会出现卡顿现象

3.redis的通信协议

1.redis使用的通信协议为文本协议，这个文本协议叫Redis Serialization Protocol 简称RESP。Redis协议将传输的结构分为五种最小的单元，单元结束时，加上\r\n

2.单行字符串以 + 开始，例如+hellojava\r\n

3.多行字符串以$开头，后面加上字符串的长度，例如$4java\r\n\

4.整数值以:开头，例如:25

5.数组以*开头，后面加上数组的长度

执行redis中的set和get命令
1）先在redis的配置文件注释掉需要密码验证这一项，还有关闭保护模式

在这里插入图片描述

2）定义socket连接redis,并且提供set和get方法

package com.yl;import java.io.IOException;
import java.io.StringReader;
import java.net.Socket;public class RedisProtocolClient {private Socket socket;public RedisProtocolClient () {try {socket = new Socket("192.168.244.129",6379);} catch (IOException e) {e.printStackTrace();}}//定义redis的set命令,传一个数组到redis[set,key,value]public String set(String key,String value) throws IOException{StringBuffer sb = new StringBuffer();sb.append("*3").append("\r\n").append("$").append("set".length()).append("\r\n").append("set").append("\r\n").append("$").append(key.getBytes().length).append("\r\n").append(key).append("\r\n").append("$").append(value.getBytes().length).append("\r\n").append(value).append("\r\n");socket.getOutputStream().write(sb.toString().getBytes());byte[] buff = new byte[1024];socket.getInputStream().read(buff);return new String(buff);}//定义get方法.[get,key]public String get(String key) throws IOException{StringBuffer sb = new StringBuffer();sb.append("*2").append("\r\n").append("$").append("get".length()).append("\r\n").append("get").append("\r\n").append("$").append(key.getBytes().length).append("\r\n").append(key).append("\r\n");socket.getOutputStream().write(sb.toString().getBytes());byte[] buff = new byte[1024];socket.getInputStream().read(buff);return new String(buff);}
}

3）测试

package com.yl;import java.io.IOException;public class RedisProtocolTest {public static void main(String[] args) throws IOException {String s1 = new RedisProtocolClient().set("k1","hellojava");System.out.println(s1);String s2 = new RedisProtocolClient().get("k1");System.out.println(s2);}
}