From 070b1e9cc8fccd36e7b65720a778ac46e118c792 Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期一, 04 三月 2024 09:13:04 +0800
Subject: [PATCH] 增加西山油罐协议
---
src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java | 31 +++++++++++--------------------
1 files changed, 11 insertions(+), 20 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 830878b..3fc685b 100644
--- a/src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java
+++ b/src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java
@@ -2,7 +2,8 @@
import com.fzzy.api.utils.BytesUtil;
import com.fzzy.api.utils.SpringUtil;
-import com.fzzy.protocol.wujia.analysis.AnalysisService;
+import com.fzzy.protocol.youxian0.analysis.AnalysisService;
+import com.fzzy.protocol.youxian0.client.ClientEngine;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import lombok.extern.slf4j.Slf4j;
@@ -15,7 +16,6 @@
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,26 +45,17 @@
String strMsg = BytesUtil.bytesToString(bytes);
log.info("缁堢杩斿洖淇℃伅锛孖P={},port={}锛宮sg={}", socketAddress.getAddress(), socketAddress.getPort(), strMsg);
- msgStr+= strMsg;
- 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);
-
+ if (null == analysisService) {
+ analysisService = SpringUtil.getBean(AnalysisService.class);
}
+ try{
+ analysisService.analysis(socketAddress.getAddress(), socketAddress.getPort(), strMsg);
+ }catch (Exception e){
+ log.error(e.getMessage(),e);
+ }
+
}
@Override
--
Gitblit v1.9.3