vue websocket组件封装

简介: vue websocket组件封装

目录结构如下



封装代码


import { Message } from 'element-ui'
let websock = null
// let messageCallback = null
// const errorCallback = null
var tryTime = 0
let wsUrl = ''
// 接收ws后端返回的数据
function websocketonmessage(e, successCallback) {
  successCallback(JSON.parse(e.data))
  // console.log(JSON.parse(e.data))
  // messageCallback(e.data)
}
/**
 * 发起websocket连接
 * @param {Object} agentData 需要向后台传递的参数数据
 */
function websocketSend(agentData) {
  // 加延迟是为了尽量让ws连接状态变为OPEN
  setTimeout(() => {
    // 添加状态判断,当为OPEN时,发送消息
    if (websock.readyState === websock.OPEN) { // websock.OPEN = 1
      // 发给后端的数据需要字符串化
      websock.send(JSON.stringify(agentData))
    }
    // if (websock.readyState === websock.CLOSED) { // websock.CLOSED = 3
    //   console.log('websock.readyState=3')
    //   Message.error('ws连接异常,请稍候重试')
    // }
  }, 3000)
}
// 关闭ws连接
function websocketclose(e) {
  // e.code === 1000  表示正常关闭。 无论为何目的而创建, 该链接都已成功完成任务。
  // e.code !== 1000  表示非正常关闭。
  if (e && e.code !== 1000) {
    if (tryTime < 50) {
      setTimeout(function() {
        websock = null
        tryTime++
        initWebSocket()
        console.log(`第${tryTime}次重连`)
      }, 3 * 1000)
    } else {
      Message.error('重连失败!请稍后重试')
    }
    // Message.error('ws连接异常,请稍候重试')
    // errorCallback()
  }
}
// 建立ws连接
function websocketOpen(e) {
  console.log('ws连接成功')
}
// 初始化weosocket
function initWebSocket(successCallback) {
  if (typeof (WebSocket) === 'undefined') {
    Message.error('您的浏览器不支持WebSocket,无法获取数据')
    return false
  }
  // ws请求完整地址
  const requstWsUrl = wsUrl
  websock = new WebSocket(requstWsUrl)
  websock.onmessage = function(e) {
    websocketonmessage(e, successCallback)
  }
  websock.onopen = function() {
    websocketOpen()
  }
  websock.onerror = function() {
    // Message.error('ws连接异常,请稍候重试')
    // errorCallback()
  }
  websock.onclose = function(e) {
    websocketclose(e)
  }
}
/**
 * 发起websocket请求函数
 * @param {string} url ws连接地址
 * @param {Object} agentData 传给后台的参数
 * @param {function} successCallback 接收到ws数据,对数据进行处理的回调函数
 * @param {function} errCallback ws连接错误的回调函数
 */
export function sendWebsocket(url, agentData, successCallback) {
  wsUrl = url + agentData.group_id + '/'
  initWebSocket(successCallback)
  console.log(wsUrl, 'wsurl')
  // messageCallback = successCallback
  websocketSend()
}
/**
 * 关闭websocket函数
 */
export function closeWebsocket() {
  if (websock) {
    websock.close() // 关闭websocket
    websock.onclose() // 关闭websocket
  }
}

注释的地方可以来看ws 的状态 , 在这里加入了重连次数


引用


// ws连接成功,后台返回的ws数据,组件要拿数据渲染页面等操作
    wsMessage(data) {
      const dataJson = data
     // 在这里可以写逻辑
    },
    requstWs() {
      // 防止用户多次连续点击发起请求,所以要先关闭上次的ws请求。
      closeWebsocket()
      this.percentage = 1
      this.timeNumber = 0
      // 传递给后端的数据 这里的obj 我是作为参数进行传递的 , 如果你需要与服务端对话的话obj 也可以作为消息模板进行传递
      // 但是在websocket.js 里需要修改下 websocketSend 这个函数 
      const obj = {
        group_id: this.taskRecord
      }
      // 发起ws请求
      sendWebsocket('wss://192.168.0.21/ws/task_new_infos/', obj, this.wsMessage)
    },

ok 就这么多 附赠两断代码

  1. 将 “1天4时30分60秒” 转换为 秒
const dateA = this.duration.replace('天', ',') // 更改日期格式
        const dateB = dateA.replace('时', ',') // 更改日期格式时
        const dateC = dateB.replace('分', ',') // 更改日期格式时
        const dateD = dateC.replace('秒', '') // 更改日期格式时
        // console.log(dateD)
        const fullTimer = dateD.split(',') // 数组的转换
        this.timeNumber = 0
        this.timeNumber = parseInt(fullTimer[0] * 24 * 60 * 60) + parseInt(fullTimer[1] * 60 * 60) + parseInt(fullTimer[2] * 60) + parseInt(fullTimer[3])
  1. 将秒数转换为 “00 :33:22:11”
const one_day = 60 * 60 * 24
      const one_hour = 60 * 60
      const one_minute = 60
      var days = Math.abs(parseInt(this.timeNumber / one_day)) < 10 ? '0' + parseInt(this.timeNumber / one_day) : parseInt(this.timeNumber / one_day)
      var hours = Math.abs(parseInt((this.timeNumber % one_day) / one_hour)) < 10 ? '0' + parseInt((this.timeNumber % one_day) / one_hour) : parseInt((this.timeNumber % one_day) / one_hour)
      var minutes = Math.abs(parseInt((this.timeNumber % one_day % one_hour) / one_minute)) < 10 ? '0' + parseInt((this.timeNumber % one_day % one_hour) / one_minute) : parseInt((this.timeNumber % one_day % one_hour) / one_minute)
      var seconds = Math.abs(this.timeNumber % one_day % one_hour % one_minute) < 10 ? '0' + this.timeNumber % one_day % one_hour % one_minute : this.timeNumber % one_day % one_hour % one_minute
      return days + ':' + hours + ':' + minutes + ':' + seconds
相关文章
|
24天前
|
JavaScript
在 Vue 中处理组件选项与 Mixin 选项冲突的详细解决方案
【10月更文挑战第18天】通过以上的分析和探讨,相信你对在 Vue 中使用 Mixin 时遇到组件选项与 Mixin 选项冲突的解决方法有了更深入的理解。在实际开发中,要根据具体情况灵活选择合适的解决方案,以确保代码的质量和可维护性。
80 7
|
6天前
|
存储 JavaScript 开发者
Vue 组件间通信的最佳实践
本文总结了 Vue.js 中组件间通信的多种方法,包括 props、事件、Vuex 状态管理等,帮助开发者选择最适合项目需求的通信方式,提高开发效率和代码可维护性。
|
6天前
|
存储 JavaScript
Vue 组件间如何通信
Vue组件间通信是指在Vue应用中,不同组件之间传递数据和事件的方法。常用的方式有:props、自定义事件、$emit、$attrs、$refs、provide/inject、Vuex等。掌握这些方法可以实现父子组件、兄弟组件及跨级组件间的高效通信。
|
23天前
|
缓存 JavaScript UED
Vue 的动态组件与 keep-alive
【10月更文挑战第19天】总的来说,动态组件和 `keep-alive` 是 Vue.js 中非常实用的特性,它们为我们提供了更灵活和高效的组件管理方式,使我们能够更好地构建复杂的应用界面。深入理解和掌握它们,以便在实际开发中能够充分发挥它们的优势,提升我们的开发效率和应用性能。
43 18
|
18天前
|
缓存 JavaScript UED
Vue 中实现组件的懒加载
【10月更文挑战第23天】组件的懒加载是 Vue 应用中提高性能的重要手段之一。通过合理运用动态导入、路由配置等方式,可以实现组件的按需加载,减少资源浪费,提高应用的响应速度和用户体验。在实际应用中,需要根据具体情况选择合适的懒加载方式,并结合性能优化的其他措施,以打造更高效、更优质的 Vue 应用。
|
22天前
|
前端开发 UED
vue3知识点:Suspense组件
vue3知识点:Suspense组件
29 4
|
21天前
|
JavaScript 前端开发 测试技术
组件化开发:创建可重用的Vue组件
【10月更文挑战第21天】组件化开发:创建可重用的Vue组件
24 1
|
22天前
|
JavaScript 前端开发 Java
《vue3第五章》新的组件,包含:Fragment、Teleport、Suspense
《vue3第五章》新的组件,包含:Fragment、Teleport、Suspense
32 2
|
22天前
|
Java
vue3知识点:Teleport组件
vue3知识点:Teleport组件
25 1
|
25天前
|
存储 JavaScript
Vue 组件间通信的方式有哪些?
Vue组件间通信主要通过Props、Events、Provide/Inject、Vuex(状态管理)、Ref、Event Bus等实现,支持父子组件及跨级组件间的高效数据传递与状态共享。