| | |
| | | return bootstrap; |
| | | } |
| | | |
| | | /** 新增或重连服务器 */ |
| | | /** |
| | | * 新增或重连服务器 |
| | | */ |
| | | public void connectServer(ArdServerInfo serverInfo) { |
| | | String serverId = serverInfo.getId(); |
| | | String host = serverInfo.getHost(); |
| | |
| | | Channel channel = f.channel(); |
| | | channel.attr(AttributeKey.valueOf("serverId")).set(serverId); |
| | | TyTcpServerCache.putTcpServerCache(serverId, true); |
| | | // 断开服务器,修改状态为: 0 - 在线 |
| | | ardServerService.updateServerStatus(serverId, "1"); |
| | | } else { |
| | | log.warn("❌ 服务器 [{}] 连接失败", serverId); |
| | | TyTcpServerCache.putTcpServerCache(serverId, false); |
| | | // 断开服务器,修改状态为: 0 - 离线 |
| | | ardServerService.updateServerStatus(serverId, "0"); |
| | | } |
| | | }); |
| | | |
| | |
| | | channels.put(serverId, session); |
| | | } |
| | | |
| | | /** 断开服务器连接 */ |
| | | /** |
| | | * 断开服务器连接 |
| | | */ |
| | | public void disconnectServer(String serverId) { |
| | | TcpClientSession session = channels.remove(serverId); |
| | | if (session != null && session.getChannelFuture() != null) { |
| | | session.getChannelFuture().channel().close(); |
| | | log.info("断开服务器 [{}] 连接", serverId); |
| | | // 断开服务器,修改状态为: 0 - 离线 |
| | | ardServerService.updateServerStatus(serverId, "0"); |
| | | } |
| | | TyTcpServerCache.removeTcpServerCache(serverId); |
| | | } |
| | |
| | | session.getServerId(), session.getHost(), session.getPort(), timestamp); |
| | | }); |
| | | } |
| | | |
| | | } |