多个用户会话未收到订阅消息 - spring stomp websocket

Question

我正在使用 Spring stomp websocket 框架向客户端发送订阅消息。我们使用 ActiveMQ 作为消息代理 并且正在使用 stomp javascript 客户端。 Spring 4.1.5 和在这个架构中，消息是使用

发送的

simplemessagingTemplate.convertAndSendToUser(user, "/queue/msg", serverMsg, map);

为了确保只有正确的用户才能收到他们的消息，我还使用了实现 ChannelInterceptor 的 QueueSubscriptionInterceptor。 消息正确地传递到目的地。像这样使用JS客户端接收消息。

  stompClient.subscribe('/user/guest/queue/msg', function(greeting){              
                    x = JSON.parse(greeting.body);
                    ...
                    }

到目前为止一切顺利。但是，当有多个用户会话时，只有一个会话接收到消息。对于（例如），如果两个“访客”用户 已登录，我希望所有两个“访客”用户都能收到消息。这似乎没有发生。看着日志， 我看到消息似乎已发送..

2015-04-11 14:39:40 DEBUG StompBrokerRelayMessageHandler:738 - Forwarding SEND /queue/msg-user1 session=_system_ application/json;charset=UTF-8 payload={"my message to you...)
2015-04-11 14:39:40 DEBUG StompBrokerRelayMessageHandler:738 - Forwarding SEND /queue/msg-user0 session=_system_ application/json;charset=UTF-8 payload={"my message to you...)

我看到只有一个客户端接收到消息，而没有看到另一个。阅读 Spring 文档，我知道这是默认行为。 谁能告诉我我做错了什么。

谢谢。

Answer 1

您应该使用主题的语义而不是队列。

队列允许消息被消费一次，但主题允许每个订阅者消费一次。所以像 /topic/user/guest/msg 这样的东西可能会这样做。

Answer 2

在连接帧中设置确认头。这将做的是服务器将继续向您发送相同的消息，直到您发送回一个 ack 帧。我在下面通过在收到消息后立即调用 greeting.ack() 来执行此操作。将其设置为“client-individual”意味着服务器必须从特定客户端的所有会话中接收 ack，否则它将在每个 CONNECT 上继续重新发送相同的 msg。 希望这可以帮助！！ 使用下面的代码作为参考。

   function connect() {
    var socket = new SockJS('/powerme-notification-websocket');
    stompClient = Stomp.over(socket);
    stompClient.connect(
        {client_id:'testClient'}, function (frame) {
        setConnected(true);
        console.log('Connected: ' + frame);
        stompClient.subscribe('/user/topic/releaseLock', function (greeting) {
        stompClient.subscribe('/queue/releaseLock-testClient', function (greeting) {
            console.log(greeting);
            showGreeting(greeting.body);
            greeting.ack();
        },{durable:true,
            'auto-delete':false,
        ack:'client-individual',
        id:'testClient'});

    }); 
}

参考资料： https://stomp.github.io/stomp-specification-1.2.html#ACK