修改nettyTCP客户端断开重连 增加数据库连接池 修改日志打印

‘liusuyi’

2023-07-05 1fd64b07ddb99c2d9cc8a358b71aceb6a2c81492

 src/main/java/com/ard/alarm/radar/service/impl/ArdEquipRadarServiceImpl.java

@@ -4,6 +4,7 @@
import com.ard.alarm.radar.domain.ArdEquipRadar;
import com.ard.alarm.radar.mapper.ArdEquipRadarMapper;
import com.ard.alarm.radar.service.IArdEquipRadarService;
import com.ard.utils.tcp.ClientInitialize;
import com.ard.utils.tcp.NettyTcpClient;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -19,32 +20,10 @@
 * @date 2023-03-11
 */
@Service
@Slf4j(topic = "radar")
public class ArdEquipRadarServiceImpl implements IArdEquipRadarService
{
    @Autowired
    private ArdEquipRadarMapper ardEquipRadarMapper;


    @Resource
    NettyTcpClient nettyTcpClient;
    @Value("${spring.netty.tcp.enabled}")
    private Boolean tcpClientEnable;
    @PostConstruct
    public void init() {
        if(!tcpClientEnable)
        {
            return;
        }
        List<ArdEquipRadar> ardEquipRadars = selectArdEquipRadarList(new ArdEquipRadar());
        for (ArdEquipRadar ardEquipRadar:ardEquipRadars)
        {
            String host = ardEquipRadar.getIp();
            Integer port = Integer.valueOf(ardEquipRadar.getPort());
            log.info("TCP客户端尝试连接："+host+":"+port);
            nettyTcpClient.init(ardEquipRadar);
        }
    }

    /**
     * 查询radar