*/
private static Map<String, Channel> CHANNEL_POOL = new ConcurrentHashMap<>(); private static Map<Channel, String> KEY_POOL = new ConcurrentHashMap<>();
/**
* 添加 Channel
*
* @param key
*/
public static void add(String key, Channel channel) {
CHANNEL_POOL.put(key, channel);
KEY_POOL.put(channel, key);
}
/**
* 删除 Channel
*
* @param key
*/
public static void remove(String key) {
Channel channel = (key);
if (channel == null) {
return;
}
ve(key);
ve(channel);
}
/**
* 删除并同步关闭连接
*
* @param key
*/
public static void removeAndClo(String key) {
Channel channel = (key);
remove(key);
if (channel != null) {
/
/ 关闭连接
try {
channel.clo();
} catch (Exception e) {
e.printStackTrace();
}
}
}
public static void removeAndClo(Channel channel) {
String key = (channel);
removeAndClo(key);
}
/**
* 获得 Channel
*
* @param key
* @return String
*/
public static Channel getChannel(String key) {
return (key);
}
/**
* 获得 key
*
* @param channel
* @return Channel
*/
public static String getKey(Channel channel) {
return (channel);
}
/**
* 判断是否存在key
