ard-work/src/main/java/com/ard/work/component/netty/TyTcpClientManager.java
@@ -63,7 +63,9 @@ return bootstrap; } /** 新增或重连服务器 */ /** * 新增或重连服务器 */ public void connectServer(ArdServerInfo serverInfo) { String serverId = serverInfo.getId(); String host = serverInfo.getHost(); @@ -97,7 +99,9 @@ channels.put(serverId, session); } /** 断开服务器连接 */ /** * 断开服务器连接 */ public void disconnectServer(String serverId) { TcpClientSession session = channels.remove(serverId); if (session != null && session.getChannelFuture() != null) { @@ -188,5 +192,4 @@ session.getServerId(), session.getHost(), session.getPort(), timestamp); }); } }