Spring Websockets/Stomp upgrade to secure websockets

Question

У меня есть 2 приложения Java, которые обмениваются данными с использованием весенних веб-узлов. Я использую ActiveMQ Version 5.12.3. Я запускаю приложения на TomEE Server. Это конфигурация я использую в tomee.xml для ActiveMQ:

<Resource id="MyAppMessageBus" type="ActiveMQResourceAdapter"> 
    BrokerXmlConfig = broker:(tcp://localhost:61616,ws://0.0.0.0:61614,stomp://0.0.0.0:61613) 
    ServerUrl  = tcp://localhost:61616 
</Resource> 

Это мой Java-код для подключения:

if (brokerUrl.startsWith("ws")) { 
     WebSocketClient transport = new StandardWebSocketClient(); 
     stompClient = new WebSocketStompClient(transport); 
    } 

    stompClient.setMessageConverter(new MappingJackson2MessageConverter()); 
    stompClient.setTaskScheduler(taskScheduler); 
    stompClient.setDefaultHeartbeat(heartbeat); 
    stompClient.connect(brokerUrl, handler); 

Я могу соединиться успешно используя следующий брокер URL: WS: // локальный : 61614

Что бы я хотел сделать, это соединение с помощью защищенных веб-узлов. Когда я изменить URL в tomee.xml использовать WSS: // и обновить brokerurl в моем коде, я получаю следующее исключение:

javax.websocket.DeploymentException: The HTTP request to initiate the WebSocket connection failed 
    at org.apache.tomcat.websocket.WsWebSocketContainer.connectToServer(WsWebSocketContainer.java:434) ~[tomcat7-websocket.jar:7.0.68] 
    at org.springframework.web.socket.client.standard.StandardWebSocketClient$1.call(StandardWebSocketClient.java:152) ~[spring-websocket-4.2.5.RELEASE.jar:4.2.5.RELEASE] 
    at org.springframework.web.socket.client.standard.StandardWebSocketClient$1.call(StandardWebSocketClient.java:149) ~[spring-websocket-4.2.5.RELEASE.jar:4.2.5.RELEASE] 
    at java.util.concurrent.FutureTask.run(FutureTask.java:262) ~[na:1.7.0_80] 
    at java.lang.Thread.run(Thread.java:745) [na:1.7.0_80] 
Caused by: java.util.concurrent.ExecutionException: java.net.ConnectException: Connection refused 
    at sun.nio.ch.PendingFuture.get(PendingFuture.java:202) ~[na:1.7.0_80] 
    at org.apache.tomcat.websocket.WsWebSocketContainer.connectToServer(WsWebSocketContainer.java:376) ~[tomcat7-websocket.jar:7.0.68] 
    ... 4 common frames omitted 
Caused by: java.net.ConnectException: Connection refused 
    at sun.nio.ch.UnixAsynchronousSocketChannelImpl.checkConnect(Native Method) ~[na:1.7.0_80] 
    at sun.nio.ch.UnixAsynchronousSocketChannelImpl.finishConnect(UnixAsynchronousSocketChannelImpl.java:252) ~[na:1.7.0_80] 
    at sun.nio.ch.UnixAsynchronousSocketChannelImpl.finish(UnixAsynchronousSocketChannelImpl.java:198) ~[na:1.7.0_80] 
    at sun.nio.ch.UnixAsynchronousSocketChannelImpl.onEvent(UnixAsynchronousSocketChannelImpl.java:213) ~[na:1.7.0_80] 
    at sun.nio.ch.EPollPort$EventHandlerTask.run(EPollPort.java:293) ~[na:1.7.0_80] 
    ... 1 common frames omitted 

Кто-нибудь знает простой способ, чтобы включить безопасный WebSockets? Нужно ли мне добавить дополнительный транспорт в свой код или добавить что-то в конфигурацию моего сервера?

Answer 1

Вам нужен транспортный коннектор «wss: // ...» на стороне сервера в конфигурации брокера.

См: http://activemq.apache.org/websockets.html

Answer 2

ActiveMQ не поддерживает WebSocket через стандартный протокол, но только через причал (см https://github.com/apache/activemq/blob/master/activemq-http/src/main/java/org/apache/activemq/transport/ws/WSTransportServer.java)

У вас есть несколько вариантов там:

• попробовать добавить Jetty банки (заботясь о том, чтобы не добавлять конфликтующие) в tomee/lib
• настроить внешний брокер (автономный activemq) и позволить ему подключиться к нему