从Java客户机通过使用Spring4实现的WebSockets连接到Stomp

Question

我收到了一个Web应用程序，它使用Spring使用STOMP over WebSockets消息传递实现，类似于这里描述的内容（后端使用RabbitMQ）。它运行在Tomcat上，我可以使用常规URL（例如http://host/server/)连接到应用程序。我还得到了一个演示客户机--一个JSPX页面，它使用Modernizr WebSockets和SockJS。演示客户端中的连接代码如下所示：

if (Modernizr.websockets) {
    socket = new WebSocket('ws://host/server/endpointx');
}
else {
    socket = new SockJS('/server/endpointy');
}

stompClient = Stomp.over(socket);
stompClient.connect(headers, function(frame) { ... });
....

演示客户端工作正常（当我在浏览器中加载JSPX页面时，我可以连接到服务器）。但我的目标是使用一些Java STOMP库连接到同一个服务器。问题是，我尝试的库需要主机和端口作为连接参数：例如，使用ActiveMQ Stomp库：

StompConnection connection = new StompConnection();
connection.open("host", port);
connection.connect(new HashMap<String, String>());

所以我很困惑：我是不是用错了端口？或者处理一些库不兼容？或者我需要以某种方式向Tomcat表明我想将HTTP连接升级到WebSockets吗？

如果上面的问题很难回答，那么这个问题同样有用：我如何使用STOMP over WebSockets消息传递通道连接到Spring应用html" target="_blank">程序，这些消息传递通道运行在使用Java的Tomcat上？

Answer 1

我找到的时候应该贴出答案的。为了实现Java客户机，连接到Tomcat，而不是直接连接到RabbitMQ，Java客户机不仅应该实现WebSockets上的STOMP，还应该实现打开握手：

打开握手旨在与基于HTTP的服务器端软件和中介体兼容，以便与该服务器对话的HTTP客户端和与该服务器对话的WebSocket客户端都可以使用单个端口。为此，WebSocket客户端的握手是HTTP升级请求

我试图使用的库只是缺少这个功能。他们试图在没有握手的情况下直接执行WebSocket连接。

null

taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(N); // N = number of threads
taskScheduler.afterPropertiesSet();

stompClient = new WebSocketStompClient(new StandardWebSocketClient());
stompClient.setTaskScheduler(taskScheduler);
stompClient.setMessageConverter(new MappingJackson2MessageConverter()); 

WebSocketHttpHeaders handshakeHeaders = new WebSocketHttpHeaders(); // you can add additional headers here for Tomcat

// Here's the main piece other libraries were missing:
// The following request will perform both, handshake and connection
// hence it gets both sets of headers (for Tomcat and for Stomp)
ListenableFuture<StompSession> future = stompClient.connect(
            url,
            handshakeHeaders,
            new StompHeaders(),
            new CustomStompSessionHandlerAdapter(this)); // called from class that also was implementing CustomStompSessionHandlerAdapter, but this could be separate class as well.

另请参见Spring参考中的WebSocket支持一节