要配置底层 WebSocket 服务器,服务器配置中 的信息适用。然而,对于 Jetty,你需要通过 StompEndpointRegistry 设置 HandshakeHandler 和 WebSocketPolicy。
@Configuration@EnableWebSocketMessageBrokerpublic class WebSocketConfig implements WebSocketMessageBrokerConfigurer {@Overridepublic void registerStompEndpoints(StompEndpointRegistry registry) {registry.addEndpoint("/portfolio").setHandshakeHandler(handshakeHandler());}@Beanpublic DefaultHandshakeHandler handshakeHandler() {WebSocketPolicy policy = new WebSocketPolicy(WebSocketBehavior.SERVER);policy.setInputBufferSize(8192);policy.setIdleTimeout(600000);return new DefaultHandshakeHandler(new JettyRequestUpgradeStrategy(new WebSocketServerFactory(policy)));}}
