Spring STOMP Websockets:有什么方法可以在服务器端启用 permessage-deflate?
Spring STOMP Websockets: any way to enable permessage-deflate on server side?
我在 spring-boot-starter 1.3.1.RELEASE 下使用 spring-websockets,使用 Jetty 后端。我想知道如何在服务器中启用 permessage-deflate。
我有一个托管在愿意协商压缩的 Firefox 版本上的客户端,即与 WebSocket 端点的初始握手包括压缩协商 header,例如:
GET https://my-websocket-host/my-endpoint
...
Sec-WebSocket-Protocol: v10.stomp,v11.stomp
Sec-WebSocket-Extensions: permessage-deflate
Sec-WebSocket-Key: ...
...
,但服务器响应在升级响应中不包含 permessage-deflate 扩展 header,这意味着它不愿意协商压缩。我一直在寻找可以在配置中启用此功能的寻宝游戏,但没有找到任何东西。是否有一些 API 我可以用来打开此功能,或者当前产品不支持它?
非常感谢,
史蒂夫
需要在 Jetty 本身中启用此功能,因为我认为默认情况下未注册此扩展。 Spring 提供了一种配置握手处理程序并启用该扩展的方法。
原理在the reference documentation on websocket server configuration中有解释,但这里有一个完整的例子:
@Configuration
@EnableWebSocket
public class SampleJettyWebSocketsApplication implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
// make sure to use the handshake handler we've defined
registry.addHandler(echoWebSocketHandler(), "/echo")
.setHandshakeHandler(handshakeHandler()).withSockJS();
}
@Bean
public DefaultHandshakeHandler handshakeHandler() {
WebSocketServerFactory factory = new WebSocketServerFactory();
// add the "permessage-compress" Websocket extension
factory.getExtensionFactory()
.register("permessage-compress", PerMessageDeflateExtension.class);
return new DefaultHandshakeHandler(new JettyRequestUpgradeStrategy(factory));
}
我在 spring-boot-starter 1.3.1.RELEASE 下使用 spring-websockets,使用 Jetty 后端。我想知道如何在服务器中启用 permessage-deflate。
我有一个托管在愿意协商压缩的 Firefox 版本上的客户端,即与 WebSocket 端点的初始握手包括压缩协商 header,例如:
GET https://my-websocket-host/my-endpoint
...
Sec-WebSocket-Protocol: v10.stomp,v11.stomp
Sec-WebSocket-Extensions: permessage-deflate
Sec-WebSocket-Key: ...
...
,但服务器响应在升级响应中不包含 permessage-deflate 扩展 header,这意味着它不愿意协商压缩。我一直在寻找可以在配置中启用此功能的寻宝游戏,但没有找到任何东西。是否有一些 API 我可以用来打开此功能,或者当前产品不支持它?
非常感谢,
史蒂夫
需要在 Jetty 本身中启用此功能,因为我认为默认情况下未注册此扩展。 Spring 提供了一种配置握手处理程序并启用该扩展的方法。
原理在the reference documentation on websocket server configuration中有解释,但这里有一个完整的例子:
@Configuration
@EnableWebSocket
public class SampleJettyWebSocketsApplication implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
// make sure to use the handshake handler we've defined
registry.addHandler(echoWebSocketHandler(), "/echo")
.setHandshakeHandler(handshakeHandler()).withSockJS();
}
@Bean
public DefaultHandshakeHandler handshakeHandler() {
WebSocketServerFactory factory = new WebSocketServerFactory();
// add the "permessage-compress" Websocket extension
factory.getExtensionFactory()
.register("permessage-compress", PerMessageDeflateExtension.class);
return new DefaultHandshakeHandler(new JettyRequestUpgradeStrategy(factory));
}