外部代理
简单的代理非常适合入门,但仅支持 STOMP 命令的一个子集(它不支持确认、回执和其他一些功能),依赖于简单的消息发送循环,并且不适合集群。作为替代方案,您可以升级您的应用程序以使用功能齐全的消息代理。
请参阅您选择的消息代理的 STOMP 文档(例如 RabbitMQ、ActiveMQ 等),安装代理,并在启用 STOMP 支持的情况下运行它。然后,您可以在 Spring 配置中启用 STOMP 代理中继(而不是简单代理)。
以下示例配置启用了功能齐全的代理
-
Java
-
Kotlin
-
Xml
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfiguration implements WebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/portfolio").withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableStompBrokerRelay("/topic", "/queue");
registry.setApplicationDestinationPrefixes("/app");
}
}
@Configuration
@EnableWebSocketMessageBroker
class WebSocketConfiguration : WebSocketMessageBrokerConfigurer {
override fun registerStompEndpoints(registry: StompEndpointRegistry) {
registry.addEndpoint("/portfolio").withSockJS()
}
override fun configureMessageBroker(registry: MessageBrokerRegistry) {
registry.enableStompBrokerRelay("/topic", "/queue")
registry.setApplicationDestinationPrefixes("/app")
}
}
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:websocket="http://www.springframework.org/schema/websocket"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
https://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/websocket
https://www.springframework.org/schema/websocket/spring-websocket.xsd">
<websocket:message-broker application-destination-prefix="/app">
<websocket:stomp-endpoint path="/portfolio">
<websocket:sockjs />
</websocket:stomp-endpoint>
<websocket:stomp-broker-relay prefix="/topic,/queue" />
</websocket:message-broker>
</beans>
上述配置中的 STOMP 代理中继是一个 Spring MessageHandler
,它通过将消息转发到外部消息代理来处理消息。为此,它建立到代理的 TCP 连接,将所有消息转发到它,然后将从代理接收到的所有消息通过其 WebSocket 会话转发到客户端。本质上,它充当“中继”,在两个方向上转发消息。
将io.projectreactor.netty:reactor-netty 和io.netty:netty-all 依赖项添加到您的项目中以进行 TCP 连接管理。 |
此外,应用程序组件(例如 HTTP 请求处理方法、业务服务等)也可以将消息发送到代理中继,如发送消息中所述,以将消息广播到已订阅的 WebSocket 客户端。
实际上,代理中继实现了健壮且可扩展的消息广播。