优化雷达tcp客户端

‘liusuyi’

2023-12-28 1c490ff27a0eeb4327923a9367f3a7c2aaa929b2

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
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);
        }
    }
 
}