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/BeiboClientEngine.java | 16 ++++++++++------
1 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/client/BeiboClientEngine.java b/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grainv1/client/BeiboClientEngine.java
similarity index 85%
rename from igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/client/BeiboClientEngine.java
rename to igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grainv1/client/BeiboClientEngine.java
index b4d65e2..de79179 100644
--- a/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/client/BeiboClientEngine.java
+++ b/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grainv1/client/BeiboClientEngine.java
@@ -1,4 +1,4 @@
-package com.ld.igds.protocol.beibo.grain.client;
+package com.ld.igds.protocol.beibo.grainv1.client;
import com.ld.igds.util.BytesUtil;
import com.ld.io.api.InvokeResult;
@@ -10,6 +10,8 @@
import io.netty.channel.socket.oio.OioSocketChannel;
import io.netty.handler.codec.bytes.ByteArrayDecoder;
import io.netty.handler.codec.bytes.ByteArrayEncoder;
+import io.netty.util.internal.logging.InternalLogger;
+import io.netty.util.internal.logging.InternalLoggerFactory;
/**
* 璐濆崥绮儏鍗忚锛屽垎鏈轰负鏈嶅姟绔紝骞冲彴涓哄鎴风涓诲姩杩炴帴
@@ -17,6 +19,8 @@
* @author czt
*/
public class BeiboClientEngine implements Runnable {
+
+ private final InternalLogger log = InternalLoggerFactory.getInstance(this.getClass());
private String host;
private int port;
@@ -44,14 +48,14 @@
public void startRun() throws Exception {
EventLoopGroup group = new OioEventLoopGroup();
Bootstrap b = new Bootstrap();
- // b.option(ChannelOption.SO_KEEPALIVE, true);
+// b.option(ChannelOption.SO_KEEPALIVE, true);
b.group(group).channel(OioSocketChannel.class)
.handler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel ch)
throws Exception {
ChannelPipeline p = ch.pipeline();
- // 瀛楃涓茶В鐮� 鍜� 缂栫爜
+ // 瀛楃涓茶В鐮佸拰缂栫爜
p.addLast("decoder", new ByteArrayDecoder());
p.addLast("encoder", new ByteArrayEncoder());
// 鑷繁鐨勯�昏緫Handler
@@ -62,15 +66,15 @@
// 鍙戣捣寮傛杩炴帴璇锋眰锛岀粦瀹氳繛鎺ョ鍙ｅ拰host淇℃伅
ChannelFuture channelFuture = b.connect(host, port);
this.channel = channelFuture.channel();
- // channelFuture.channel().closeFuture().sync();
+// channelFuture.channel().closeFuture().sync();
channelFuture.addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture arg0) throws Exception {
if (channelFuture.isSuccess()) {
- System.out.println("杩炴帴鏈嶅姟鍣ㄦ垚鍔�");
+ log.info("杩炴帴鏈嶅姟鍣ㄦ垚鍔�");
} else {
- System.out.println("杩炴帴鏈嶅姟鍣ㄥけ璐�");
+ log.info("杩炴帴鏈嶅姟鍣ㄥけ璐�");
channelFuture.cause().printStackTrace();
group.shutdownGracefully(); // 鍏抽棴绾跨▼缁�
}
--
Gitblit v1.9.3