×

抖音网红

前端websocket怎么用案例(websocket推送消息给前端)

douyinfenxiang douyinfenxiang 发表于2024-11-16 20:44:24 浏览19 评论0

抢沙发发表评论

前言

今天这篇文章我们聊一聊websocket,上篇文章说到的SSE只能单向传递数据,而websocket是全双工的,可以双向传递数据!当我们遇到需要互相实时通信的场景时就可以使用它,比如聊天等!

客户端使用

在页面上的使用还是非常简单的,和上一篇的SSE类似,代码如下:

图1

浏览器提供了原生接口WebSocket,使用它的实例然后绑定几个事件就可以使用了!

  • WebSocket的第一个参数是一个实现了websocket服务的后端接口地址,注意使用的协议是ws,第二个参数是它的子协议(这里没有使用);
  • onopen事件在连接服务成功时触发;
  • onmessage事件在收发信息时触发,后端传来的数据可以从事件对象的data属性中取到;
  • onclose事件在连接关闭时触发;
  • 如果想要向后端传递数据,可以调用send方法。

如果想在页面上获取websocket的状态,可以通过实例对象的readyState属性获取,状态如下:

  • 0表示正在连接;
  • 1表示连接成功,可以通信了;
  • 2表示正在关闭;
  • 3表示已经关闭或者连接失败。

如何搭建websocket服务器

websocket服务有别于传统的http服务,因为它的服务需要在http服务的基础进行升级,下面我们来一起搭建!

图2

图2中我们先搭建一个http服务,它是websocket服务的基础。

图3

图3中是浏览器连接websocket服务的请求头,其中两个请求比较关键——Connection:Upgrade和Upgrade:websocket,这两个请求头告诉服务端,我想要升级协议并且升级的协议是websocket。

这里就可以看出两个问题:

  1. 服务器必须拥有升级协议的能力,此处对服务器提出来要求;
  2. 这个机制只属于http1.1;

下面我们开始升级协议,当有服务升级的请求时会触发upgrade事件,

图4

如图4中,服务监听upgrade事件,在回调函数中处理升级逻辑。

图5

在图3中我们发现浏览器发来的请求头包含sec-websocket-key和sec-websocket-version,前者的主要作用有两点:

  1. 用于校验请求是否真的就是websocket请求,因为从以上代码中就可以看出普通的ajax在设置了各种请求头后也可以对这个服务发起请求,所以用这个key可以做一次简单的校验;
  2. 这个key会在每次连接之初由浏览器随机生成,可以用来标记请求与响应对应,比如如果连续发送两次连接,可能存在服务器把第一次请求的数据发送给第二次请求这样的情况,所以用这个key可以为每次连接做一个标记;

后者告诉服务器需要支持的websocket版本。

拿到这些信息后需要先在逻辑中做一些基础校验:

  • 必须是get请求;
  • 升级的协议必须是websocket;
  • 必须存在key,长度为24个字符;
  • 版本是8或者13。

如果不满足以上条件,会返回400,请求无效,如果验证通过,我们可以继续下面的处理!

图6

后面的处理逻辑都封装在completeUpgrade方法中

图7

如图7,首先是计算Sec-WebSocket-Accept响应头的值,将key和一个固定的字符串拼接在一起通过sha1计算出摘要并转化为base64得到此值。

当链接成功时响应状态码应该是101,表示协议转换。

图8

讲到这里我们已经成功把页面与websocket服务连接起来了,后面数据的收发可以通过socket操作!现在回过头看一下图2,它是一个http服务,它很容易接收到普通的ajax请求,但是这里它的角色只是为websocket服务的,所以我们不希望有人直接请求它,如果有人非要请求它,那我们就告诉客户端这是一个需要升级的服务!

图9

图10

响应状态码426,需要升级协议!

总结

上篇文章在分享SSE的时候很多同学提到了websocket,它们两在客户端的用法很相似,但是websocket服务的实现却麻烦很多!本篇文章主要分享了如何搭建这样的服务,但是在服务中如何具体收发数据没有讲到,这是因为数据协议比较难,由于篇幅限制就放在后面分享!

喜欢我的文章就关注我吧,有问题可以发表评论,我们一起学习,共同成长!