| | |
| | | @Component |
| | | @Slf4j(topic = "netty") |
| | | @Order(2) |
| | | public class ClientInitialize implements ApplicationRunner { |
| | | public class ClientInitialize { |
| | | @Resource |
| | | NettyTcpConfiguration nettyTcpConfig; |
| | | @Resource |
| | |
| | | // 连接成功信息从Set拔除 |
| | | falseConnectSet.remove(ardEquipRadar); |
| | | // 连接成功信息写入map |
| | | tureConnectMap.put(host+"_"+port, ardEquipRadar); |
| | | tureConnectMap.put(host+":"+port, ardEquipRadar); |
| | | SuccessConnectMap.put(ardEquipRadar.getId(),futureListener.channel()); |
| | | } |
| | | }); |
| | |
| | | /** |
| | | * 初始化方法 |
| | | */ |
| | | @Override |
| | | // @Override |
| | | public void run(ApplicationArguments args) { |
| | | if (!nettyTcpConfig.getEnabled()) { |
| | | return; |