kd-aiot-frontend/src/utils/common.js

import { io } from 'socket.io-client';
import { getToken, setToken } from './token-util';
const token = getToken();
export const init = () => {


//   let socket = new WebSocket(
//     'ws://192.168.1.251:18086/websocket/UnreadNotifyMessageCount'
//   );
//   // 连接时发送认证令牌
//   socket.onopen = () => {
//     socket.send(
//       JSON.stringify({
//         type: 'AUTH',
//         authorization: token
//       })
//     );
//   };
//   socket.onmessage = (event) => {
//     // this.messages.push(event.data)
//   };

//   // 连接关闭
//   socket.onclose = () => {
//     console.log('WebSocket 连接已关闭');
//   };

//   // 错误处理
//   socket.onerror = (error) => {
//     console.error('WebSocket 错误:', error);
//   };

//   console.log('初始化Socket.io连接', token);

  let socket = io('ws://192.168.1.251:18086/websocket/UnreadNotifyMessageCount',{
    extraHeaders: {
      Authorization: `Bearer ${token}`
    }
    //   auth:{
    //       authorization:token
    //   },
    //  transports: ['websocket']
    // transports: ['polling'],
    // extraHeaders: {
    //   'Authorization': token
    // }
  }); ///websocket/UnreadNotifyMessageCount
//   socket.disconnect().connect()
  
  console.log('初始化Socket.io连接',socket);

  socket.on('connect', () => {
      console.log('已成功连接到Socket.io服务器');
    });
  socket.on('disconnect', () => {
      console.log('与Socket.io服务器断开连接');
    });

    socket.emit('before-api-request', '11111')
};