1、 更新打包方式 2、在websocket增加锁

zhoushihao

2025-12-02 0b6fd6aa3304f192b6cf80e5ce72e04c6d5df0a3

 hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java

@@ -85,7 +85,7 @@
     * 向当前用户的所有会话发送消息
     */
    public void sendToWeb(String webSocketName, String message) {
        List<WebSocketServer> sessions = sessionMap.get(webSocketName);
         List<WebSocketServer> sessions = sessionMap.get(webSocketName);
        if (sessions == null) return;
        sessions.forEach(ws -> {
            try {
@@ -104,7 +104,7 @@
    /**
     * 分块发送大消息
     */
    private void sendChunkedMessage(String message) {
    private synchronized void sendChunkedMessage(String message) {
        if (!session.isOpen()) return;
        try {
            if (message.length() <= MAX_MESSAGE_SIZE) {