修改forest动态服务请求

liusuyi

2025-10-14 39e8bb722006c55fb986a7394bfb4747d482b8c4

 ard-work/src/main/java/com/ard/work/component/netty/TyTcpClientManager.java

@@ -62,7 +62,7 @@
    }

    /**
     * 初始化与天宇服务器的连接
     * 初始化与六合服务器的连接
     */
    public void initConnection(String serverId, String host, Integer port) {
        String key = host + ":" + port;
@@ -113,23 +113,23 @@
        try {
            TcpClientSession session = channels.get(serverId);
            if (session == null) {
                log.error("未找到天宇服务器 [{}] 的连接", serverId);
                log.error("未找到六合服务器 [{}] 的连接", serverId);
                return;
            }

            ChannelFuture future = session.getChannelFuture();
            if (future == null || !future.channel().isActive()) {
                log.warn("天宇服务器 [{}] 连接未激活，无法发送消息", serverId);
                log.warn("六合服务器 [{}] 连接未激活，无法发送消息", serverId);
                return;
            }

            InetSocketAddress remote = (InetSocketAddress) future.channel().remoteAddress();
            future.channel().writeAndFlush(msg);
            log.debug("→ 向天宇服务器 [{}] ({}:{}) 发送消息，命令码：0x{}",
            log.debug("→ 向六合服务器 [{}] ({}:{}) 发送消息，命令码：0x{}",
                    serverId, remote.getHostString(), remote.getPort(),
                    String.format("%02X", msg.getCmdCode() & 0xFF));
        } catch (Exception e) {
            log.error("发送消息到天宇服务器 [{}] 异常：{}", serverId, e.getMessage());
            log.error("发送消息到六合服务器 [{}] 异常：{}", serverId, e.getMessage());
        }
    }