分支自 ard/ruoyi-api-alarm
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
‘liusuyi’
2023-12-05 745d5b90be7d8cdb8873b18d18b286fdc4b6913b 
 src/main/java/com/ard/utils/netty/tcp/DynamicClient.java


文件名从 src/main/java/com/ard/utils/tcp/DynamicClient.java 修改


@@ -1,13 +1,13 @@


package com.ard.utils.tcp;


package com.ard.utils.netty.tcp;




import com.ard.alarm.radar.domain.ArdEquipRadar;


import com.ard.alarm.radar.service.IArdEquipRadarService;


import com.ard.utils.netty.config.NettyTcpConfiguration;


import io.netty.bootstrap.Bootstrap;


import io.netty.channel.*;


import io.netty.channel.nio.NioEventLoopGroup;


import io.netty.channel.socket.nio.NioSocketChannel;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.boot.ApplicationArguments;


import org.springframework.stereotype.Component;


import javax.annotation.Resource;


@@ -28,9 +28,8 @@


public class DynamicClient {


    @Resource


    IArdEquipRadarService ardEquipRadarService;




    @Value("${spring.netty.tcp.enabled}")


    private Boolean tcpClientEnable;


    @Resource


    NettyTcpConfiguration nettyTcpConfig;




    private static List<Channel> serverChannels = new ArrayList<>();


    public static ConcurrentHashMap<Channel, ArdEquipRadar> ConnectMap = new ConcurrentHashMap();


@@ -128,7 +127,7 @@


     */


    //@Override


    public void run(ApplicationArguments args) {


        if (!tcpClientEnable) {


        if (!nettyTcpConfig.getEnabled()) {


            return;


        }


        EventLoopGroup group = new NioEventLoopGroup();