我將整個廚盆放入一個小型Web應用程序中，此應用程序是我在該帖子中開發的一部分-Spring Boot，Spring Integration，RabbitMQ，最后是該帖子的主題，Spring MVC與Spring 4中的Websocket支持。

實時地震清單應用

最終的應用程序將列出世界各地發生的地震并實時更新（如果可以將一分鐘視為足夠實時的話），其內容如下：

存儲地震信息

該應用程序的第一部分是每分鐘從USGS地震危害計劃中輪詢數據并進行存儲。 我選擇將其直接存儲到RabbitMQ主題中，稍后將其用于Websockets集成。 Spring Integration非常適合此類功能的需求-僅使用配置，我就可以輪詢USGS服務，以提供此信息的json供稿并將其寫入RabbitMQ主題。 這是這樣的流程：

下面是相同的原始完整Spring集成流程，此處缺少的唯一代碼是Rabbitmq的配置，該配置是另一個配置文件的一部分：

<import resource="rabbit-context.xml"/><int:inbound-channel-adapter channel="quakeinfotrigger" expression="''"><int:poller fixed-delay="60000"></int:poller></int:inbound-channel-adapter><int:channel id="quakeinfo"/><int:channel id="quakeinfotrigger"></int:channel><int-http:outbound-gateway id="quakerHttpGateway"request-channel="quakeinfotrigger"url="http://earthquake.usgs.gov/earthquakes/feed/geojson/all/hour"http-method="GET"expected-response-type="java.lang.String"charset="UTF-8"reply-channel="quakeinfo"></int-http:outbound-gateway><int-amqp:outbound-channel-adapter amqp-template="amqpTemplate" channel="quakeinfo" />

因此，現在我有了一個流程來收集地震信息，并將其存儲到名為“ amq.topic”的RabbitMQ主題中，并在內部將“ quakes.all”的路由密鑰插入每個地震信息中，下一步是要弄清楚如何在瀏覽器應用程序上動態顯示此信息。

呈現地震信息

Spring Framework 4.0+借助框架中內置的基于Websocket的消息傳遞支持，可以輕松開發應用程序的Web部件。 Spring 4.0使用STOMP作為原始Websocket的高級協議–我提供了一些參考，這些參考使Websocket支持的細節更加清晰。

本質上，Spring將充當瀏覽器的中介，以訂閱RabbitMQ地震主題并在流入新地震信息時顯示實時信息，來自參考文獻的此圖很好地總結了這一點：

外部代理對Spring 4 Websockets的支持要求代理支持STOMP協議，該協議易于使用RabbitMQ啟用 。 有了RabbitMQ中的STOMP支持，Spring MVC配置如下所示：

@Configuration @EnableWebSocketMessageBroker public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {@Overridepublic void configureMessageBroker(MessageBrokerRegistry config) {config.enableStompBrokerRelay("/topic/");config.setApplicationDestinationPrefixes("/app");}@Overridepublic void registerStompEndpoints(StompEndpointRegistry registry) {registry.addEndpoint("/quakesep").withSockJS();} }

• “ / topic”被注冊為終結點，其中Spring充當了RabbitMQ STOMP支持的網關
• “ / app”是應用程序前綴，Spring MVC將在該應用程序前綴中偵聽在STOMP消息幀內編碼的瀏覽器請求，在這種特定情況下，我沒有從UI收到任何請求，因此未真正使用此端點
• “ / quakesep”是websocket端點

這就是服務器端所需的全部內容！

現在，為了讓客戶訂閱RabbitMQ主題中的消息，我已經按照其中一篇參考文章中的示例實現了該消息。 該示例使用sockjs client ，這是一個JavaScript庫，用于在瀏覽器中進行websocket仿真。

這是連接到websocket端點“ / quakesep”并訂閱“ /topic/quakes.all”端點的javascript代碼的樣子。 這會在內部為該Websocket會話向RabbitMQ注冊一個臨時隊列，并將AMQP路由密鑰“ quakes.all”映射到該臨時隊列，實質上是將所有地震消息發送到該會話的臨時隊列。

function connect() {var socket = new SockJS('/quakesep');stompClient = Stomp.over(socket);stompClient.connect({}, function(frame) {console.log('Connected: ' + frame);stompClient.subscribe('/topic/quakes.all', function(message){showQuakeInfo(message.body);});});}

從RabbitMQ獲得時，上面的showQuakeInfo函數僅顯示新鮮的地震信息。

整個示例與Spring Boot結合在一起，這可以確保將pom文件中聲明的依賴項保持在最低限度，啟動應用程序所需的配置量非常小-本質上是我在上面顯示的WebSocketConfig代碼！

• 我在github上有可用的代碼

資源資源

Spring Framework中的Websocket架構

使用Spring Framework構建基于Websocket的應用程序的網絡研討會

參考： all和其他博客中來自JCG合作伙伴 Biju Kunjummen的Spring 4 Websockets 。

翻譯自: https://www.javacodegeeks.com/2014/03/websockets-with-spring-4.html

總結

以上是生活随笔為你收集整理的Websockets与Spring 4的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。