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(400)); +// private ExecutorService executorService = new ThreadPoolExecutor(20, 50, 100, TimeUnit.SECONDS, new LinkedBlockingQueue(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(400)); +// private ExecutorService executorService = new ThreadPoolExecutor(20, 50, 100, TimeUnit.SECONDS, new LinkedBlockingQueue(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); } - }); +// }); } //重新发送