更改雷达tcp客户端

‘liusuyi’

2023-12-28 eae9c75f70004dfe128718c63fe04c1a5cc35b01

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

@@ -26,7 +26,7 @@
 **/
@Slf4j(topic = "netty")
@Component
public class DynamicClient implements ApplicationRunner {
public class DynamicClient {
    @Resource
    IArdEquipRadarService ardEquipRadarService;
    @Resource
@@ -126,25 +126,27 @@
    /**
     * 初始化方法
     */
    @Override

    public void run(ApplicationArguments args) {
        if (!nettyTcpConfig.getEnabled()) {
            return;
        }
        EventLoopGroup group = new NioEventLoopGroup();
        Bootstrap bootstrap = new Bootstrap();
        bootstrap.group(group)
                .channel(NioSocketChannel.class)
                .option(ChannelOption.TCP_NODELAY, true)
                .option(ChannelOption.SO_KEEPALIVE, true)
                .handler(new DynamicClientInitializer());
        //EventLoopGroup group = new NioEventLoopGroup();
        //Bootstrap bootstrap = new Bootstrap();
        //bootstrap.group(group)
        //        .channel(NioSocketChannel.class)
        //        .option(ChannelOption.TCP_NODELAY, true)
        //        .option(ChannelOption.SO_KEEPALIVE, true)
        //        .handler(new DynamicClientInitializer());
        List<ArdEquipRadar> ardEquipRadars = ardEquipRadarService.selectArdEquipRadarList(new ArdEquipRadar());
        for (ArdEquipRadar ardEquipRadar : ardEquipRadars) {
            String host = ardEquipRadar.getIp();
            Integer port = Integer.valueOf(ardEquipRadar.getPort());
            log.debug("TCP client try to connect radar【：" + host + ":" + port+"】");
            // connectServer(ardEquipRadar);//连接每一个雷达服务
            connect(bootstrap, ardEquipRadar);
           // connect(bootstrap, ardEquipRadar);
            BootNettyClientThread thread = new BootNettyClientThread(host,port);
            thread.start();
        }
    }
}