从RedisHTTP协议，看Nett协议设计，我发现了个惊天大秘密

　　1. 协议的作用
　　TCP/IP 中消息传输基于流的方式，没有边界
　　协议的目的就是划定消息的边界，制定通信双方要共同遵守的通信规则2. Redis 协议
　　如果我们要向 Redis 服务器发送一条 set name Nyima 的指令，需要遵守如下协议// 该指令一共有3部分，每条指令之后都要添加回车与换行符 *3r  // 第一个指令的长度是3 $3r  // 第一个指令是set指令 setr  // 下面的指令以此类推 $4r  namer  $5r  Nyimar  复制代码
　　客户端代码如下public class RedisClient {     static final Logger log = LoggerFactory.getLogger(StudyServer.class);     public static void main(String[] args) {         NioEventLoopGroup group =  new NioEventLoopGroup();         try {             ChannelFuture channelFuture = new Bootstrap()                     .group(group)                     .channel(NioSocketChannel.class)                     .handler(new ChannelInitializer() {                         @Override                         protected void initChannel(SocketChannel ch) {                             // 打印日志                             ch.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));                             ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {                                 @Override                                 public void channelActive(ChannelHandlerContext ctx) throws Exception {                                     // 回车与换行符                                     final byte[] LINE = {＂r＂,＂ ＂};                                     // 获得ByteBuf                                     ByteBuf buffer = ctx.alloc().buffer();                                     // 连接建立后，向Redis中发送一条指令，注意添加回车与换行                                     // set name Nyima                                     buffer.writeBytes(＂*3＂.getBytes());                                     buffer.writeBytes(LINE);                                     buffer.writeBytes(＂$3＂.getBytes());                                     buffer.writeBytes(LINE);                                     buffer.writeBytes(＂set＂.getBytes());                                     buffer.writeBytes(LINE);                                     buffer.writeBytes(＂$4＂.getBytes());                                     buffer.writeBytes(LINE);                                     buffer.writeBytes(＂name＂.getBytes());                                     buffer.writeBytes(LINE);                                     buffer.writeBytes(＂$5＂.getBytes());                                     buffer.writeBytes(LINE);                                     buffer.writeBytes(＂Nyima＂.getBytes());                                     buffer.writeBytes(LINE);                                     ctx.writeAndFlush(buffer);                                 }                              });                         }                     })                     .connect(new InetSocketAddress(＂localhost＂, 6379));             channelFuture.sync();             // 关闭channel             channelFuture.channel().close().sync();         } catch (InterruptedException e) {             e.printStackTrace();         } finally {             // 关闭group             group.shutdownGracefully();         }     } } 复制代码
　　控制台打印结果1600 [nioEventLoopGroup-2-1] DEBUG io.netty.handler.logging.LoggingHandler  - [id: 0x28c994f1, L:/127.0.0.1:60792 - R:localhost/127.0.0.1:6379] WRITE: 34B          +-------------------------------------------------+          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f | +--------+-------------------------------------------------+----------------+ |00000000| 2a 33 0d 0a 24 33 0d 0a 73 65 74 0d 0a 24 34 0d |*3..$3..set..$4.| |00000010| 0a 6e 61 6d 65 0d 0a 24 35 0d 0a 4e 79 69 6d 61 |.name..$5..Nyima| |00000020| 0d 0a                                           |..              | +--------+-------------------------------------------------+----------------+ 复制代码
　　Redis 中查询执行结果
　　3. HTTP 协议
　　HTTP 协议在请求行请求头中都有很多的内容，自己实现较为困难，可以使用 HttpServerCodec 作为服务器端的解码器与编码器，来处理 HTTP 请求// HttpServerCodec 中既有请求的解码器 HttpRequestDecoder 又有响应的编码器 HttpResponseEncoder // Codec(CodeCombine) 一般代表该类既作为 编码器 又作为 解码器 public final class HttpServerCodec extends CombinedChannelDuplexHandler         implements HttpServerUpgradeHandler.SourceCodec 复制代码
　　服务器代码public class HttpServer {     static final Logger log = LoggerFactory.getLogger(StudyServer.class);      public static void main(String[] args) {         NioEventLoopGroup group = new NioEventLoopGroup();         new ServerBootstrap()                 .group(group)                 .channel(NioServerSocketChannel.class)                 .childHandler(new ChannelInitializer() {                     @Override                     protected void initChannel(SocketChannel ch) {                         ch.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));                         // 作为服务器，使用 HttpServerCodec 作为编码器与解码器                         ch.pipeline().addLast(new HttpServerCodec());                         // 服务器只处理HTTPRequest                         ch.pipeline().addLast(new SimpleChannelInboundHandler() {                             @Override                             protected void channelRead0(ChannelHandlerContext ctx, HttpRequest msg) {                                 // 获得请求uri                                 log.debug(msg.uri());                                  // 获得完整响应，设置版本号与状态码                                 DefaultFullHttpResponse response = new DefaultFullHttpResponse(msg.protocolVersion(), HttpResponseStatus.OK);                                 // 设置响应内容                                 byte[] bytes = ＂
Hello, World!
＂.getBytes(StandardCharsets.UTF_8);                                 // 设置响应体长度，避免浏览器一直接收响应内容                                 response.headers().setInt(CONTENT_LENGTH, bytes.length);                                 // 设置响应体                                 response.content().writeBytes(bytes);                                  // 写回响应                                 ctx.writeAndFlush(response);                             }                         });                     }                 })                 .bind(8080);     } } 复制代码
　　服务器负责处理请求并响应浏览器。所以只需要处理 HTTP 请求即可// 服务器只处理HTTPRequest ch.pipeline().addLast(new SimpleChannelInboundHandler() 复制代码
　　获得请求后，需要返回响应给浏览器。需要创建响应对象 DefaultFullHttpResponse，设置 HTTP 版本号及状态码，为避免浏览器获得响应后，因为获得 CONTENT_LENGTH 而一直空转，需要添加 CONTENT_LENGTH 字段，表明响应体中数据的具体长度// 获得完整响应，设置版本号与状态码 DefaultFullHttpResponse response = new DefaultFullHttpResponse(msg.protocolVersion(), HttpResponseStatus.OK); // 设置响应内容 byte[] bytes = ＂
Hello, World!
＂.getBytes(StandardCharsets.UTF_8); // 设置响应体长度，避免浏览器一直接收响应内容 response.headers().setInt(CONTENT_LENGTH, bytes.length); // 设置响应体 response.content().writeBytes(bytes); 复制代码
　　运行结果
　　浏览器
　　控制台// 请求内容 1714 [nioEventLoopGroup-2-2] DEBUG io.netty.handler.logging.LoggingHandler  - [id: 0x72630ef7, L:/0:0:0:0:0:0:0:1:8080 - R:/0:0:0:0:0:0:0:1:55503] READ: 688B          +-------------------------------------------------+          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f | +--------+-------------------------------------------------+----------------+ |00000000| 47 45 54 20 2f 66 61 76 69 63 6f 6e 2e 69 63 6f |GET /favicon.ico| |00000010| 20 48 54 54 50 2f 31 2e 31 0d 0a 48 6f 73 74 3a | HTTP/1.1..Host:| |00000020| 20 6c 6f 63 61 6c 68 6f 73 74 3a 38 30 38 30 0d | localhost:8080.| |00000030| 0a 43 6f 6e 6e 65 63 74 69 6f 6e 3a 20 6b 65 65 |.Connection: kee| |00000040| 70 2d 61 6c 69 76 65 0d 0a 50 72 61 67 6d 61 3a |p-alive..Pragma:| ....  // 响应内容 1716 [nioEventLoopGroup-2-2] DEBUG io.netty.handler.logging.LoggingHandler  - [id: 0x72630ef7, L:/0:0:0:0:0:0:0:1:8080 - R:/0:0:0:0:0:0:0:1:55503] WRITE: 61B          +-------------------------------------------------+          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f | +--------+-------------------------------------------------+----------------+ |00000000| 48 54 54 50 2f 31 2e 31 20 32 30 30 20 4f 4b 0d |HTTP/1.1 200 OK.| |00000010| 0a 43 6f 6e 74 65 6e 74 2d 4c 65 6e 67 74 68 3a |.Content-Length:| |00000020| 20 32 32 0d 0a 0d 0a 3c 68 31 3e 48 65 6c 6c 6f | 22....
Hello| |00000030| 2c 20 57 6f 72 6c 64 21 3c 2f 68 31 3e          |, World!
   | +--------+-------------------------------------------------+----------------+  复制代码4. 自定义协议
　　组成要素魔数：用来在第一时间判定接收的数据是否为无效数据包版本号：可以支持协议的升级序列化算法：消息正文到底采用哪种序列化反序列化方式如：json、protobuf、hessian、jdk指令类型：是登录、注册、单聊、群聊… 跟业务相关请求序号：为了双工通信，提供异步能力正文长度消息正文编码器与解码器public class MessageCodec extends ByteToMessageCodec {      @Override     protected void encode(ChannelHandlerContext ctx, Message msg, ByteBuf out) throws Exception {         // 设置魔数 4个字节         out.writeBytes(new byte[]{＂N＂,＂Y＂,＂I＂,＂M＂});         // 设置版本号 1个字节         out.writeByte(1);         // 设置序列化方式 1个字节         out.writeByte(1);         // 设置指令类型 1个字节         out.writeByte(msg.getMessageType());         // 设置请求序号 4个字节         out.writeInt(msg.getSequenceId());         // 为了补齐为16个字节，填充1个字节的数据         out.writeByte(0xff);          // 获得序列化后的msg         ByteArrayOutputStream bos = new ByteArrayOutputStream();         ObjectOutputStream oos = new ObjectOutputStream(bos);         oos.writeObject(msg);         byte[] bytes = bos.toByteArray();          // 获得并设置正文长度 长度用4个字节标识         out.writeInt(bytes.length);         // 设置消息正文         out.writeBytes(bytes);     }      @Override     protected void decode(ChannelHandlerContext ctx, ByteBuf in, List