sse实时通信

使用原因：用户网络环境较差，之前使用ws总是出现断连重连，导致数据总是不能实时更新，所以更换为sse

npm install event-source-polyfill

createWebSocket：创建sse连接 

getWebSocketMsg：接收sse消息

  import { EventSourcePolyfill } from "event-source-polyfill";
  import { getToken } from '@/utils/auth'
  class webSocketClass {
  constructor(name) {
     = `http`; //直连阿里云正式环境
     = null;
    (name);
     = 0;
  }
  createWebSocket(url) {
    var that =this
    // 建立连接
     = new EventSourcePolyfill(
      + url,
      {
        // 设置重连时间
        heartbeatTimeout: 60 * 60 * 1000,
        // 添加token
        headers: {
          Authorization: `Bearer ${getToken()}`,
        },
      }
    );
     = (e) => {
      ("已建立SSE连接~");
    };
     = (e) => {
      const d = ();
      ("sse已接受到消息:", d);
      ();

    };
     = (e) => {
      ("SSE连接错误" + );
      if ( == ) {
        ("SSE连接关闭");
      } else if ( == ) {
        ("SSE正在重连");
        //重新设置token
         = {
          Authorization: `Bearer ${getToken()}`,
        };
      } else {
        ("error", e);
      }
    };
  }
  getWebSocketMsg(callback) {
      ("开始接收sse消息~",);
       = (ev) => {
        callback && callback(ev);
    };
  }
  close(){
      ()
      ("SSE关闭" );
  }
}
export default webSocketClass;

使用方法：

   = new vueSSEUtil('/sse/warning/'+);
  ((evt) => {
      const d = ();
       = this.code_to_value();
      ('sse回调数据',d) 
   });
     

一定要在页面退出关闭sse

()