From 5f92b2034f84caeab9cb6efc61ecbe22407935b4 Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期二, 16 一月 2024 12:14:03 +0800
Subject: [PATCH] 优化主库协议，支持路由
---
src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java | 25 +++++++++++++++++--------
1 files changed, 17 insertions(+), 8 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 1f87e38..614ded3 100644
--- a/src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java
+++ b/src/main/java/com/fzzy/protocol/wujia/client/ClientHandler.java
@@ -15,6 +15,7 @@
private AnalysisService analysisService;
+ private static String msgStr = "";
@Override
public void channelActive(ChannelHandlerContext ctx) {
InetSocketAddress socketAddress = (InetSocketAddress) ctx.channel()
@@ -44,16 +45,24 @@
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);
+ }
+
+ }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