UI-Project/src/utils/WebSocketService.js | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
UI-Project/src/utils/WebSocketService.js
@@ -18,10 +18,11 @@ if (!msg.data) { return; } messages += msg.data; const isLastChunk = msg.data.endsWith('<END>'); //是否为最后一块消息 if(isLastChunk) { messages += msg.data; if(isLastChunk||msg.data.length<50000) { messages= messages.replace('<END>', ''); const obj = JSON.parse(messages); hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java
@@ -122,6 +122,7 @@ if(this.session.isOpen()){ int maxChunkSize = 50000; // 定义最大的分块大小 int length = message.length(); if(length>50000){ int chunks = (int) Math.ceil((double) length / maxChunkSize); //分块发送消息 for (int i = 0; i < chunks; i++) { @@ -137,6 +138,10 @@ // 发送分块消息,并传递是否是最后一块消息的标识 this.session.getBasicRemote().sendText(chunk); } }else{ this.session.getBasicRemote().sendText(message); } } } catch (Exception e) { log.error("发送消息给客户端失败:{}", e.getMessage(), e);