From 1368168678914a88bf96dd3f4b7357c0b64e3dda Mon Sep 17 00:00:00 2001
From: Aaron3S <chenyang@fit2cloud.com>
Date: Thu, 4 Sep 2025 16:31:12 +0800
Subject: [PATCH] feat: change websocket buffer size

---
 .../chen/web/config/WebSocketConfig.java          | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/backend/web/src/main/java/org/jumpserver/chen/web/config/WebSocketConfig.java b/backend/web/src/main/java/org/jumpserver/chen/web/config/WebSocketConfig.java
index 273d5e6..4eba094 100644
--- a/backend/web/src/main/java/org/jumpserver/chen/web/config/WebSocketConfig.java
+++ b/backend/web/src/main/java/org/jumpserver/chen/web/config/WebSocketConfig.java
@@ -3,6 +3,7 @@
 import org.jumpserver.chen.framework.ws.ConsoleWebSocketHandler;
 import org.jumpserver.chen.framework.ws.DBConsoleWebsocketHandler;
 import org.jumpserver.chen.framework.ws.SessionWebSocketHandler;
+import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.http.server.ServerHttpRequest;
 import org.springframework.http.server.ServerHttpResponse;
@@ -11,6 +12,7 @@
 import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
 import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
 import org.springframework.web.socket.server.HandshakeInterceptor;
+import org.springframework.web.socket.server.standard.ServletServerContainerFactoryBean;
 
 import java.util.Map;
 import java.util.Objects;
@@ -18,6 +20,19 @@
 @Configuration
 @EnableWebSocket
 public class WebSocketConfig implements WebSocketConfigurer {
+
+
+    @Bean
+    public ServletServerContainerFactoryBean createWebSocketContainer() {
+        ServletServerContainerFactoryBean container = new ServletServerContainerFactoryBean();
+        container.setMaxTextMessageBufferSize(20 * 1024 * 1024);
+        container.setMaxBinaryMessageBufferSize(20 * 1024 * 1024);
+        // 可选：异步发送超时
+        // container.setAsyncSendTimeout(20_000L);
+        return container;
+    }
+
+
     @Override
     public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
         registry