From 91f6e60919b92b7f99a41f2ddeb42df17cd0c487 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Fri, 25 Oct 2024 10:48:26 +0800
Subject: [PATCH] 优化
---
ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java | 17 ++++++++---------
1 files changed, 8 insertions(+), 9 deletions(-)
diff --git a/ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java b/ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java
index be26ca9..f4b544a 100644
--- a/ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java
+++ b/ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java
@@ -2,7 +2,6 @@
import com.ard.tianyu.netty.TyNettyTcpClient;
import com.ard.tianyu.netty.command.BaseCommand;
-import com.ard.tianyu.netty.command.HeartbeatCommand;
import com.ard.tianyu.service.ITyService;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
@@ -29,10 +28,10 @@
@Override
public void channelRead0(ChannelHandlerContext ctx, BaseCommand command) {
- //InetSocketAddress ipSocket = (InetSocketAddress) ctx.channel().remoteAddress();
- //String host = ipSocket.getHostString();
- //int port = ipSocket.getPort();
- //tyService.processMessage(host + "/" + port, msg);
+ InetSocketAddress ipSocket = (InetSocketAddress) ctx.channel().remoteAddress();
+ String host = ipSocket.getHostString();
+ int port = ipSocket.getPort();
+ tyService.processMessage(host + ":" + port, command);
}
@Override
@@ -56,9 +55,9 @@
if (event.state() == IdleState.READER_IDLE) {
log.info("客户端读超时");
} else if (event.state() == IdleState.WRITER_IDLE) {
- log.info("写空闲发送⼼跳!");
- HeartbeatCommand msg = new HeartbeatCommand(System.currentTimeMillis());
- ctx.writeAndFlush(msg);
+ // log.info("写空闲发送⼼跳!");
+ // HeartbeatCommand msg = new HeartbeatCommand(System.currentTimeMillis());
+ //ctx.writeAndFlush(msg);
} else if (event.state() == IdleState.ALL_IDLE) {
log.info("客户端所有操作超时");
}
@@ -75,7 +74,7 @@
ctx.channel().eventLoop().schedule(() -> {
log.error("天宇服务端链接不上，开始重连操作...");
try {
- tyNettyTcpClient.initOneConnection(host, port);
+ tyNettyTcpClient.initConnection(host, port);
} catch (Exception e) {
log.error("天宇服务端连接异常: {}", e.getMessage());
}
--
Gitblit v1.9.3