Netty 通道怎么区分对应的用户？很多人搞错了！

忘是亡心i 2022-10-13 12:38 124阅读 0赞

**点击关注公众号，Java干货****及时送达**![09a3021cf45c86dc0850dae68c0b91a6.png][]

*作者：南城之南  
出处：www.cnblogs.com/liangshu/p/12459657.html*

## 前言 ##

考虑一个功能业务,在`web`程序中向指定的某个用户进行实时通讯

在Web运用的`Socket`通[讯功能中(如在线客服),为保证点对点通讯.而这个看似简单的根据用户寻到][.]起`channel`通道实际会碰到不少问题

1.  web程序中的`Http`协议是无状态的
2.  一般项目中`socket`服务和`web`项目是独立部署的
3.  `socket`连接存在重连的情况,而`Channel`对象每次都不一样
4.  `Channel`是面向网卡绑定的,无法序列化

## 解决方案 ##

通过管理一个线程安全的`用户标识`(如用户主键)和对应`channel`的`map`链表

private final ConcurrentHashMap<String, Channel> channelMap = new ConcurrentHashMap<>();

那么问题来了,

*  在[`netty`][netty]模块中怎么得到这个`用户标识`?
 *  又如何保证`netty socket`模块可以安全的识别某个通道属于某个用户?(这个可以像上面一样的方式解决)
 *  `nettysocket`模块接收到一条消息又任何证明这条通道是可信的?

在`nett`的实现中是没有认证也没有`HttpSession`这个东西的,也就是说.在`netty`程序线程中是无法得到web项目登录的用户情况的。另外，Netty 系列面试题和答案全部整理好了，微信搜索Java技术栈，在后台发送：面试，可以在线阅读。

出于这点,参考`web`项目集群的`session`共享方案.可以在Redis等缓存中保存登录信息.

![685812ab4cea5e79bbb9fad818e9eba9.png][]

1.  在`web`项目中登录之后在redis中在这个以`用户id`为名的`key`中保存一个`token`,
2.  在客户端`socket`通道建立之后立马发送包含一个`用户标识`和`ASK`到`socket`服务端,
3.  服务端根据`ASK`计算一个`token`和`redis`比对.一旦比对成功,则绑定当前`channel`和用户之间的关系;
4.  之后`server`每接收到一条消息就检测当前通道有没有绑定用户信息

> 这个`key`是**一次性**的.这点非常重要,试想一下.在你前台项目可能因为cookie过期或者后台已经自动将该用户下线,而你的`用户标识`和`ASK`暴露.那么就可能被恶意连接发送消息;

另外关于`token`和`ASK`之类的验证传输如果仅仅是为了识别和绑定用户与`channel`的关系,这点也是可以忽略的,只要redis中保存该用户的登录状态即可,通道建立的第一次通讯就传输当前浏览器的登录用户标识,再去redis中比对即可,但是redis中的这个`key`还是一次性的好,避免一个用户建立多条`socket`通道

#### 正确的绑定通道`Channel`和用户之间的关系 ####

如果我们仅仅有一个`ConcurrentHashMap<String, Channel>`,是无法快速优雅的判断当前`channel`是属于哪个用户的，我看到别人绝大多数的实现是在创建一个`channelId`和`用户标识`的Ma[p来管理。][.]

//key为channel的长id,channel.id().asLongText();value为用户id
    private final ConcurrentHashMap<String, String> channelAndUserMap = new ConcurrentHashMap<>();

[其实这不是最合理的做法,正确的做法是][.]利用`Channel`对象提供的`AttributeMap`来保存该通道的附带信息,很多人不知道`Channel`对象提供了一个绑定自定义数据的Map。

[使用示例：][.]

//用户id=>channel示例
    private final ConcurrentHashMap<String, Channel> channelMap = new ConcurrentHashMap<>();
    
    
    /**
     * 判断一个通道是否有用户在使用
     * 可做信息转发时判断该通道是否合法
     * @param channel
     * @return
     */
    public boolean hasUser(Channel channel) {
        AttributeKey<String> key = AttributeKey.valueOf("user");
        return (channel.hasAttr(key) || channel.attr(key).get() != null);//netty移除了这个map的remove方法,这里的判断谨慎一点
    }
    
    /**
     * 上线一个用户
     *
     * @param channel
     * @param userId
     */
    public void online(Channel channel, String userId) {
        //先判断用户是否在web系统中登录?
        //这部分代码个人实现,参考上面redis中的验证
    
            this.channelMap.put(userId, channel);
            AttributeKey<String> key = AttributeKey.valueOf("user");
            channel.attr(key).set(userId);
    
    
    }
    
    /**
     * 根据用户id获取该用户的通道
     *
     * @param userId
     * @return
     */
    public Channel getChannelByUserId(String userId) {
        return this.channelMap.get(userId);
    }
    
    /**
     * 判断一个用户是否在线
     *
     * @param userId
     * @return
     */
    public Boolean online(String userId) {
        return this.channelMap.containsKey(userId) && this.channelMap.get(userId) != null;
    }

[**注意!!**][.]

很多人拿`channel.id().asShortText()`来记录标识`channel`,这是错误的!!!!!短id不保证全局唯一!!

![d80e649cd9151752c568788d3b428d26.png][]

另外，关注公众号Java技术栈，在后台回复：面试，可以获取我整理的 Java 系列面试题和答案，非常齐全。

![f9711c734782653dcaea9ec48be22818.gif][]

![faa80358466e33cd59e0ef67ef2dff5b.png][]

[![71a8513eddd1ec9c3eda13b226abaddf.png][]][71a8513eddd1ec9c3eda13b226abaddf.png 1]

[![db4fa83fe04e0f0c70ed86eae3254ce8.png][]][db4fa83fe04e0f0c70ed86eae3254ce8.png 1]

[![80de77f62aa4fd3f9546d603de310f4d.png][]][80de77f62aa4fd3f9546d603de310f4d.png 1]

[![6b746a1c5d86762505d9f1564d6963d6.png][]][6b746a1c5d86762505d9f1564d6963d6.png 1]

[![3f1187ae127e6d0957daeb724dc6d82e.png][]][3f1187ae127e6d0957daeb724dc6d82e.png 1]

**关注Java技术栈看更多干货**

![fa53ad06e10b7566309f0d5a7f58c854.png][]

![ddc3571578141d4d16fcb274b2282f09.gif][]

获取 Spring Boot 实战笔记！

[09a3021cf45c86dc0850dae68c0b91a6.png]: /images/20221005/051e273b7e77480cbc426639ad25b0a4.png
[.]: http://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&chksm=eb50f82edc2771386229a5bb81d865eee375f8ecbec665494417beb8c933260114d67b34c3a0&idx=2&mid=2247531800&scene=21&sn=fbf496a2626d9d550c4ae95bb4f60c11#wechat_redirect
[netty]: http://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&chksm=eb50f765dc277e7328851c2d884e557c362c8cbfdfea922fd49b2cbacffc4ab10034c784b82c&idx=2&mid=2247529043&scene=21&sn=ccbb24c037bbe434e86779c4206f0040#wechat_redirect
[685812ab4cea5e79bbb9fad818e9eba9.png]: /images/20221005/af14d09816e34b66a7dcbdfc8f408f19.png
[d80e649cd9151752c568788d3b428d26.png]: /images/20221005/62b1d45b626b4ad8962e09306fd16bcf.png
[f9711c734782653dcaea9ec48be22818.gif]: /images/20221005/bce2891dcfdd4deea0960d5d8e720251.png
[faa80358466e33cd59e0ef67ef2dff5b.png]: /images/20221005/341c16ac9e03493a84c3f0abaace6959.png
[71a8513eddd1ec9c3eda13b226abaddf.png]: /images/20221005/093c64b032df464d8d44862b4ba7e47e.png
[71a8513eddd1ec9c3eda13b226abaddf.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247535009&scene=21&sn=5a0ac485739f9ee7be02bbe938ff0eb3#wechat_redirect
[db4fa83fe04e0f0c70ed86eae3254ce8.png]: /images/20221005/c739976141d441c5b66da0253394259e.png
[db4fa83fe04e0f0c70ed86eae3254ce8.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247534855&scene=21&sn=fdaf7ea70fca4597d3cc4e18f5ada334#wechat_redirect
[80de77f62aa4fd3f9546d603de310f4d.png]: /images/20221005/775726d4abda4595855b6d5a3ee1c64b.png
[80de77f62aa4fd3f9546d603de310f4d.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247530418&scene=21&sn=e6a0138c7c2f9a9ff6a8b4c878386211#wechat_redirect
[6b746a1c5d86762505d9f1564d6963d6.png]: /images/20221005/73691739a8ad4438815dad9de87523a1.png
[6b746a1c5d86762505d9f1564d6963d6.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247535062&scene=21&sn=c34b69e41525dbcb3c473c6986daa801#wechat_redirect
[3f1187ae127e6d0957daeb724dc6d82e.png]: /images/20221005/5202988cf88145168c5c429afa355892.png
[3f1187ae127e6d0957daeb724dc6d82e.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw%3D%3D&idx=1&mid=2247535563&scene=21&sn=b2a1de775b95890690e3295aa7e6b253#wechat_redirect
[fa53ad06e10b7566309f0d5a7f58c854.png]: /images/20221005/cef0102129934d219b3f425c1c4cdf89.png
[ddc3571578141d4d16fcb274b2282f09.gif]: /images/20221005/41f855a581904cb4b4a63921a90cfef9.png