镜屏多订阅问题

ebc-middle-platform/src/ipu-stomp.js

@@ -4,32 +4,64 @@ import {socketUrl} from '@/constants'
import EventBus from './bus'
var socket = null
var stompClient = null
var peronStompClient = null
var shipStompClient = null
export default function initWebSocket(params) {
  personStomp(params)
  shipStomp(params)
}
function personStomp(params) {
  if (socketUrl.startsWith('http') || socketUrl.startsWith('https')) {
    socket = new SockJS(socketUrl)// 连接服务端
    stompClient = Stomp.over(socket)
    peronStompClient = Stomp.over(socket)
  } else { // SockJS支持ws前缀
    stompClient = Stomp.client(socketUrl)
    peronStompClient = Stomp.client(socketUrl)
  }
  stompClient.connect(params, (frame) => {
  params.uuid = uuid()
  peronStompClient.connect(params, (frame) => {
    successCallback()
  }, () => {
    initWebSocket(params)
    personStomp(params)
  })
  return stompClient
}
function successCallback() {
  stompClient.subscribe('ship', msg => {
    // EventBus.$emit('ship', msg)
function shipStomp(params) {
  if (socketUrl.startsWith('http') || socketUrl.startsWith('https')) {
    socket = new SockJS(socketUrl)// 连接服务端
    shipStompClient = Stomp.over(socket)
  } else { // SockJS支持ws前缀
    shipStompClient = Stomp.client(socketUrl)
  }
  params.uuid = uuid()
  shipStompClient.connect(params, (frame) => {
    successShipCallback()
  }, () => {
    shipStomp(params)
  })
  stompClient.subscribe('personnel', msg => { // 订阅多个topic暂时实现
    if (msg.headers.destination === 'personnel') {
      EventBus.$emit('person', msg.body)
    } else if (msg.headers.destination === 'ship') {
      EventBus.$emit('ship', msg.body)
    }
}
function successShipCallback() {
  shipStompClient.subscribe('ship', msg => {
    EventBus.$emit('ship', msg.body)
  })
}
function successCallback() {
  peronStompClient.subscribe('personnel', msg => {
    EventBus.$emit('person', msg.body)
  })
}
function uuid() {
  var s = []
  var hexDigits = '0123456789abcdef'
  for (var i = 0; i < 36; i++) {
    s[i] = hexDigits.substr(Math.floor(Math.random() * 0x10), 1)
  }
  s[14] = '4' // bits 12-15 of the time_hi_and_version field to 0010
  s[19] = hexDigits.substr((s[19] & 0x3) | 0x8, 1) // bits 6-7 of the clock_seq_hi_and_reserved to 01
  s[8] = s[13] = s[18] = s[23] = '-'
  var uuid = s.join('')
  return uuid
}

ebc-middle-platform/src/modules/layouts/BasicLayout.vue

@@ -67,7 +67,7 @@ export default {
  },
  mounted() {
    // 镜屏调用
    initWebSocket({name: 'zhangsan', passcode: '123456', uuid: this.uuid()})
    initWebSocket({name: 'zhangsan', passcode: '123456'})
    EventBus.$on('person', (msg) => { // 获取镜屏推送消息
      console.log(msg)
      var obj = JSON.parse(msg)
@@ -82,19 +82,6 @@ export default {
  methods: {
    closeAlarmModal() {
      this.modal = false
    },
    uuid() {
      var s = []
      var hexDigits = '0123456789abcdef'
      for (var i = 0; i < 36; i++) {
        s[i] = hexDigits.substr(Math.floor(Math.random() * 0x10), 1)
      }
      s[14] = '4' // bits 12-15 of the time_hi_and_version field to 0010
      s[19] = hexDigits.substr((s[19] & 0x3) | 0x8, 1) // bits 6-7 of the clock_seq_hi_and_reserved to 01
      s[8] = s[13] = s[18] = s[23] = '-'
      var uuid = s.join('')
      return uuid
    }
  }
}