...

bin/client.bat

@@ -0,0 +1 @@
+java -cp ./netty-example.jar com.ljja.client.ClientApp

bin/server.bat

@@ -0,0 +1 @@
+java -cp ./netty-example.jar com.ljja.server.ServerApp

src/main/java/com/ljja/client/ClientApp.java

@@ -37,14 +37,13 @@ public void initChannel(SocketChannel ch) throws Exception {
             //异步连接到服务
             ChannelFuture future = b.connect(HOST, PORT).sync();
 
-
             Channel clientChannel = future.channel();
 
             int currentCount = 10;
 
             while (currentCount > 0) {
 
-                Thread.sleep(1000);
+                //Thread.sleep(1000);
 
                 clientChannel.writeAndFlush("Hello Netty Server");
 
@@ -58,7 +57,7 @@ public void initChannel(SocketChannel ch) throws Exception {
 
                 clientChannel.writeAndFlush(msgEntity);
 
-                currentCount -= 1;
+                //currentCount -= 1;
             }
 
             System.out.println("Close Channel");

src/main/java/com/ljja/encoder/CustomDecoder.java

@@ -5,19 +5,15 @@
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 
-
 public class CustomDecoder extends LengthFieldBasedFrameDecoder {
 
     //判断传送客户端传送过来的数据是否按照协议传输，头部信息的大小应该是 byte+byte+int = 1+1+4 = 6
     private static final int HEADER_SIZE = 6;
-
     private byte type;
-
     private byte flag;
-
     private int length;
-
     private String body;
+    private String encoding = "UTF-8";
 
     /**
      * @param maxFrameLength      解码时，处理每个帧数据的最大长度
@@ -65,10 +61,8 @@ protected Object decode(ChannelHandlerContext ctx, ByteBuf in) throws Exception
 
         buf.readBytes(req);
 
-        body = new String(req, "UTF-8");
-
-        CustomMsg customMsg = new CustomMsg(type, flag, length, body);
+        body = new String(req, encoding);
 
-        return customMsg;
+        return new CustomMsg(type, flag, length, body);
     }
 }

src/main/java/com/ljja/protocol/CustomMsg.java

@@ -1,7 +1,7 @@
 package com.ljja.protocol;
 
 /**
- * Created by Administrator on 2017/10/28.
+ * 消息协议数据包
  */
 public class CustomMsg {
 

src/main/java/com/ljja/server/ServerApp.java

@@ -17,7 +17,7 @@
  */
 public class ServerApp {
 
-    private static final int MAX_FRAME_LENGTH = 1024 * 1024;
+    private static final int MAX_FRAME_LENGTH = 1024 * 1024 * 10;
     private static final int LENGTH_FIELD_LENGTH = 4;
     private static final int LENGTH_FIELD_OFFSET = 2;
     private static final int LENGTH_ADJUSTMENT = 0;