外部代理

简单代理非常适合入门，但仅支持STOMP命令的子集（不支持确认、接收和其他一些功能），依赖于简单的消息发送循环，不适合集群。作为替代方案，您可以升级您的应用程序以使用功能齐全的消息代理。

查看您选择的消息代理的STOMP文档（例如RabbitMQ，ActiveMQ等），安装代理，并启用STOMP支持运行。然后您可以在Spring配置中启用STOMP代理中继（而不是简单代理）。

以下示例配置启用了功能齐全的代理：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig 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");
	}

}

以下示例显示了前面示例的XML配置等效项：

<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会话将从代理接收的所有消息转发给客户端。实质上，它充当了一个在两个方向上转发消息的“中继”。

为了TCP连接管理，请向您的项目添加io.projectreactor.netty:reactor-netty和io.netty:netty-all依赖项。

此外，应用程序组件（如HTTP请求处理方法、业务服务等）也可以向代理中继发送消息，如发送消息中所述，以向订阅的WebSocket客户端广播消息。

实际上，代理中继实现了强大且可扩展的消息广播。