vue使用websocket实现实时数据推送功能

 更新时间:2023年12月12日 10:30:29   作者:请叫我欧皇i  
这篇文章主要为大家详细介绍了vue如何使用websocket实现实时数据推送,发布订阅重连单点登录功能,感兴趣的小伙伴可以跟随小编一起学习一下

需求:使用websocket不借助插件实现发布,订阅,网络断开重连,单点登录后挤号的功能

1.单点登录(同一账号同一时间只有一个在线,禁止多用户登录)

实现:在用户登录之后获取到token令牌并且存入到本地,可以判断token令牌是否失效来让用户退出登录,websocket的操作是让用户登录后连接到websocket并且发送指令,这边发送的指令是后端给的,之后前端进行接受消息,如果消息是退出登录的直接让他清空本地并且跳转到登录页就行

1.登录获取token令牌并且存储到localStorage

2.在layout也就是页面主体框架拿到token并且去连接websocket

3.连接成功后直接发送指令,之后再去监听返给前端的消息之后实现退出操作

url = `${protocol}://websocket的地址,要后端给?token=${token}`;,

这个我举个例子,连接地址应该是这样的:ws://127.0.0.1:8080?token=362466325,

ws.send(`msg:${this.data.id}`);这个也是后端定的要把账户的id给他,这样去监听登录

重连,之后消息返回loginOut后做退出登录的操作,如果链接因为各种原因关闭了,直接去请求重连。

retryCount: 0,
maxRetryCount: 5,
retryInterval: 2000, // 重试间隔时间,单位:毫秒

注意!!websocket不能设置请求头携带token好像,试了很多次都不行,用ws插件也不行,只能拼接token给后端了

let ws;
let url = "";
export default { 
 mounted() {
    this.connectWebsocket();
  },
  methods: {
    connectWebsocket() {
      let protocol = "ws";
 
      if (typeof WebSocket === "undefined") {
        console.log("您的浏览器不支持WebSocket");
        return;
      } else {
        if (window.location.protocol == "https:") {
          protocol = "wss";
        }
        let token = localStorage.getItem("token");
        url = `${protocol}://websocket的地址,要后端给?token=${token}`;
        // 打开一个ws
        ws = new WebSocket(url);
        ws.onopen = () => {
          // 发送数据
          console.log("ws已连接!!");
          ws.send(`msg:${this.data.id}`);
          // this.$message.success("ws已连接!!");
        };
        // 发生错误时
        ws.onerror = (evt) => {
          console.log("ws错误:", evt);
        };
        // 关闭连接
        ws.onclose = (event) => {
          console.warn("WebSocket 已关闭");
          console.log("关闭代码:", event.code);
          console.log("关闭原因:", event.reason);
          // 处理连接断开事件
          this.handleWebSocketClose();
        };
        ws.onmessage = (evt) => {
          if (evt.data == "loginOut") {
            // 此时要做清空数据的操作
            this.$message.warning("您的帐号在另一地点登录,您已被迫下线!!");
            this.$router.replace("/");
            localStorage.clear();
            ws.close();
            ws.onclose = () => {
              console.log("ws断开连接成功");
            };
          }
          console.log(evt, "接收到的消息");
        };
        this.$bus.$emit("Websocket", ws);
      }
    },
    handleWebSocketClose() {
      if (this.retryCount < this.maxRetryCount) {
        console.log(`正在尝试第 ${this.retryCount + 1} 次重连...`);
        setTimeout(() => {
          this.connectWebsocket();
          this.retryCount++;
        }, this.retryInterval);
      } else {
        console.error("WebSocket 连接失败,已达到最大重试次数");
      }
    },
}
}

2.发布订阅

注意!!这边每次发布的时候都应该重新连一个新的消息,不然和之前的登录的消息搞混了就不好了,特别是在做操作的时候,比如el-table的编辑操作这些,每次关闭弹窗肯定要关闭websocket,如果和登录的消息搞混了,关闭弹窗就不能实时接收到单点登录传来的消息了

这个connectWebsocket和上面的不是一个,这个是需要实时推送页面的websocket连接,不会影响全局的单点登录的。

let websocket;
let url = "";
    export default {
connectWebsocket(data) {
      let protocol = "ws";
 
      if (typeof WebSocket === "undefined") {
        console.log("您的浏览器不支持WebSocket");
        return;
      } else {
        if (window.location.protocol == "https:") {
          protocol = "wss";
        }
        let token = localStorage.getItem("token");
        url = `${protocol}://后端的给的地址?token=${token}`;
        // 打开一个websocket
        websocket = new WebSocket(url);
        websocket.onopen = () => {
          // 发送数据
          // console.log("websocket已连接!!");
          websocket.send(data);
          this.$message.success("websocket已连接!!");
        };
        // 发生错误时
        websocket.onerror = (evt) => {
          console.log("websocket错误:", evt);
        };
        // 关闭连接
        websocket.onclose = (event) => {
          console.warn("WebSocket 已关闭");
          console.log("关闭代码:", event.code);
          console.log("关闭原因:", event.reason);
          // 处理连接断开事件
          this.handleWebSocketClose(data);
        };
      }
    },
    handleWebSocketClose(data) {
      if (this.retryCount < this.maxRetryCount) {
        console.log(`正在尝试第 ${this.retryCount + 1} 次重连...`);
        setTimeout(() => {
          this.connectWebsocket(data);
          this.retryCount++;
        }, this.retryInterval);
      } else {
        this.$message.error("WebSocket 连接失败!!");
        console.error("WebSocket 连接失败,已达到最大重试次数");
      }
    },
}

2.1模拟编辑操作需要发布消息

1.点击编辑后打开并且实时接收

    updData(row) {
      this.connectWebsocket(`data_imei:${row.id}`);
      websocket.onmessage = (evt) => {
    //如果收到的消息是msgUpd
    if(evt.data=='msgUpd'){
  let data = JSON.parse(evt.data);
    //把得到的数据进行json转换之后再给tableData进行展示就行
    let tableData.unshift(data)
    //也不能一直接受吧,那数据得多少啊,定义一下接收到多少条后截取
      if (tableData.length > 500) {
           tableData.splice(500);
          }
        }
    }
}

2.关闭弹窗后需要断开连接

  closeWebSocket() {
      if (websocket != null) {
        websocket.close();
        websocket.onclose = () => {
          console.log("websocket断开连接成功");
        };
      }
    },

3.在离开websocket推送页面后也关闭连接

  destroyed() {
    if (websocket != null) {
      websocket.close();
      websocket.onclose = () => {
        console.log("websocket断开连接成功");
      };
    }
  },

到此这篇关于vue使用websocket实现实时数据推送功能的文章就介绍到这了,更多相关vue websocket实时数据推送内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Vue中$emit调用父组件异步方法模拟.then实现方式

    Vue中$emit调用父组件异步方法模拟.then实现方式

    这篇文章主要介绍了Vue中$emit调用父组件异步方法模拟.then实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-09-09
  • Vue实现图书管理小案例

    Vue实现图书管理小案例

    这篇文章主要为大家详细介绍了Vue实现图书管理小案例,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-12-12
  • 浅谈Vue中render中的h箭头函数

    浅谈Vue中render中的h箭头函数

    今天小编就为大家分享一篇浅谈Vue中render中的h箭头函数,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2019-11-11
  • 基于element-ui对话框el-dialog初始化的校验问题解决

    基于element-ui对话框el-dialog初始化的校验问题解决

    这篇文章主要介绍了基于element-ui对话框el-dialog初始化的校验问题解决,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-09-09
  • Vue函数式组件的应用实例详解

    Vue函数式组件的应用实例详解

    这篇文章主要介绍了Vue函数式组件的应用实例详解,本文给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下
    2019-08-08
  • js数组的 entries() 获取迭代方法

    js数组的 entries() 获取迭代方法

    这篇文章主要介绍了js数组的 entries() 获取迭代方法,entries() 方法返回一个数组的迭代对象,该对象包含数组的键值对 (key/value)。下面来详细介绍该neural,需要的朋友可以参考一下
    2021-10-10
  • 从零搭建一个vite+vue3+ts规范基础项目(搭建过程问题小结)

    从零搭建一个vite+vue3+ts规范基础项目(搭建过程问题小结)

    这篇文章主要介绍了从零搭建一个vite+vue3+ts规范基础项目,本项目已vite开始,所以按照vite官方的命令开始,对vite+vue3+ts项目搭建过程感兴趣的朋友一起看看吧
    2022-05-05
  • element-ui表格列金额显示两位小数的方法

    element-ui表格列金额显示两位小数的方法

    这篇文章主要介绍了element-ui表格列金额显示两位小数的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-08-08
  • 在Vue2项目中使用Mock.js的详细教程

    在Vue2项目中使用Mock.js的详细教程

    Mock.js 是一个用于生成随机数据和拦截 Ajax 请求的 JavaScript 库,它非常适合在前端开发中模拟后端 API,尤其是在前后端分离的开发模式下,本文给大家介绍了如何在Vue2项目中使用Mock.js,需要的朋友可以参考下
    2024-10-10
  • vue实现分页的三种效果

    vue实现分页的三种效果

    这篇文章主要为大家详细介绍了vue实现分页的三种效果,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-06-06

最新评论