From d4dced0974a2e1872e416d88d20aa5d8f3815ae9 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Tue, 11 Feb 2025 17:05:59 +0800
Subject: [PATCH] 111
---
ard-work/src/main/java/com/ard/tianyu/netty/handler/ClientHandler.java | 7 ++++---
1 files changed, 4 insertions(+), 3 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 1bef005..646264d 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
@@ -1,5 +1,6 @@
package com.ard.tianyu.netty.handler;
+import com.ard.tianyu.model.cache.TyTcpServerCache;
import com.ard.tianyu.netty.TyNettyTcpClient;
import com.ard.tianyu.netty.command.BaseCmd;
import com.ard.tianyu.service.ITyService;
@@ -31,7 +32,7 @@
InetSocketAddress ipSocket = (InetSocketAddress) ctx.channel().remoteAddress();
String host = ipSocket.getHostString();
int port = ipSocket.getPort();
- tyService.processMessage(host + ":" + port, command);
+ tyService.processReplyMessage(host + ":" + port, command);
}
@Override
@@ -45,7 +46,7 @@
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
log.error("发生异常: ", cause); // 使用日志记录异常
- ctx.close();
+ // ctx.close();
}
@Override
@@ -70,7 +71,7 @@
int port = ipSocket.getPort();
String host = ipSocket.getHostString();
log.error("与天宇服务{}:{}连接断开!", host, port);
-
+ TyTcpServerCache.putTcpServerCache(host + ":" + port, false);
ctx.channel().eventLoop().schedule(() -> {
log.error("天宇服务端链接不上，开始重连操作...");
try {
--
Gitblit v1.9.3