From f2fc9d6cf202fc3f07bad01887e748ab8369da02 Mon Sep 17 00:00:00 2001
From: lijiuwei <lijiuwei@ht-atia.com>
Date: Wed, 2 Apr 2025 11:09:01 +0800
Subject: [PATCH] =?UTF-8?q?netty=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/inspect/tcpserver/tcp/NettyClient.java    | 10 +++++-----
 .../java/com/inspect/tcpserver/tcp/NettyServer.java    |  8 ++++----
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java b/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java
index 7b37ec6..cc95564 100644
--- a/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java
+++ b/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);
             }
-        });
+//        });
     }
 
     //处理接收消息
diff --git a/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java b/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java
index 57586a6..5ebad5c 100644
--- a/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java
+++ b/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);
             }
-        });
+//        });
     }
 
     //重新发送