| | |
| | | // 异步连接tcp服务端 |
| | | bootstrap.remoteAddress(host, port).connect().addListener((ChannelFuture futureListener) -> { |
| | | if (!futureListener.isSuccess()) { |
| | | log.error("雷达【" + host + ":" + port + "】连接失败"); |
| | | log.debug("雷达【" + host + ":" + port + "】连接失败"); |
| | | futureListener.channel().close(); |
| | | // 连接失败信息插入Set |
| | | falseConnectSet.add(ardEquipRadar); |
| | | // 连接失败信息从map移除 |
| | | tureConnectMap.remove(futureListener.channel().id()); |
| | | } else { |
| | | log.info("雷达【" + host + ":" + port + "】连接成功"); |
| | | log.debug("雷达【" + host + ":" + port + "】连接成功"); |
| | | // 连接成功信息从Set拔除 |
| | | falseConnectSet.remove(ardEquipRadar); |
| | | // 连接成功信息写入map |