对于最新的稳定版本,请使用 Spring Framework 6.2.0spring-doc.cadn.net.cn

WebSocket 传输

本节介绍如何配置底层 WebSocket 服务器传输。spring-doc.cadn.net.cn

对于 Jakarta WebSocket 服务器,请添加ServletServerContainerFactoryBean发送到您的 配置。有关示例,请参阅 WebSocket 部分下的 配置 服务器spring-doc.cadn.net.cn

对于 Jetty WebSocket 服务器,自定义JettyRequestUpgradeStrategy如下:spring-doc.cadn.net.cn

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

	@Override
	public void registerStompEndpoints(StompEndpointRegistry registry) {
		registry.addEndpoint("/portfolio").setHandshakeHandler(handshakeHandler());
	}

	@Bean
	public DefaultHandshakeHandler handshakeHandler() {

		WebSocketPolicy policy = new WebSocketPolicy(WebSocketBehavior.SERVER);
		policy.setInputBufferSize(8192);
		policy.setIdleTimeout(600000);

		return new DefaultHandshakeHandler(
				new JettyRequestUpgradeStrategy(new WebSocketServerFactory(policy)));
	}
}

除了 WebSocket 服务器属性之外,还有 STOMP WebSocket 传输属性 进行自定义,如下所示:spring-doc.cadn.net.cn

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

	@Override
	public void configureWebSocketTransport(WebSocketTransportRegistration registry) {
		registry.setMessageSizeLimit(4 * 8192);
		registry.setTimeToFirstMessage(30000);
	}

}