优化

liusuyi

2025-03-22 fe63fd580c5b65fa398dfe1fdf44466b26c6aadd

 ard-work/src/main/java/com/ard/tianyu/component/netty/handler/ClientHandler.java

@@ -1,7 +1,7 @@
package com.ard.tianyu.component.netty.handler;

import com.ard.tianyu.domain.cache.TyTcpServerCache;
import com.ard.tianyu.component.netty.TyNettyTcpClient;
import com.ard.tianyu.component.netty.NettyTcpClient;
import com.ard.tianyu.component.netty.command.BaseCmd;
import com.ard.tianyu.service.ITyService;
import io.netty.channel.ChannelHandler;
@@ -25,7 +25,7 @@
    private ITyService tyService;

    @Resource
    private TyNettyTcpClient tyNettyTcpClient;
    private NettyTcpClient nettyTcpClient;

    @Override
    public void channelRead0(ChannelHandlerContext ctx, BaseCmd command) {
@@ -75,7 +75,7 @@
        ctx.channel().eventLoop().schedule(() -> {
            log.error("天宇服务端链接不上，开始重连操作...");
            try {
                tyNettyTcpClient.initConnection(host, port);
                nettyTcpClient.initConnection(host, port);
            } catch (Exception e) {
                log.error("天宇服务端连接异常: {}", e.getMessage());
            }