netty代码优化

src/main/java/com/inspect/tcpserver/tcp/NettyClient.java

@@ -57,7 +57,7 @@ public class NettyClient {
     private DownXml2Json downXml2Json;
     private NettyClientHandler client;
     private ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(4);
-    private ExecutorService executorService = new ThreadPoolExecutor(20, 50, 100, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(400));
+//    private ExecutorService executorService = new ThreadPoolExecutor(20, 50, 100, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(400));
 
     @Resource
     UpSystemServerProperties upSystemServerProperties;
@@ -175,14 +175,14 @@ public class NettyClient {
 
     //线程处理接收函数
     public void ReceiveMsg(BinaryModel binaryModel) {
-        executorService.execute(() ->
-        {
+//        executorService.execute(() ->
+//        {
             try {
                 threadDealMsg(binaryModel);
             } catch (Exception e) {
-                e.printStackTrace();
+                logger.error("error", e);
             }
-        });
+//        });
     }
 
     //处理接收消息

src/main/java/com/inspect/tcpserver/tcp/NettyServer.java

@@ -61,7 +61,7 @@ public class NettyServer {
     private DownXml2Json downXml2Json = new DownXml2Json(aliasHost);
     private UpJson2Xml upJson2Xml = new UpJson2Xml(aliasHost);
     private NettyServerHandler nettyServerHandler;
-    private ExecutorService executorService = new ThreadPoolExecutor(20, 50, 100, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(400));
+//    private ExecutorService executorService = new ThreadPoolExecutor(20, 50, 100, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(400));
 
     @Resource
     DeviceServerProperties deviceServerProperties;
@@ -198,13 +198,13 @@ public class NettyServer {
 
     //开启线程处理消息
     public void receiveMsg(BinaryModel binaryModel, ChannelHandlerContext context) {
-        executorService.execute(() -> {
+//        executorService.execute(() -> {
             try {
                 dealMsgInThreadPool(binaryModel, context);
             } catch (Exception e) {
-                logger.error(ExceptionUtils.getStackTrace(e));
+                logger.error("error", e);
             }
-        });
+//        });
     }
 
     //重新发送