通过使用外部消息代理，Spring作为代理中继

Question

我想使用Spring消息为我的webapp的登录用户创建一个实时通知系统。

我定义了一个AbstractWebSocketMessageBrokerConfigrer如下：

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/notifications").withSockJS()
        .setSessionCookieNeeded(true)
        .setWebSocketEnabled(true);
}

@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
    registry.enableSimpleBroker("/topic/", "/queue/");
}

根据文件规定：

应用程序可以发送针对特定用户的消息。Spring的STOMP支持识别前缀为“/user/”的目的地。例如，客户机可能订阅目标“/用户/队列/位置更新”。此目的地将由UserDestinationMessageHandler处理，并转换为用户会话特有的目的地，例如“/queue/position-updates-user123”。这提供了订阅通用名称目的地的便利，同时确保与订阅同一目的地的其他用户不发生冲突，以便每个用户都可以接收唯一的股票头寸更新。

在发送端，消息可以发送到一个目的地，例如/user/{username}/队列/位置更新，这反过来将由UserDestinationMessageHandler翻译成一个或多个目的地，每个目的地对应于与用户关联的每个会话。这允许应用程序中的任何组件发送针对特定用户的消息，而不必知道他们的名称和通用目的地以外的任何信息。这也通过注释和消息模板得到支持。

通过将消息发送到/user/{username}/queue/something，它将只发送给由{username}标识的特定用户。

现在，我正在寻找一种解决方案，允许我使用外部消息代理（例如，RabbitMQ），将Spring用作代理中继：

registry.enableStompBrokerRelay("/topic/", "/queue/");

在Spring中配置外部Message Broker后：

• 是否可以使用as通道/user/{username/}/queue/something，在MessageBroker上发送消息？如果是，如何进行

Answer 1

是的，这是可能的，如果启用外部代理，每个@MessageMapping返回值都将被序列化为JSON并发送给代理，有关更多详细信息，请参阅参考文档的消息流部分。因此，这与简单的代理基本相同。

您还可以注入SimpMessageTemplate或SimpMessageSendingOperations bean，就像在我的OpenSnap示例应用程序中一样。您可以从控制器使用它，也可以从纯推送上下文中的任何其他类使用它。

您可以通过向您的@Message映射或@Subcribe映射处理程序方法添加主体参数来检索主体，就像这里所做的那样，当前主体将被自动注入。