Ogn*_*ute 5 java spring rabbitmq sockjs spring-websocket
我希望有人能帮助我解决这个问题。我正在将 Spring 的 Websocket 支持与 SockJs 和 StompJs 一起使用。我订阅了这样的队列:
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) {
});
Run Code Online (Sandbox Code Playgroud)
这对于 Spring 的 SimpMessageSendingOperations 非常有效。但是有一个大问题。队列名称如下所示:gotMessage-user3w4tstcj并且它没有声明为自动删除队列,但这正是我想要的。否则,我有 10k 个未使用的队列。在队列没有消费者的那一刻,应该删除队列。我怎么能假设呢?
有同样的问题,来自文档:
当使用 /exchange/amq.direct/position-updates 等目的地时,RabbitMQ 会创建自动删除队列。因此,在这种情况下,客户端可以订阅 /user/exchange/amq.direct/position-updates
请记住在 stomp 代理中继配置中添加 ' /exchange/' 作为目标前缀
| 归档时间: |
|
| 查看次数: |
1769 次 |
| 最近记录: |