记一次 websocket 实战,“我没有拿到回执呀”

简介: web 前端 A1 与后端 C1 建立 websocket,等后端 C2 推送给 C1 一个 callBack 消息后,C1 再将这个消息推回给 A1,最后 A1 拿到这个回执后渲染界面;

image.png

  • 首先祝:今晚 4x100 接力,中国队必胜!!!✊✊✊


认清需求



认清需求是第一步!实战中需求是这样的:


web 前端 A1 与后端 C1 建立 websocket,等后端 C2 推送给 C1 一个 callBack 消息后,C1 再将这个消息推回给 A1,最后 A1 拿到这个回执后渲染界面;

额外说明:这个回执是由内嵌在 A1 iframe 里的 web 前端 A2 的用户输入的。

脑图如下:


实战代码



弄清需求后,就开始刷刷刷写代码了✍(这里实现 web 前端 A1 的逻辑)

此处通过wss://echo.websocket.org 来模拟连接地址:


重点说明:

  1. 因为拿到 回执 callBack 后前端就主动断开了,所以断开分为:【正常断开】和【异常断开】;
  2. 异常断开要有重连机制,正常断开不用;
  3. 要有心跳发送机制;每隔 10 s 发送(send)一个 'ping' 到后端;
  4. send 失败也要重连;
  • websocket.js 实战代码(参数做了简化,可直接复制在控制台上调用测试


var limitConnect = 20 // 断线重连次数
var timeConnect = 0
const service = 'wss://echo.websocket.org'
// socket初始化
const webSocketInit = function() {
  var ws = new WebSocket(service)
  let ws_close_correctly = false
  ws.onopen = function() {
    console.log('已连接TCP服务器')
  }
  ws.onmessage = function(msg) {
    if (msg.data === 'callBack') { //
      ws.close()
      ws_close_correctly = true
      console.log("拿到回执,渲染界面")
    }
  }
  ws.onclose = function() {
    console.log(ws_close_correctly ? 'ws 正常断开' : 'ws 异常断开')
    reconnect(service)
  }
  // 重连
  function reconnect(service) {
    if (ws_close_correctly) return
    if (limitConnect > 0) {
      limitConnect--
      timeConnect++
      console.log('第' + timeConnect + '次重连')
      setTimeout(function() {
         webSocketInit()
      }, 2000)
    } else {
      console.log('TCP连接已超时')
    }
  }
  //  心跳 * 发送
  var timer = setInterval(function() {
    if (!isOpen(ws)) {
      console.log('ws 已断开,不用发 ping')
      clearInterval(timer)
      return false
    }
    if (ws.readyState === 3) {
      console.log('发送 send 失败,重连')
      clearInterval(timer)
      reconnect(service)
    }
    ws.send('ping')
  }, 1000 * 10)
  function isOpen(ws) { return ws.readyState === ws.OPEN }
}

调用:

webSocketInit()


有些疑问



功能确实是实现了,但是还有些疑问:


  • 心跳包是由前端发更好,还是后端发更好?或者说:由前端发,发了之后,后端再返回一个,类似:ping、pong、ping、pong......(必要性又有多少?)
  • 心跳包设置多久发一次比较合理?
  • 在本瓜这个实战场景中,消息还可能丢失!! 比如:在 A2 中用户输入传递给了 C2,然后 C2 把回执给了 C1,如果此时 websocket 是中断的,等待重连后,C1 是否还能把消息准确推给 A1?C1 和 C2 之间需要有一个机制来记录,A1 是否准确收到了回执!
  • 页面崩溃下的 websocket 断开如何处理?
  • “我没拿到回执呀”,websocket 因为网络环境断开的可能情况是什么?websocket 断开在不同浏览器下的表现是怎样的?......


哭了,基本需求是解决了,但是这些开放性的问题一个接着一个,等待去回答!!

在逐层理解的过程中,就会对 websocket 有新的认识~


要点整理



通过这次实战,也梳理了些概念点:

  1. WebSocket 与 HTTP 和 HTTPS 使用相同的 TCP 端口;
  2. RFC 6455 中规定:WebSocket 被设计为在 HTTP 80 和 443 端口上工作,并支持 HTTP 代理和中介,从而使其与 HTTP 协议兼容;
  3. socket 本质是对 TCP/IP 协议栈的封装,它提供了一个针对 TCP 或者 UDP 编程的接口,并不是另一种协议;
  4. WebSocket.readyState:0 (WebSocket.CONNECTING)正在链接中、1 (WebSocket.OPEN)已经链接并且可以通讯、2 (WebSocket.CLOSING)连接正在关闭、3 (WebSocket.CLOSED)连接已关闭或者没有链接成功;
  5. websocket 基本属性和方法-MDN; ......


还有很多点可以去探究,可以把代码拷在控制台上玩一玩儿~

看到这里,喜欢就点个赞吧~👍👍👍后续会有更多关于实战的分享!

实践是检验真理的唯一标准!


我是掘进安东尼,输出暴露输入,技术洞见生活,下次再会~


相关文章
|
2月前
|
前端开发 JavaScript Python
Python Web应用中的WebSocket实战:前后端分离时代的实时数据交换
在前后端分离的Web应用开发模式中,如何实现前后端之间的实时数据交换成为了一个重要议题。传统的轮询或长轮询方式在实时性、资源消耗和服务器压力方面存在明显不足,而WebSocket技术的出现则为这一问题提供了优雅的解决方案。本文将通过实战案例,详细介绍如何在Python Web应用中运用WebSocket技术,实现前后端之间的实时数据交换。
104 0
|
5月前
|
监控 前端开发 API
实战指南:使用Python Flask与WebSocket实现高效的前后端分离实时系统
【7月更文挑战第18天】构建实时Web应用,如聊天室,可借助Python的Flask和WebSocket。安装Flask及Flask-SocketIO库,创建Flask应用,处理WebSocket事件。前端模板通过Socket.IO库连接服务器,发送和接收消息。运行应用,实现实时通信。此示例展现了Flask结合WebSocket实现前后端实时交互的能力。
589 3
|
6月前
|
JavaScript 网络协议 前端开发
【Nodejs】WebSocket 全面解析+实战演练——(Nodejs实现简易聊天室)
【Nodejs】WebSocket 全面解析+实战演练——(Nodejs实现简易聊天室)
629 0
|
5月前
|
前端开发 JavaScript UED
Python Web应用中的WebSocket实战:前后端分离时代的实时数据交换
【7月更文挑战第16天】在前后端分离的Web开发中,WebSocket解决了实时数据交换的问题。使用Python的Flask和Flask-SocketIO库,后端创建WebSocket服务,监听并广播消息。前端HTML通过JavaScript连接到服务器,发送并显示接收到的消息。WebSocket适用于实时通知、在线游戏等场景,提升应用的实时性和用户体验。通过实战案例,展示了如何实现这一功能。
330 2
|
存储 数据安全/隐私保护
Netty实战(十三)WebSocket协议(一)
WebSocket 协议是完全重新设计的协议,旨在为 Web 上的双向数据传输问题提供一个切实可行的解决方案,使得客户端和服务器之间可以在任意时刻传输消息,因此,这也就要求它们异步地处理消息回执。
327 0
|
7月前
|
传感器 监控 网络协议
WebSocket 实战:构建高效的实时应用
WebSocket 实战:构建高效的实时应用
WebSocket 实战:构建高效的实时应用
|
7月前
|
前端开发 网络协议 Java
WebSocket理论和实战
WebSocket详解与实战操作
|
消息中间件 缓存 前端开发
Springboot 整合 WebSocket ,使用STOMP协议 ,前后端整合实战 (一)
Springboot 整合 WebSocket ,使用STOMP协议 ,前后端整合实战 (一)
2172 1
Springboot 整合 WebSocket ,使用STOMP协议 ,前后端整合实战 (一)
|
移动开发 前端开发 网络协议
WebSocket从入门到实战
WebSocket从入门到实战
280 0
|
数据安全/隐私保护
Netty实战(十四)WebSocket协议(二)
我们之前说过为了将 ChannelHandler 安装到 ChannelPipeline 中,需要扩展了ChannelInitializer,并实现 initChannel()方法
206 0