优化

liusuyi

2024-08-09 57ff679fd4d8117c1be87c06059dc1f9ddf914d3

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
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 lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
 
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
import static com.ard.utils.netty.tcp.RadarNettyTcpClient.RADAR_MAP;
 
@Component
@Slf4j(topic = "netty")
public class NettyInit {
    @Resource
    NettyTcpConfiguration nettyTcpConfig;
    @Resource
    private RadarNettyTcpClient radarNettyTcpClient;
    @Resource
    IArdEquipRadarService ardEquipRadarService;
    @PostConstruct
    public void createRadarConnect() {
        try {
            if (!nettyTcpConfig.getEnabled()) {
                return;
            }
            List<Map<String, Object>> list = new ArrayList<>();
            List<ArdEquipRadar> ardEquipRadars = ardEquipRadarService.selectArdEquipRadarList(new ArdEquipRadar());
            for (ArdEquipRadar ardEquipRadar : ardEquipRadars) {
                String host = ardEquipRadar.getIp();
                Integer port = Integer.valueOf(ardEquipRadar.getPort());
                Map<String,Object> mapParam =new HashMap<String, Object>();
                mapParam.put("IP",host);
                mapParam.put("PORT",port);
                list.add(mapParam);
                RADAR_MAP.put(host+":"+port,ardEquipRadar);
            }
            radarNettyTcpClient.initAllChannel(list);
        }catch (Exception e) {
            e.printStackTrace();
        }
    }
}