From b1c572949997a5d82d9b609163ff280a1c49627d Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期五, 26 四月 2024 14:09:45 +0800
Subject: [PATCH] 粮情协议优化
---
src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java | 31 ++++++++++++++++++++-----------
1 files changed, 20 insertions(+), 11 deletions(-)
diff --git a/src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java b/src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java
index 3fc685b..830878b 100644
--- a/src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java
+++ b/src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java
@@ -2,8 +2,7 @@
import com.fzzy.api.utils.BytesUtil;
import com.fzzy.api.utils.SpringUtil;
-import com.fzzy.protocol.youxian0.analysis.AnalysisService;
-import com.fzzy.protocol.youxian0.client.ClientEngine;
+import com.fzzy.protocol.wujia.analysis.AnalysisService;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import lombok.extern.slf4j.Slf4j;
@@ -16,6 +15,7 @@
private AnalysisService analysisService;
+ private static String msgStr = "";
@Override
public void channelActive(ChannelHandlerContext ctx) {
InetSocketAddress socketAddress = (InetSocketAddress) ctx.channel()
@@ -32,7 +32,7 @@
InetSocketAddress socketAddress = (InetSocketAddress) ctx.channel().remoteAddress();
log.info("杩炴帴缁堢鎺夌嚎锛孖P={},port={}", socketAddress.getAddress(), socketAddress.getPort());
- ClientEngine.defaultChannel = null;
+ //ClientEngine.defaultChannel = null;
}
@@ -45,16 +45,25 @@
String strMsg = BytesUtil.bytesToString(bytes);
log.info("缁堢杩斿洖淇℃伅锛孖P={},port={}锛宮sg={}", socketAddress.getAddress(), socketAddress.getPort(), strMsg);
+ msgStr+= strMsg;
- if (null == analysisService) {
- analysisService = SpringUtil.getBean(AnalysisService.class);
+ if(msgStr.endsWith("AABBCC")){
+
+ log.info("娑堟伅鎺ユ敹瀹屾暣寮�濮嬭В鏋愶紝IP={},port={}锛宮sg={}", socketAddress.getAddress(), socketAddress.getPort(), msgStr);
+
+ if (null == analysisService) {
+ analysisService = SpringUtil.getBean(AnalysisService.class);
+ }
+ try{
+ analysisService.analysis(socketAddress.getAddress(), socketAddress.getPort(), msgStr);
+ }catch (Exception e){
+ log.error(e.getMessage(),e);
+ }
+ msgStr = "";
+ }else{
+ log.info("娑堟伅涓嶅畬鏁达紝绛夊緟娑堟伅瀹屾暣锛孖P={},port={}锛宮sg={}", socketAddress.getAddress(), socketAddress.getPort(), strMsg);
+
}
-
- try{
- analysisService.analysis(socketAddress.getAddress(), socketAddress.getPort(), strMsg);
- }catch (Exception e){
- log.error(e.getMessage(),e);
- }
}
--
Gitblit v1.9.3