您当前的位置:首页 > 电脑百科 > 程序开发 > 编程百科

netty实现websocket客户端与服务端消息透传

时间:2021-05-24 12:37:50  来源:今日头条  作者:localhost
  • 前言:作为一个刚踏入职场的实习生,我很幸运参加了某个政府项目,并且在项目中负责一个核心模块功能的开发,而不是从头到尾对数据库的crud。虽然我一直心里抱怨我的工作范围根本就不是实习生干的活,因为没有前辈带我、入职就开始改bug。但在这样的环境下我却学到了很多东西,即便老板有压榨我的嫌疑,却给了我如此好的历练机会(但工资方面真的很亏QAQ),毕竟实习过后跳槽简历上还有亮点。
  • 背景:在不同的网络环境、不同的开发语言组成的闭环系统中,多个模块之间要实时获取硬件设备的状态,并以xml报文的格式相互传递。在必要的时候解析这个报文获取其中的关键信息完成相应的动作,最后直观地把信息显示给前端用户。如此一来就是涉及到了跨终端通信,并且有的功能模块既要充当客户端分发指令,还要作为客户端从别处获取信息。很不巧的是,我负责的模块正是充当消息中转站的作用,为了解决这个需求我才有了了解这种机制的机会。
  • 正文:由于涉及到不同模块之间的通信,其中又包含了web前端,为了保持通信协议的一致性项目采用了ws协议,即websocket。

http协议和ws协议:最直观的特点就是访问地址的写法上略有不同,两种访问分别为http://ip:port、ws://ip:port。http协议访问采用一问一答的方式——客户端发起请求到服务端,服务端收到请求后返回对应的信息,通信结束。虽然可以利用ajax发起异步的http请求,不过都是一次访问后连接就断开(ajax轮询可以解决此问题,对服务器资源消耗较大);ws协议建立于TCP协议之上,我们观察ws的头部信息会发现一件有意思的事情

HttpObjectAggregator$AggregatedFullHttpRequest(decodeResult: success, version: HTTP/1.1, content: CompositeByteBuf(ridx: 0, widx: 0, cap: 0, components=0))
GET / HTTP/1.1
Host: localhost:8888
Connection: Upgrade
Pragma: no-cache
Cache-Control: no-cache
User-Agent: Mozilla/5.0 (windows NT 10.0; Win64; x64) AppleWebKit/537.36 (Khtml, like Gecko) Chrome/90.0.4430.212 Safari/537.36
Upgrade: websocket
Origin: file://
Sec-WebSocket-Version: 13
Accept-Encoding: gzip, deflate, br
Accept-Language: zh-CN,zh;q=0.9
Sec-WebSocket-Key: RLnvly29Zl3sJQOfGFjO9w==
Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits
content-length: 0

websocket建立时是以http协议握手,当建立连接之后就不需要http之间双向通信。协议深层次的东西以我目前的能力是无法理解的,将来有机会我会再回过头来分析底层协议。那么接下来就进入我们的主题。

引入maven依赖(结合项目实际情况而定):

<dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-all</artifactId>
            <version>5.0.0.Alpha2</version>
</dependency>

我们的需求自己既是服务端向其他模块推送消息,又是客户端从别处获取消息后推送其他模块。那么我们要在自己项目中集成netty客户端和服务端,因为客户端无法给多个连接推送消息。这里我主要介绍
SimpleChannelInboundHandler类的三个方法:

1. channelActive

private static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
@Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
         System.out.println("客户端加入连接:"+ctx.channel());
      //UserChannelUtil封装了channelGroup
        UserChannelUtil.getChannelGroup().add(ctx.channel());
    }

这个方法会在有客户端连接上来时执行,具体作用很多,通常是获取客户端的通道号加入到ChannelGroup中,例如注意这个GlobalEventExecutor.INSTANCE是单例,那么就意味着我们操作的是同一个对象,我们将连接的通道加入后将来就可以实现批量推送。

2.channelInactive

 @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        //断开连接
        System.out.println("客户端断开连接:"+ctx.channel());
        UserChannelUtil.getChannelGroup().remove(ctx.channel());
    }

它表示在客户端离开时会触发该事件,在这个方法内我们可以做一些收尾工作——把通道号去除,避免了通过列表的积累造成管理混乱。

3.channelRead

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println("收到客户端:"+ctx.channel()+"的消息:n"+msg.text())
    }

很显然它就是在收到消息后会执行该事件,客户端和服务端的方法都是相同的。

重点:netty主要是通过连接时产生的通道channel进行消息的推送,只要拿到这个channe就能对任意的客户端推送消息,我们分析以下场景:当客户端连接服务端时会产生一个channel,观察channelRead()方法里面一个参数是channel,另一个则是接收的消息 。现在我们的任务就是获取服务端channelRead()的channel,在客户端的channelRead()中调用服务端的channelRead()方法,再把刚刚获取的服务端channel传进去这样通道就以及打通了,我们只需要把客户端传来的消息试试传入就完成了我们的需求。

首先建立通道号保存的对象

@Data
public class ServerChannel{
  private static Channel serverChannel;
}

从服务端获取通道号

  @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
      ServerChannel.setServerChannel(ctx.channel());
        System.out.println("收到客户端:"+ctx.channel()+"的消息:n"+msg.text())
    }

在客户端调用服务端的方法

@Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println("收到服务端:"+ctx.channel()+"的消息:n"+msg.text())
      //通过反射创建服务端对象
      Class<WebSocketServerHandler> SocketHandler=WebSocketServerHandler.class;
       WebSocketServerHandler socketHandler=SocketHandler.newInstance();
						//获取服务端的通道号
        ChannelHandlerContext serverChannel=ServerCtx.getContext();
       if(serverChannel !=null){
                socketHandler.channelRead(serverCtx,msg);
            }
  • 结尾:说了一大堆做法就这么简单,分析问题的过程很漫长,理清思路就能高效解决问题。在这里给大家一个提示:netty握手协议内容的大小写敏感,很有可能会因为不同语言的websocket类库不同导致握手不成功,这时就需要重写netty的头部握手协议。如有不足之处请各位大佬们指正。


Tags:websocket   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
最近工作中需要开发前端操作远程虚拟机的功能,简称 WebShell。基于当前的技术栈为 react+django,调研了一会发现大部分的后端实现都是 django+channels 来实现 websocket 服务。...【详细内容】
2021-09-13  Tags: websocket  点击:(52)  评论:(0)  加入收藏
前言:作为一个刚踏入职场的实习生,我很幸运参加了某个政府项目,并且在项目中负责一个核心模块功能的开发,而不是从头到尾对数据库的crud。虽然我一直心里抱怨我的工作范围根本...【详细内容】
2021-05-24  Tags: websocket  点击:(230)  评论:(0)  加入收藏
1)通知功能:保持一个长连接,当服务端游新的消息,能够实时的推送到使用方。像知乎的点赞通知、评论等,都可以使用WebSocket通信。某些使用H5的客户端,为了简化开发,也会使用WebSocke...【详细内容】
2021-03-03  Tags: websocket  点击:(156)  评论:(0)  加入收藏
背景:一般与服务端交互频繁的需求,可以使用轮询机制来实现。然而一些业务场景,比如游戏大厅、直播、即时聊天等,这些需求都可以或者说更适合使用长连接来实现,一方面可以减少轮询...【详细内容】
2020-12-17  Tags: websocket  点击:(156)  评论:(0)  加入收藏
1. 前言Websocket是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。WebSocket 使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送...【详细内容】
2020-11-11  Tags: websocket  点击:(100)  评论:(0)  加入收藏
前段时间我有这样一个需求,想和一个异地的人一起看电影,先后在网上找了一些方案,不过那几个案都有一些缺点...【详细内容】
2020-10-21  Tags: websocket  点击:(92)  评论:(0)  加入收藏
1. 前言Websocket是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。WebSocket 使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数...【详细内容】
2020-09-18  Tags: websocket  点击:(97)  评论:(0)  加入收藏
前言服务器和客户端保持长连接通信,实现方式比较多。有很多成熟的框架可以完成,底层无非都是对Socket流的封装和使用。一、SOCKET原理Socket大致是指在端到端的一个连接中,这...【详细内容】
2020-08-06  Tags: websocket  点击:(75)  评论:(0)  加入收藏
1. 心跳重连原由 心跳和重连的目的用一句话概括就是客户端和服务端保证彼此还活着,避免丢包发生。websocket连接断开有以下两种情况:前端断开在使用websocket过程中,可能会出现...【详细内容】
2020-07-29  Tags: websocket  点击:(308)  评论:(0)  加入收藏
用这些简化了 WebSockets 的开源支持工具来控制你的流媒体。 来源:https://linux.cn/article-12347-1.html 作者:Kevin Sonney 译者:Xingyu.Wang(本文字数:4340,阅读时长大约:6 分...【详细内容】
2020-06-25  Tags: websocket  点击:(96)  评论:(0)  加入收藏
▌简易百科推荐
摘 要 (OF作品展示)OF之前介绍了用python实现数据可视化、数据分析及一些小项目,但基本都是后端的知识。想要做一个好看的可视化大屏,我们还要学一些前端的知识(vue),网上有很多比...【详细内容】
2021-12-27  项目与数据管理    Tags:Vue   点击:(1)  评论:(0)  加入收藏
程序是如何被执行的&emsp;&emsp;程序是如何被执行的?许多开发者可能也没法回答这个问题,大多数人更注重的是如何编写程序,却不会太注意编写好的程序是如何被运行,这并不是一个好...【详细内容】
2021-12-23  IT学习日记    Tags:程序   点击:(9)  评论:(0)  加入收藏
阅读收获✔️1. 了解单点登录实现原理✔️2. 掌握快速使用xxl-sso接入单点登录功能一、早期的多系统登录解决方案 单系统登录解决方案的核心是cookie,cookie携带会话id在浏览器...【详细内容】
2021-12-23  程序yuan    Tags:单点登录(   点击:(8)  评论:(0)  加入收藏
下载Eclipse RCP IDE如果你电脑上还没有安装Eclipse,那么请到这里下载对应版本的软件进行安装。具体的安装步骤就不在这赘述了。创建第一个标准Eclipse RCP应用(总共分为六步)1...【详细内容】
2021-12-22  阿福ChrisYuan    Tags:RCP应用   点击:(7)  评论:(0)  加入收藏
今天想简单聊一聊 Token 的 Value Capture,就是币的价值问题。首先说明啊,这个话题包含的内容非常之光,Token 的经济学设计也可以包含诸多问题,所以几乎不可能把这个问题说的清...【详细内容】
2021-12-21  唐少华TSH    Tags:Token   点击:(9)  评论:(0)  加入收藏
实现效果:假如有10条数据,分组展示,默认在当前页面展示4个,点击换一批,从第5个开始继续展示,到最后一组,再重新返回到第一组 data() { return { qList: [], //处理后...【详细内容】
2021-12-17  Mason程    Tags:VUE   点击:(14)  评论:(0)  加入收藏
什么是性能调优?(what) 为什么需要性能调优?(why) 什么时候需要性能调优?(when) 什么地方需要性能调优?(where) 什么时候来进行性能调优?(who) 怎么样进行性能调优?(How) 硬件配...【详细内容】
2021-12-16  软件测试小p    Tags:性能调优   点击:(19)  评论:(0)  加入收藏
Tasker 是一款适用于 Android 设备的高级自动化应用,它可以通过脚本让重复性的操作自动运行,提高效率。 不知道从哪里听说的抖音 app 会导致 OLED 屏幕烧屏。于是就现学现卖,自...【详细内容】
2021-12-15  ITBang    Tags:抖音防烧屏   点击:(23)  评论:(0)  加入收藏
11 月 23 日,Rust Moderation Team(审核团队)在 GitHub 上发布了辞职公告,即刻生效。根据公告,审核团队集体辞职是为了抗议 Rust 核心团队(Core team)在执行社区行为准则和标准上...【详细内容】
2021-12-15  InfoQ    Tags:Rust   点击:(24)  评论:(0)  加入收藏
一个项目的大部分API,测试用例在参数和参数值等信息会有很多相似的地方。我们可以复制API,复制用例来快速生成,然后做细微调整既可以满足我们的测试需求1.复制API:在菜单发布单...【详细内容】
2021-12-14  AutoMeter    Tags:AutoMeter   点击:(20)  评论:(0)  加入收藏
最新更新
栏目热门
栏目头条