优化雷达tcp客户端

‘liusuyi’

2023-12-28 1c490ff27a0eeb4327923a9367f3a7c2aaa929b2

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

@@ -1,29 +1,41 @@
package com.ard.utils.netty.tcp;

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

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class BootNettyClientChannelCache {
 
    public static volatile Map<String, ArdEquipRadar> radarMapCache = new ConcurrentHashMap<String, ArdEquipRadar>();
    public static volatile Map<String, BootNettyClientChannel> channelMapCache = new ConcurrentHashMap<String, BootNettyClientChannel>();
 
    public static void add(String code, BootNettyClientChannel channel){
        channelMapCache.put(code,channel);
    }
 
    public static void addRadar(String code, ArdEquipRadar radar){
        radarMapCache.put(code,radar);
    }
    public static BootNettyClientChannel get(String code){
        return channelMapCache.get(code);
    }
 
    public static ArdEquipRadar getRadar(String code){
        return radarMapCache.get(code);
    }
    public static void remove(String code){
        channelMapCache.remove(code);
    }
 
    public static void removeRadar(String code){
        radarMapCache.remove(code);
    }
    public static void save(String code, BootNettyClientChannel channel) {
        if(channelMapCache.get(code) == null) {
            add(code,channel);
        }
    }
 
    public static void save(String code, ArdEquipRadar radar) {
        if(radarMapCache.get(code) == null) {
            addRadar(code,radar);
        }
    }
 
}