From 3a97ed3e03c8969aef34d172bf46116596683bd3 Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期三, 27 九月 2023 21:50:00 +0800
Subject: [PATCH] 贝博粮情解析2
---
igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grainv1/client/ClientHandler.java | 15 +++++++--------
1 files changed, 7 insertions(+), 8 deletions(-)
diff --git a/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/client/ClientHandler.java b/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grainv1/client/ClientHandler.java
similarity index 72%
rename from igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/client/ClientHandler.java
rename to igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grainv1/client/ClientHandler.java
index 9fdb924..4d97ce2 100644
--- a/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/client/ClientHandler.java
+++ b/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grainv1/client/ClientHandler.java
@@ -1,13 +1,12 @@
-package com.ld.igds.protocol.beibo.grain.client;
+package com.ld.igds.protocol.beibo.grainv1.client;
-import com.ld.igds.protocol.beibo.grain.analysis.AnalysisService;
+import com.ld.igds.protocol.beibo.grainv1.analysis.AnalysisService;
import com.ld.igds.util.BytesUtil;
import com.ld.igds.util.SpringUtil;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.util.internal.logging.InternalLogger;
import io.netty.util.internal.logging.InternalLoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
import java.net.InetSocketAddress;
@@ -25,7 +24,7 @@
public void channelActive(ChannelHandlerContext ctx) {
InetSocketAddress insocket = (InetSocketAddress) ctx.channel()
.remoteAddress();
- log.info("璐濆崥绮儏鍒嗘満鎴愬姛杩炴帴锛孖P={},port={}", insocket.getAddress()
+ log.info("鍒嗘満鎴愬姛杩炴帴锛孖P={},port={}", insocket.getAddress()
.getHostAddress(), insocket.getPort());
}
@@ -36,7 +35,7 @@
InetSocketAddress insocket = (InetSocketAddress) ctx.channel()
.remoteAddress();
- log.info("璐濆崥绮儏鍒嗘満鏂紑杩炴帴锛孖P={},port={}", insocket.getAddress(),insocket.getPort());
+ log.info("鍒嗘満鏂紑杩炴帴锛孖P={},port={}", insocket.getAddress(),insocket.getPort());
}
@Override
@@ -44,15 +43,15 @@
throws Exception {
byte[] bytes = (byte[]) msg;
String result = BytesUtil.bytesToString(bytes);
- log.info("璐濆崥绮儏鍒嗘満杩斿洖淇℃伅=" + result);
+ log.info("鍒嗘満杩斿洖淇℃伅=" + result);
- InetSocketAddress insocket = (InetSocketAddress) ctx.channel().remoteAddress();
+// InetSocketAddress insocket = (InetSocketAddress) ctx.channel().remoteAddress();
//瑙ｆ瀽
if (null == analysisService) {
analysisService = (AnalysisService) SpringUtil.getBean(AnalysisService.BEAN_ID);
}
- analysisService.analysis(result);
+// analysisService.analysis(result);
}
@Override
--
Gitblit v1.9.3