优化雷达tcp客户端

‘liusuyi’

2023-12-28 dfdc6bdfda10de4c01fb1cfe43cabf050e71f8c3

 src/main/java/com/ard/utils/netty/tcp/ClientInitialize.java

@@ -37,7 +37,7 @@
@Component
@Slf4j(topic = "netty")
@Order(2)
public class ClientInitialize {
public class ClientInitialize implements ApplicationRunner{
    @Resource
    NettyTcpConfiguration nettyTcpConfig;
    @Resource
@@ -47,6 +47,7 @@
    public static CopyOnWriteArraySet<ArdEquipRadar> falseConnectSet = new CopyOnWriteArraySet();
    public static ConcurrentHashMap<String, ArdEquipRadar> tureConnectMap = new ConcurrentHashMap();
    public static ConcurrentHashMap<String, Object> SuccessConnectMap = new ConcurrentHashMap();
    public static ConcurrentHashMap<String, MessageParsing> MessageMap = new ConcurrentHashMap();
    /**
     * Netty初始化配置
     */
@@ -114,6 +115,7 @@
                falseConnectSet.remove(ardEquipRadar);
                // 连接成功信息写入map
                tureConnectMap.put(host+":"+port, ardEquipRadar);
                MessageMap.put(host+":"+port,new MessageParsing());
                SuccessConnectMap.put(ardEquipRadar.getId(),futureListener.channel());
            }
        });
@@ -122,7 +124,7 @@
    /**
     * 初始化方法
     */
   // @Override
    @Override
    public void run(ApplicationArguments args) {
        if (!nettyTcpConfig.getEnabled()) {
            return;