//去vuex，utils里調(diào)用getUserInfo方法
this.$store
.dispatch("utils/getUserInfo", { initSocket: true })
.then((res) => {
});

//因?yàn)槲冶旧淼臉I(yè)務(wù)是在有新消息收到后再調(diào)用列表查詢的接口，所以會(huì)引入框架的請(qǐng)求方法（無(wú)此需求的小伙伴不用理會(huì)）
import * as $http from '@/utils/request'
import { mapGetters } from 'vuex';
const utils = {
  namespaced: true,
  state: {     //聲明變量，跟單頁(yè)面data return聲明一個(gè)意思
    message: [],
    readSysMsgList: [],
    readSysMsgListLength: "",
    wsUrl: '',
    ws_heart: '', // ws心跳定時(shí)器
    lockReconnect: false, //是否真正建立連接
    timeoutnum: null //斷開(kāi) 重連倒計(jì)時(shí)
  },
  getters: {},
  mutations: {
    //vuex突變，拿到維護(hù)的數(shù)據(jù)后交給對(duì)應(yīng)的變量，供頁(yè)面使用（可查看資料vuex用法）
    unReadSysMsg(state, options) {
      state.readSysMsgList = options
    },
    unReadSysMsglenght(state, options) {
      state.readSysMsgListLength = options
    },
  },
  actions: {
    // 獲取連接信息（在登錄接口調(diào)用getUserInfo方法建立連接）
    //getUserInfo有一個(gè)dispatch 參數(shù)，此參數(shù)目的為了調(diào)用actions中其他方法
    getUserInfo({ state, commit, dispatch },) {
    //先判斷瀏覽器是否支持WebSocket
      if (typeof WebSocket === "undefined") {
        alert("您的瀏覽器不支持socket");
      } else {
      	//提前判斷 WebSocket是否已經(jīng)建立，避免重復(fù)連接問(wèn)題
        if (this.socket) {
          this.socket.close()
        }
        //WebSocket連接時(shí)我的地址需要拼接用戶的id所以再此進(jìn)行獲取，也就是在登錄時(shí)為啥把getUserInfo放在登錄成功的回調(diào)中，無(wú)此需要的小伙伴可省略
        let id = JSON.parse(localStorage.getItem('loginUserAllInfo')).user.id
        // 實(shí)例化socket （長(zhǎng)連接為ws地址格式）這一步就是建立連接(自行放入url即可)
        this.socket = new WebSocket(`ws://xxx.xxx.xxx/${id}`);
        //new WebSocket有很多內(nèi)置的方法，onopen 就是證明連接已經(jīng)成功，可以在此進(jìn)行心跳檢測(cè)
        this.socket.onopen = () => {
          console.log('websocket已連接');
          //調(diào)用reset方法，reset方法是跟getUserInfo同級(jí)，在vuex中需要用dispatch進(jìn)行調(diào)用（可參考actions里第二行注釋解釋，必須得有接收參數(shù)）。跟單頁(yè)面中的this.reset（）同理
          dispatch("reset")
          //本項(xiàng)目業(yè)務(wù)，建立連接后先進(jìn)行列表查詢
          $http.get("/task/sysMessage/getUnReadSysMsg").then((res) => {
            console.log(res.data)
            //列表查詢的結(jié)果拿commit存到vuex當(dāng)中，然后再給了state中的變量，到時(shí)候頁(yè)面就可以直接拿到了。比如先把unReadSysMsg存起來(lái)，給了readSysMsgList ，然后頁(yè)面獲取數(shù)據(jù)的時(shí)候就可以this.readSysMsgList 稍后會(huì)有頁(yè)面展示的代碼
            commit("unReadSysMsg", res.data);
            commit("unReadSysMsglenght", res.data.length);
          })
        };
        // 監(jiān)聽(tīng)socket消息（主要內(nèi)置方法，收到消息后會(huì)進(jìn)行監(jiān)聽(tīng)接收）
        this.socket.onmessage = (msg) => {
          // console.log('接收到新消息--------' + msg.data)
          //同樣調(diào)用reset進(jìn)行心跳檢測(cè)重置
          dispatch("reset")
          
          //本項(xiàng)目業(yè)務(wù)，主要心跳檢測(cè)，我會(huì)在start方法里每隔30秒主動(dòng)進(jìn)行ping推送，看連接是否還存在，如果接收到pong到pong就證明是因?yàn)槲抑鲃?dòng)推送消息拿到的監(jiān)聽(tīng)結(jié)果，就不需要處理。如果接收到非pong則證明是后端有新消息推送過(guò)來(lái)，重新進(jìn)行列表查詢，刷新數(shù)據(jù)
          if (msg.data == "pong") {
          } else {
          //直接返回?cái)?shù)據(jù)的可避免此操作，直接拿到msg，commit存儲(chǔ)好就可
            $http.get("/task/sysMessage/getUnReadSysMsg").then((res) => {
              commit("unReadSysMsg", res.data);
              commit("unReadSysMsglenght", res.data.length);
              console.log(res.data)
            })
          }
        };
        // 監(jiān)聽(tīng)socket錯(cuò)誤信息（websocket斷開(kāi)會(huì)進(jìn)入此方法，需要進(jìn)行重連）
        this.socket.onclose = function (e) {
          console.log('關(guān)閉了')
          //斷開(kāi)連接后調(diào)用reconnect進(jìn)行重新連接
          dispatch("reconnect")
        };
        // WebSocket發(fā)生錯(cuò)誤
        this.socket.onerror = function (e) {
         //斷開(kāi)連接后調(diào)用reconnect進(jìn)行重新連接
          dispatch("reconnect")
          console.log("WebSocket發(fā)生錯(cuò)誤");
        };
      }
    },
    //重新連接（斷開(kāi)跟錯(cuò)誤后都需要進(jìn)行重連操作）
    reconnect({ dispatch }) {
      var that = this;
      if (that.lockReconnect) {
        // 是否真正建立連接
        return;
      }
      that.lockReconnect = true;
      //沒(méi)連接上會(huì)一直重連，設(shè)置延遲避免請(qǐng)求過(guò)多
      that.timeoutnum && clearTimeout(that.timeoutnum);
      // 如果到了這里斷開(kāi)重連的倒計(jì)時(shí)還有值的話就清除掉
      that.timeoutnum = setTimeout(function () {
        console.log('重啟中')
        //然后新連接（dispatch照樣進(jìn)行方法getUserInfo的調(diào)用）
        dispatch('getUserInfo')
        that.lockReconnect = false;
      }, 60000);
    },
    //建立連接及有新消息接收后進(jìn)行心跳重置
    reset({ dispatch }) {
      //重置心跳
      var that = this;
      //清除時(shí)間（清除心跳計(jì)時(shí)）
      clearInterval(that.ws_heart)
      //重啟心跳
      dispatch("start")
    },
    //心跳檢測(cè)
    start({ dispatch }) {
    //實(shí)時(shí)推送ping消息，查看連接是否斷開(kāi)
      this.ws_heart = setInterval(() => {
        let actions = "ping"
        this.socket.send(JSON.stringify(actions));
      }, 30000)
    },
  }
}
export default utils

 mounted() {
 //退出登錄后會(huì)把localStorage清空，避免控制臺(tái)報(bào)錯(cuò)
    if (JSON.parse(localStorage.getItem('loginUserAllInfo'))) {
      let userId = JSON.parse(localStorage.getItem('loginUserAllInfo')).user.id
      if (userId) {
        this.$store
          .dispatch("utils/getUserInfo", { initSocket: true })
          .then(() => {
          });
      }
    } else {
    }
  },

//頁(yè)面可直接使用數(shù)據(jù)，放到想用到的地方
	<template>
	<div>
	{{this.readSysMsgList}}
	</div>
	</template>
//引入vuex
import { mapActions, mapState } from 'vuex'  
export default {
 computed: {
    //獲取vuex中存放的數(shù)據(jù)
    ...mapState("utils", ["readSysMsgList","readSysMsgListLength"]),
  },
} 

//貼入本項(xiàng)目的業(yè)務(wù)代碼（主要看我el-table遍歷data   :data="this.readSysMsgList"直接就可渲染）
<template>
  <div class="navbar">
 <el-dialog :modal="false" title="您的消息" :visible.sync="moreFlag" class="tableLocation">
      <el-table :data="this.readSysMsgList" height="200"  @row-click="rowClick">
        <el-table-column align="center" width="40">
          <template slot-scope="scope">
            <i v-if="scope.row.messageType == '1'" class="el-icon-warning" style="color:#d0183d"></i>
            <i v-else class="el-icon-warning" style="color:#45d720"></i>
          </template>
        </el-table-column>
        <el-table-column property="messageType" label="消息類(lèi)型" width="70">
          <template slot-scope="scope">
            <div v-if="scope.row.messageType == '1'">新任務(wù)</div>
            <div v-else-if="scope.row.orderStatus == '2'">待跟進(jìn)</div>
            <div v-else-if="scope.row.orderStatus == '3'">待執(zhí)行</div>
          </template>
        </el-table-column>
        <el-table-column property="content" label="消息內(nèi)容"></el-table-column>
      </el-table>
    </el-dialog>
  </div>
</template>