Skip to content

Commit 1368168

Browse files
committed
feat: change websocket buffer size
1 parent 84a9494 commit 1368168

1 file changed

Lines changed: 15 additions & 0 deletions

File tree

backend/web/src/main/java/org/jumpserver/chen/web/config/WebSocketConfig.java

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import org.jumpserver.chen.framework.ws.ConsoleWebSocketHandler;
44
import org.jumpserver.chen.framework.ws.DBConsoleWebsocketHandler;
55
import org.jumpserver.chen.framework.ws.SessionWebSocketHandler;
6+
import org.springframework.context.annotation.Bean;
67
import org.springframework.context.annotation.Configuration;
78
import org.springframework.http.server.ServerHttpRequest;
89
import org.springframework.http.server.ServerHttpResponse;
@@ -11,13 +12,27 @@
1112
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
1213
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
1314
import org.springframework.web.socket.server.HandshakeInterceptor;
15+
import org.springframework.web.socket.server.standard.ServletServerContainerFactoryBean;
1416

1517
import java.util.Map;
1618
import java.util.Objects;
1719

1820
@Configuration
1921
@EnableWebSocket
2022
public class WebSocketConfig implements WebSocketConfigurer {
23+
24+
25+
@Bean
26+
public ServletServerContainerFactoryBean createWebSocketContainer() {
27+
ServletServerContainerFactoryBean container = new ServletServerContainerFactoryBean();
28+
container.setMaxTextMessageBufferSize(20 * 1024 * 1024);
29+
container.setMaxBinaryMessageBufferSize(20 * 1024 * 1024);
30+
// 可选:异步发送超时
31+
// container.setAsyncSendTimeout(20_000L);
32+
return container;
33+
}
34+
35+
2136
@Override
2237
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
2338
registry

0 commit comments

Comments
 (0)