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') };