From 3634fe2ab8f51773872e7b43bed307629c84cee1 Mon Sep 17 00:00:00 2001
From: zhuyijun <zhuyijun1317453947@outlook.com>
Date: Mon, 18 Oct 2021 19:09:43 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0protocol?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../netty/protocoltcp/MyClientHandler.java         |  5 ++++-
 .../netty/protocoltcp/MyClientInitializer.java     |  3 +++
 .../netty/protocoltcp/MyMessageDecoder.java        |  2 +-
 .../netty/protocoltcp/MyMessageEncoder.java        |  2 +-
 .../netty/protocoltcp/MyServerHandler.java         | 13 ++++++++++++-
 .../netty/protocoltcp/MyServerInitializer.java     |  3 +++
 .../cn/zyjblogs/netty/source/echo/EchoClient.java  | 14 ++------------
 .../netty/source/echo/EchoClientHandler.java       |  2 --
 .../cn/zyjblogs/netty/source/echo/EchoServer.java  |  6 +-----
 9 files changed, 27 insertions(+), 23 deletions(-)

diff --git a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyClientHandler.java b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyClientHandler.java
index 74d7cf2..70aa2f8 100644
--- a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyClientHandler.java
+++ b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyClientHandler.java
@@ -19,7 +19,10 @@ public class MyClientHandler extends SimpleChannelInboundHandler<MessageProtocol
      */
     @Override
     protected void channelRead0(ChannelHandlerContext ctx, MessageProtocol msg) throws Exception {
-
+        System.out.println("客户端接收到的消息:");
+        System.out.println("长度="+msg.getLen());
+        System.out.println("内容="+new String(msg.getContent(),CharsetUtil.UTF_8));
+        System.out.println("客户端接收消息包数量="+(++this.count));
     }
 
     @Override
diff --git a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyClientInitializer.java b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyClientInitializer.java
index 156c291..c7b6366 100644
--- a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyClientInitializer.java
+++ b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyClientInitializer.java
@@ -10,7 +10,10 @@ public class MyClientInitializer extends ChannelInitializer<SocketChannel> {
     @Override
     protected void initChannel(SocketChannel ch) throws Exception {
         ch.pipeline()
+                //编码器
                 .addLast(new MyMessageEncoder())
+                //解码器
+                .addLast(new MyMessageDecoder())
                 .addLast(new MyClientHandler());
     }
 }
diff --git a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyMessageDecoder.java b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyMessageDecoder.java
index 98206c8..9df754a 100644
--- a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyMessageDecoder.java
+++ b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyMessageDecoder.java
@@ -13,7 +13,7 @@ public class MyMessageDecoder extends ReplayingDecoder<MessageProtocol> {
 
     @Override
     protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
-        System.out.println("MyMessageDecoder方法被调用 解码");
+        System.out.println("\nMyMessageDecoder方法被调用 解码");
         //需要将得到的二进制字节码 转成 MessageProtocol
         int length = in.readInt();
         byte[] content = new byte[length];
diff --git a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyMessageEncoder.java b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyMessageEncoder.java
index 7a9d68a..781c888 100644
--- a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyMessageEncoder.java
+++ b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyMessageEncoder.java
@@ -9,7 +9,7 @@ public class MyMessageEncoder extends MessageToByteEncoder<MessageProtocol> {
 
     @Override
     protected void encode(ChannelHandlerContext ctx, MessageProtocol msg, ByteBuf out) throws Exception {
-        System.out.println("MyMessageEncoder方法被调用 编码");
+        System.out.println("\nMyMessageEncoder方法被调用 编码");
         out.writeInt(msg.getLen());
         out.writeBytes(msg.getContent());
     }
diff --git a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyServerHandler.java b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyServerHandler.java
index c34b4fd..6b262db 100644
--- a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyServerHandler.java
+++ b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyServerHandler.java
@@ -7,6 +7,7 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 import io.netty.util.CharsetUtil;
 
+import java.nio.charset.StandardCharsets;
 import java.util.UUID;
 
 public class MyServerHandler extends SimpleChannelInboundHandler<MessageProtocol> {
@@ -20,9 +21,19 @@ public class MyServerHandler extends SimpleChannelInboundHandler<MessageProtocol
     @Override
     protected void channelRead0(ChannelHandlerContext ctx, MessageProtocol msg) throws Exception {
         //接收数据，并处理
-        System.out.println("\n服务端接收信息：");
+        System.out.println("服务端接收信息：");
         System.out.println("长度="+msg.getLen());
         System.out.println("内容="+new String(msg.getContent(),CharsetUtil.UTF_8));
         System.out.println("服务器接收消息包数量="+(++this.count));
+
+        //回复消息
+        String responseContent = UUID.randomUUID().toString();
+        int responseLen = responseContent.getBytes(CharsetUtil.UTF_8).length;
+        MessageProtocol messageProtocol = new MessageProtocol();
+        messageProtocol.setLen(responseLen);
+        messageProtocol.setContent(responseContent.getBytes(CharsetUtil.UTF_8));
+
+        ctx.writeAndFlush(messageProtocol);
+
     }
 }
diff --git a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyServerInitializer.java b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyServerInitializer.java
index 9645432..772f00a 100644
--- a/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyServerInitializer.java
+++ b/nettyPro/src/main/java/cn/zyjblogs/netty/protocoltcp/MyServerInitializer.java
@@ -11,7 +11,10 @@ public class MyServerInitializer extends ChannelInitializer<SocketChannel> {
     @Override
     protected void initChannel(SocketChannel ch) throws Exception {
         ch.pipeline()
+                //解码器
                 .addLast(new MyMessageDecoder())
+                //编码器
+                .addLast(new MyMessageEncoder())
                 .addLast(new MyServerHandler());
     }
 }
diff --git a/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoClient.java b/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoClient.java
index cce208a..2fd094d 100644
--- a/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoClient.java
+++ b/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoClient.java
@@ -16,21 +16,13 @@
 package cn.zyjblogs.netty.source.echo;
 
 import io.netty.bootstrap.Bootstrap;
-import io.netty.channel.ChannelFuture;
-import io.netty.channel.ChannelInitializer;
-import io.netty.channel.ChannelOption;
-import io.netty.channel.ChannelPipeline;
-import io.netty.channel.DefaultEventLoopGroup;
-import io.netty.channel.EventLoopGroup;
+import io.netty.channel.*;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioSocketChannel;
 import io.netty.handler.ssl.SslContext;
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
-import io.netty.util.concurrent.DefaultEventExecutorGroup;
-import io.netty.util.concurrent.EventExecutor;
-import io.netty.util.concurrent.EventExecutorGroup;
 
 /**
  * Sends one message when a connection is open and echoes back any received
@@ -46,7 +38,6 @@ public final class EchoClient {
     static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
 
     public static void main(String[] args) throws Exception {
-        EventExecutorGroup eventExecutors = new DefaultEventExecutorGroup(4);
         // Configure SSL.git
         final SslContext sslCtx;
         if (SSL) {
@@ -71,8 +62,7 @@ public final class EchoClient {
                          p.addLast(sslCtx.newHandler(ch.alloc(), HOST, PORT));
                      }
                      //p.addLast(new LoggingHandler(LogLevel.INFO));
-                     //如果在handler前面添加指定EventExecutorGroup，name该handler优先加入到该线程池
-                     p.addLast(eventExecutors,new EchoClientHandler());
+                     p.addLast(new EchoClientHandler());
                  }
              });
 
diff --git a/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoClientHandler.java b/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoClientHandler.java
index 36f7a8f..690a60f 100644
--- a/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoClientHandler.java
+++ b/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoClientHandler.java
@@ -19,7 +19,6 @@ import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
-import io.netty.util.CharsetUtil;
 
 /**
  * Handler implementation for the echo client.  It initiates the ping-pong
@@ -43,7 +42,6 @@ public class EchoClientHandler extends ChannelInboundHandlerAdapter {
     @Override
     public void channelActive(ChannelHandlerContext ctx) {
         ctx.writeAndFlush(firstMessage);
-        ctx.writeAndFlush(Unpooled.copiedBuffer("你好", CharsetUtil.UTF_8));
     }
 
     @Override
diff --git a/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoServer.java b/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoServer.java
index ef34009..4474114 100644
--- a/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoServer.java
+++ b/nettyPro/src/main/java/cn/zyjblogs/netty/source/echo/EchoServer.java
@@ -16,11 +16,7 @@
 package cn.zyjblogs.netty.source.echo;
 
 import io.netty.bootstrap.ServerBootstrap;
-import io.netty.channel.ChannelFuture;
-import io.netty.channel.ChannelInitializer;
-import io.netty.channel.ChannelOption;
-import io.netty.channel.ChannelPipeline;
-import io.netty.channel.EventLoopGroup;
+import io.netty.channel.*;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioServerSocketChannel;