STOMP 代理中继维护一个与消息代理的“系统”TCP 连接。这个连接仅用于来自服务器端应用程序的消息,不用于接收消息。您可以为此连接配置STOMP凭据(即STOMP帧的login
和passcode
头部)。这在XML命名空间和Java配置中都以systemLogin
和systemPasscode
属性的形式暴露,默认值均为guest
。
STOMP代理中继还为每个连接的WebSocket客户端创建一个单独的TCP连接。你可以配置用于代表客户端创建的所有TCP连接的STOMP凭据。这在XML命名空间和Java配置中都以clientLogin
和clientPasscode
属性的形式暴露,默认值均为guest
。
STOMP代理中继始终在代表客户转发给代理的每个 CONNECT 帧上设置
login
和passcode
标头。因此,WebSocket 客户端不需要设置这些标头。它们将被忽略。正如身份验证部分所述,WebSocket 客户端应改为依赖 HTTP 身份验证来保护 WebSocket 端点并建立客户端身份。
STOMP代理中继还在“系统”TCP连接上向消息代理发送和接收心跳。你可以配置发送和接收心跳的时间间隔(默认为10秒)。如果与代理的连接丢失,代理中继会继续尝试重新连接,每5秒一次,直到成功。
任何Spring Bean都可以实现ApplicationListener<BrokerAvailabilityEvent>
来接收,当到消息代理的“系统”连接丢失和重新建立时的通知。例如,一个广播股票报价的股票报价服务可以在没有活跃的“系统”连接时停止尝试发送消息。
默认情况下,STOMP代理中继始终保持连接,并在连接丢失时根据需要重新连接到相同的主机和端口。如果你希望提供多个地址,则在每次尝试连接时,你可以配置一个地址提供者,而不是固定的主机和端口。以下示例展示了如何做到这一点:
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {*// ...*@Overridepublic void configureMessageBroker(MessageBrokerRegistry registry) {registry.enableStompBrokerRelay("/queue/", "/topic/").setTcpClient(createTcpClient());registry.setApplicationDestinationPrefixes("/app");}private ReactorNettyTcpClient<byte[]> createTcpClient() {return new ReactorNettyTcpClient<>(client -> client.addressSupplier(() -> ... ),new StompReactorNettyCodec());}
}
你还可以使用virtualHost
属性配置STOMP代理中继。该属性的值被设置为每个CONNECT
帧的host
标头,这可能会很有用(例如,在云环境中,建立TCP连接的实际主机与提供基于云的STOMP服务的主机不同)。