From 031da535a58f83913db6287b5f29f5983435cfa2 Mon Sep 17 00:00:00 2001 From: zhoushihao <zsh19950802@163.com> Date: 星期三, 24 七月 2024 15:46:41 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java | 29 +++++++++++++++++------------ 1 files changed, 17 insertions(+), 12 deletions(-) diff --git a/hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java b/hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java index fa81984..480921c 100644 --- a/hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java +++ b/hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java @@ -122,21 +122,26 @@ if(this.session.isOpen()){ int maxChunkSize = 50000; // 瀹氫箟鏈�澶х殑鍒嗗潡澶у皬 int length = message.length(); - int chunks = (int) Math.ceil((double) length / maxChunkSize); - //鍒嗗潡鍙戦�佹秷鎭� - for (int i = 0; i < chunks; i++) { - int startIndex = i * maxChunkSize; - int endIndex = Math.min(startIndex + maxChunkSize, length); - String chunk = message.substring(startIndex, endIndex); + if(length>50000){ + int chunks = (int) Math.ceil((double) length / maxChunkSize); + //鍒嗗潡鍙戦�佹秷鎭� + for (int i = 0; i < chunks; i++) { + int startIndex = i * maxChunkSize; + int endIndex = Math.min(startIndex + maxChunkSize, length); + String chunk = message.substring(startIndex, endIndex); - // 鍒ゆ柇鏄惁鏄渶鍚庝竴鍧楁秷鎭� - boolean isLastChunk = (i == chunks - 1); - if(isLastChunk==true){ - chunk+="<END>"; + // 鍒ゆ柇鏄惁鏄渶鍚庝竴鍧楁秷鎭� + boolean isLastChunk = (i == chunks - 1); + if(isLastChunk==true){ + chunk+="<END>"; + } + // 鍙戦�佸垎鍧楁秷鎭紝骞朵紶閫掓槸鍚︽槸鏈�鍚庝竴鍧楁秷鎭殑鏍囪瘑 + this.session.getBasicRemote().sendText(chunk); } - // 鍙戦�佸垎鍧楁秷鎭紝骞朵紶閫掓槸鍚︽槸鏈�鍚庝竴鍧楁秷鎭殑鏍囪瘑 - this.session.getBasicRemote().sendText(chunk); + }else{ + this.session.getBasicRemote().sendText(message); } + } } catch (Exception e) { log.error("鍙戦�佹秷鎭粰瀹㈡埛绔け璐ワ細{}", e.getMessage(), e); -- Gitblit v1.8.0