zhoushihao
2024-07-24 c1b6a6157b8cd13192f9a9f5a819150504d08701
UI-Project/src/utils/WebSocketService.js
@@ -1,7 +1,7 @@
// WebSocketService.js
let socket = null;
let messages = '';
export const initializeWebSocket = (socketUrl, messageHandler) => {
    if (typeof WebSocket === "undefined") {
      console.log("Your browser does not support WebSocket");
@@ -18,13 +18,24 @@
      if (!msg.data) {
        return;
      }
      const obj = JSON.parse(msg.data);
      messages += msg.data;
      const isLastChunk = msg.data.endsWith('<END>');
      //是否为最后一块消息
      if(isLastChunk) {
        messages= messages.replace('<END>', '');
        const obj = JSON.parse(messages);
  
      // 调用消息处理函数,将数据传递给 Vue 组件
      if (messageHandler) {
        messageHandler(obj);
      }
        messages='';
      }
    };
  
    return socket;