spring@subscribeMapping真的会让客户端订阅某个主题吗？

Question

我正在使用spring Websocket与STOMP，简单的消息代理。在我的@controller中，我使用方法级的@subscribeMapping，它应该为客户端订阅一个主题，以便客户端在之后接收该主题的消息。假设客户端订阅主题“聊天”：

stompclient.subscribe（“/app/chat”,...）；

当客户端订阅了“/app/chat”而不是“/topic/chat”时，此订阅将转到使用@subscribemapping映射的方法：

@SubscribeMapping("/chat")
public List getChatInit() {
    return Chat.getUsers();
}

这是spring裁判。说道：

默认情况下，来自@SubscribeMapping方法的返回值作为消息直接发送回连接的客户端，而不通过代理。这对于实现请求-回复消息交互很有用；例如,在初始化应用程序UI时获取应用程序数据。

好吧，这是我想要的，但只是部分！！订阅后发送一些init数据。但是订阅呢？在我看来，这里发生的事情只是一个请求-回复，就像一个服务。订阅已被使用。如果是这样，请澄清我。

• 如果经纪人没有参与其中，客户是否订阅了某些where？
• 如果稍后我要向“聊天”订阅者发送一些消息，客户端会接收到吗？看来不是这样。
• 谁真正实现订阅？经纪人？还是别人？

如果这里的客户机没有被订阅到任何地方，我想知道为什么我们称之为“subscribe”；因为客户端只接收一条消息,而不接收将来的消息。

编辑：

为了确保订阅已经实现，我尝试了如下内容：

服务器端：

配置：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/hello").withSockJS();
    }
}

控制器：

@Controller
public class GreetingController {

    @MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public Greeting greeting(HelloMessage message) throws Exception {
        System.out.println("inside greeting");
        return new Greeting("Hello, " + message.getName() + "!");
    }

    @SubscribeMapping("/topic/greetings")
    public Greeting try1() {
        System.out.println("inside TRY 1");
        return new Greeting("Hello, " + "TRY 1" + "!");
    }
}

客户端：

...
    stompClient.subscribe('/topic/greetings', function(greeting){
                        console.log('RECEIVED !!!');
                    });
    stompClient.send("/app/hello", {}, JSON.stringify({ 'name': name }));
...

我希望发生的事情：

1. 当客户端订阅“/topic/greetings”时，将执行方法try1。
2. 当客户端将消息发送到“/app/hellow”时，它应接收到问候消息，该消息将为@sendto“/topic/greetings”。

结果：

>

如果客户端订阅/topic/greetings，则方法try1无法捕获它。

当客户端将消息发送到“/app/hello”时，greeting方法被执行，客户端收到了问候消息。所以我们知道它已经正确地订阅了'/topic/greetings'。

但请记住1。失败了。经过一些尝试，当客户端订阅'/app/topic/greetings'时，这是可能的，即前缀为/app（通过配置可以理解这一点）。

现在是1。正在工作，不过这次2。失败：当客户端向“/app/hello”发送消息时，是，执行了greeting方法，但客户端未接收到问候消息。（因为现在客户端可能订阅了前缀为“/app”的主题，这是不需要的。）

所以，我得到的是我想要的一个或两个，但不是这两个加在一起。

• 如何使用此结构（正确配置映射路径）实现此目标？

Answer 1

所以两者兼备：

• 使用主题处理订阅
• 在该主题上使用@subscribemapping传递连接响应

并不像你（和我）经历的那样起作用。

解决你的情况（就像我的情况一样）的方法是：

>

删除@subscribeMapping-它仅适用于/app前缀

订阅/topic，就像您想要的那样（带/o/app前缀）

实现ApplicationListener

>

如果您想直接回复单个客户端，请使用用户目的地（请参阅websocket-stomp-user-destination或者您也可以订阅子路径，例如/topic/my-id-42，然后您可以向该子主题发送消息（我不知道您的确切用例，我的用例是我有专用的订阅，如果我想进行广播，我会迭代它们）

收到StompCommand.Subscribe后，立即在ApplicationListener的onApplicationEvent方法中发送消息

订阅事件处理程序：

@Override
  public void onApplicationEvent(SessionSubscribeEvent event) {
      Message<byte[]> message = event.getMessage();
      StompHeaderAccessor accessor = StompHeaderAccessor.wrap(message);
      StompCommand command = accessor.getCommand();
      if (command.equals(StompCommand.SUBSCRIBE)) {
          String sessionId = accessor.getSessionId();
          String stompSubscriptionId = accessor.getSubscriptionId();
          String destination = accessor.getDestination();
          // Handle subscription event here
          // e.g. send welcome message to *destination*
       }
  }

Answer 2

默认情况下，来自@SubscribeMapping方法的返回值作为消息直接发送回连接的客户端，而不通过代理。

（重点是地雷）

这里，spring框架文档描述的是响应消息发生的事情，而不是传入的subscribe消息。

所以回答你的问题：

• 是，客户端已订阅主题
• 是的，如果您使用该主题发送消息，则订阅该主题的客户端将收到消息
• 消息代理负责管理订阅

使用SimpleMessageBroker，message broker实现位于应用程序实例中。订阅注册由DefaultSubscriptionRegistry管理。接收消息时，SimpleBrokerMessageHandler处理订阅消息和注册订阅（请参见此处的实现）。

对于RabbitMQ这样的“真正的”消息代理，您已经配置了一个Stomp broker中继，它将消息转发给代理。在这种情况下，subscribe消息被转发给负责管理订阅的代理（参见此处的实现）。

如果您查看有关STOMP消息流的参考文档，您将看到：

• 对“/topic/greeting”的订阅通过“ClientInboundChannel”并转发到代理
• 发送到“/app/greeting”的问候语通过“ClientInboundChannel”并转发到GreetingController。控制器添加当前时间，返回值通过“BrokerChannel”作为消息传递到“/topic/greeting”（目的地是根据约定选择的，但可以通过@sendto覆盖）。

因此在这里，/topic/hello是一个代理目标；在那里发送的消息直接转发给代理。而/app/hello是应用程序目标，并且应该生成要发送到/topic/hello的消息，除非@sendto另有规定。

现在您更新的问题是一个不同的问题，如果没有一个更精确的用例，很难说哪种模式是解决这个问题的最佳模式。这里有几个：

• 您希望客户端在异步情况下知道任何时候发生的事情：订阅特定主题/topic/hello
• 要广播消息：向特定主题发送消息/topic/hello
• 您希望立即获得某项内容的反馈，例如初始化应用程序的状态：订阅应用程序目标/app/hello，控制器立即响应消息
• 要将一个或多个消息发送到任何应用程序目标/app/hello:请使用@messagemapping、@sendto或消息传递模板的组合。

如果您想要一个好的例子，那么请查看这个聊天应用程序，该应用程序演示了spring websocket功能的日志，并使用了一个真实的用例。