使用STOMP订阅主题Spring WebSocket时未创建动态队列？

Question

我正在开发消息推送给订阅特定事件的所有用户子集。用户订阅RabbitMQ中的主题，格式为：user-id.event-type.id.我使用Spring WebSockJS、Stomp、RabbitMQ以及前端SockJS和Angular JS。用户应该被通知关于事件的所有行动（评论等，日期更改）。

到目前为止，我们拥有的：

首先，我通过REST webservice终结点进行身份验证，并将令牌放入Cookie。然后我们连接到webSocket。用户订阅话题（/话题/user-45.meeting.1235）并且他们得到通知。但是我的问题是一些用户没有收到通知。对于第二个用户，由于某些原因没有在RabbitMQ中创建队列。有人知道为什么吗？

这是我在Spring applicationContext中的代理设置。xml:

<websocket:message-broker application-destination-prefix="/app">
        <websocket:stomp-endpoint path="/stomp">
            <websocket:sockjs/>
        </websocket:stomp-endpoint>
        <websocket:stomp-broker-relay relay-host="localhost" relay-port="61613" system-login="guest" system-passcode="guest" prefix="/queue, /topic"/>
    </websocket:message-broker>

这就是通过Sockjs订阅的方式：

var ws = new SockJS('http://' + location.host + path);
var stompClient = Stomp.over(ws);
stompClient.connect({
    username: '',
    password: '',
    host: '/'
}, function () {
    stompClient.subscribe('/topic/user-45.meeting.' + obj.id,
        function (message) {
            console.log(message);
        }, {
            persistent: true
        });
});

若我们在SUBSCRIBE框架中指定unique Id字段，它将为每个用户创建唯一的队列。这条路走吗？

Answer 1

据我所知，您需要订阅\队列而不是\主题。通过这样做，您不需要为不同的用户自定义主题名称，这将由Sockjs根据登录用户进行处理。在服务器端，您还可以通过使用\队列\user\{用户名}\{队列名称}向特定用户发送消息。