我正在将 Spring Websocket 与 STOMP(简单消息代理)一起使用。 在我的 @Controller 中，我使用方法级别的 @SubscribeMapping ，它应该为客户端订阅一个主题，以便客户端之后接收该主题的消息。假设客户订阅了主题“聊天”:

stompClient.subscribe('/app/chat', ...);

由于客户端订阅了 "/app/chat"，而不是 "/topic/chat"，此订阅将转到使用 @SubscribeMapping 映射的方法:

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

这是 Spring 引用。说:

By default the return value from an @SubscribeMapping method is sent as a message directly back to the connected client and does not pass through the broker. This is useful for implementing request-reply message interactions; for example, to fetch application data when the application UI is being initialized.

好的，这正是我想要的，但只是部分!!订阅后发送一些初始化数据，好吧。但是订阅呢？在我看来，这里发生的事情只是一个request-reply，就像一个服务。 订阅刚刚被消耗。如果是这种情况，请澄清一下。

• 如果代理不参与，客户是否订阅了某个地方？
• 如果稍后我想向“聊天”订阅者发送一些消息，客户端会收到吗？好像不是这样的。
• 谁真正意识到订阅？经纪人？还是其他人？

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

编辑:

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

服务器端:

配置:

@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 :

@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/hello”发送消息时，它应该会收到问候消息，即 @SendTo“/topic/greetings”。

结果:

1. 如果客户端订阅了 /topic/greetings ，则 try1 方法无法捕捉到它。

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

3. 但请记住 1. 失败了。经过一番尝试，当客户端订阅了 '/app/topic/greetings' ，即以 /app 为前缀(这个可以通过配置理解)时，已经可以了。

4. 现在 1. 正在工作，但是这次 2. 失败:当客户端发送 msg 到 '/app/hello' 时，是的，执行了 greeting 方法，但客户端没有收到问候消息。 (因为可能现在客户端订阅了前缀为“/app”的主题，这是不需要的。)

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

• 如何使用这种结构实现这一点(正确配置映射路径)？

最佳答案

By default the return value from an @SubscribeMapping method is sent as a message directly back to the connected client and does not pass through the broker.

(强调我的)

这里的 Spring Framework 文档描述的是 响应消息，而不是传入的 SUBSCRIBE 消息。

所以回答你的问题:

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

关于订阅管理的更多信息

使用 SimpleMessageBroker，消息代理实现存在于您的应用程序实例中。订阅注册由 DefaultSubscriptionRegistry 管理。 接收消息时，SimpleBrokerMessageHandler 处理 SUBSCRIPTION 消息并注册订阅 (see implementation here)。

对于像 RabbitMQ 这样的“真实”消息代理，您已经配置了一个将消息转发到代理的 Stomp 代理中继。在这种情况下，SUBSCRIBE 消息被转发到代理，负责管理订阅 (see implementation here)。

更新 - 更多关于 STOMP 消息流

如果你看看 the reference documentation on STOMP message flow ，你会看到:

• Subscriptions to "/topic/greeting" pass through the "clientInboundChannel" and are forwarded to the broker
• Greetings sent to "/app/greeting" pass through the "clientInboundChannel" and are forwarded to the GreetingController. The controller adds the current time, and the return value is passed through the "brokerChannel" as a message to "/topic/greeting" (destination is selected based on a convention but can be overridden via @SendTo).

所以这里，/topic/hello 是代理目的地；在那里发送的消息直接转发到代理。而 /app/hello 是应用程序目的地，并且应该产生要发送到 /topic/hello 的消息，除非 @SendTo另有说法。

现在您更新的问题在某种程度上是一个不同的问题，如果没有更精确的用例，很难说哪种模式最能解决这个问题。以下是一些:

• 您希望客户端在异步发生任何事情时都知道:订阅特定主题 /topic/hello
• 您要广播消息:向特定主题发送消息/topic/hello
• 您想立即获得反馈，例如初始化应用程序的状态:订阅应用程序目标 /app/hello， Controller 立即响应消息
• 您想向任何应用程序目标发送一条或多条消息/app/hello:使用 @MessageMapping、@SendTo 的组合或消息传递模板。

如果您想要一个好的示例，请查看 this chat application demonstrating a log of Spring websocket features with a real world use case .

关于spring - Spring @SubscribeMapping 是否真的为客户端订阅了某个主题？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29085791/