【问题标题】:Websockets, SockJs, Stomp, Spring, RabbitMQ, delete User specific Queues automaticallyWebsockets、SockJs、Stomp、Spring、RabbitMQ,自动删除用户特定队列
【发布时间】:2014-09-21 00:45:59
【问题描述】:

我希望有人可以帮助我解决这个问题。我正在使用带有 SockJs 和 StompJs 的 Spring 的 Websocket 支持。我订阅了这样的队列:

    var socket = new SockJS(localhost + 'websocket');
    stompClient = Stomp.over(socket);
    stompClient.connect('', '', function(frame) {
        stompClient.subscribe("/user/queue/gotMessage", function(message) {
            gotMessage((JSON.parse(message.body)));
        });
    }, function(error) {
    });

这对 Spring 的 SimpMessageSendingOperations 非常有效。但是有一个大问题。队列名称如下所示: gotMessage-user3w4tstcj 并没有声明为自动删除队列,但这正是我想要的。否则,我有 10k 个未使用的队列。在队列没有消费者的那一刻,应该删除队列。我怎么能假设这个?

【问题讨论】:

  • 看起来像一些特定于库的问题,官方文档对清理临时队列有什么说法?
  • 我发现的唯一一件事是:“例如,RabbitMQ 创建自动删除队列,其目的地为 '/exchange/amq.direct/a'”,但没有用户特定的发送可能跨度>

标签: java spring rabbitmq sockjs spring-websocket


【解决方案1】:

有同样的问题,来自文档:

RabbitMQ 在目的地像 使用 /exchange/amq.direct/position-updates。所以在那种情况下 客户端可以订阅 /user/exchange/amq.direct/position-updates

记得在 stomp 代理中继配置中添加“/exchange/”作为目标前缀

【讨论】:

  • 谢谢……那行得通。我只是忘了将“/exchange/”添加到 stomp 代理中继配置中