带有STOMP、SOCKJS和ACTIVEMQ的Spring websocket

Question

我们正在将SpringWebSockets集成到我们的应用程序中，我运行了HelloWorld示例，令人惊讶的是，spring为我们连接了一切，以便将服务器端通知推送到客户端。

不过，我有一些简单的问题

1） 队列是如何创建的？我使用的是ActiveMQ，队列名称与我在目的地中指定的不同（例如，像greetings-user3n9\u jn3i）。

simpMessageSendingOperations.convertAndSend("/test/greeting", new Greeting("Hello Socket Listener!"));

2）目标名称是否不同于队列？

3） 我正在使用ActiveMQ控制台创建新的队列，例如/test1/问候语和发送，我正在客户端订阅它们，如图所示

var stompClient = null;

connect();

function connect() {
    var socket = new SockJS(stompUrl);
    stompClient = Stomp.over(socket);
    stompClient.connect({}, function(frame) {
        console.log('Connected: ' + frame);
        stompClient.subscribe('/user/queue/greetings', function(greeting){
            alert(greeting);
        });
    });
}

 function disconnect() {
        if (stompClient != null) {
            stompClient.disconnect();
        }
        setConnected(false);
        console.log("Disconnected");
    }

$("#lstnMsgsBtn").click(function() {
    $.ajax({
        url: testUrl,
        type: "POST",
        success: function(data) {

            var queueName = data.queueName;

            stompClient.subscribe(queueName, function(greeting){
                alert(greeting);
            });
        },
        error : function(jqXhr, textStatus, errorThrown) {
            alert(errorThrown);
        }
    });
});

我无法订阅queueName，我很确定我的想法是错误的，任何指针都将不胜感激。

Answer 1

>

我与RabbitMq合作过，他们在文档中解释了如何解析目标模式。我认为它在activemq中非常相似。通常是这样的

/exchange/routingkey

队列将为每个订户动态生成，并通过路由密钥绑定到exchange。但您也可以指定队列。您必须遵循exchange指定的语法。

我想上面也回答了这个问题。