netty搭建tcp服务器通信(解决粘包问题)

更新时间:2023-05-12 03:00:43 阅读: 评论:0

*/
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

本文发布于:2023-05-12 03:00:43,感谢您对本站的认可!

本文链接:https://www.wtabcd.cn/fanwen/fan/82/593877.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

标签:连接   关闭   是否   存在
相关文章
留言与评论(共有 0 条评论)
   
验证码:
推荐文章
排行榜
Copyright ©2019-2022 Comsenz Inc.Powered by © 专利检索| 网站地图