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

實(shí)時(shí)地震清單應(yīng)用

最終的應(yīng)用程序?qū)⒘谐鍪澜绺鞯匕l(fā)生的地震并實(shí)時(shí)更新（如果可以將一分鐘視為足夠?qū)崟r(shí)的話），其內(nèi)容如下：

存儲(chǔ)地震信息

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

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

<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" />

因此，現(xiàn)在我有了一個(gè)流程來(lái)收集地震信息，并將其存儲(chǔ)到名為“ amq.topic”的RabbitMQ主題中，并在內(nèi)部將“ quakes.all”的路由密鑰插入每個(gè)地震信息中，下一步是要弄清楚如何在瀏覽器應(yīng)用程序上動(dòng)態(tài)顯示此信息。

呈現(xiàn)地震信息

Spring Framework 4.0+借助框架中內(nèi)置的基于Websocket的消息傳遞支持，可以輕松開(kāi)發(fā)應(yīng)用程序的Web部件。 Spring 4.0使用STOMP作為原始Websocket的高級(jí)協(xié)議–我提供了一些參考，這些參考使Websocket支持的細(xì)節(jié)更加清晰。

本質(zhì)上，Spring將充當(dāng)瀏覽器的中介，以訂閱RabbitMQ地震主題并在流入新地震信息時(shí)顯示實(shí)時(shí)信息，來(lái)自參考文獻(xiàn)的此圖很好地總結(jié)了這一點(diǎn)：

外部代理對(duì)Spring 4 Websockets的支持要求代理支持STOMP協(xié)議，該協(xié)議易于使用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”被注冊(cè)為終結(jié)點(diǎn)，其中Spring充當(dāng)了RabbitMQ STOMP支持的網(wǎng)關(guān)
• “ / app”是應(yīng)用程序前綴，Spring MVC將在該應(yīng)用程序前綴中偵聽(tīng)在STOMP消息幀內(nèi)編碼的瀏覽器請(qǐng)求，在這種特定情況下，我沒(méi)有從UI收到任何請(qǐng)求，因此未真正使用此端點(diǎn)
• “ / quakesep”是websocket端點(diǎn)

這就是服務(wù)器端所需的全部?jī)?nèi)容！

現(xiàn)在，為了讓客戶訂閱RabbitMQ主題中的消息，我已經(jīng)按照其中一篇參考文章中的示例實(shí)現(xiàn)了該消息。 該示例使用sockjs client ，這是一個(gè)JavaScript庫(kù)，用于在瀏覽器中進(jìn)行websocket仿真。

這是連接到websocket端點(diǎn)“ / quakesep”并訂閱“ /topic/quakes.all”端點(diǎn)的javascript代碼的樣子。 這會(huì)在內(nèi)部為該Websocket會(huì)話向RabbitMQ注冊(cè)一個(gè)臨時(shí)隊(duì)列，并將AMQP路由密鑰“ quakes.all”映射到該臨時(shí)隊(duì)列，實(shí)質(zhì)上是將所有地震消息發(fā)送到該會(huì)話的臨時(shí)隊(duì)列。

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獲得時(shí)，上面的showQuakeInfo函數(shù)僅顯示新鮮的地震信息。

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

• 我在github上有可用的代碼

資源資源

Spring Framework中的Websocket架構(gòu)

使用Spring Framework構(gòu)建基于Websocket的應(yīng)用程序的網(wǎng)絡(luò)研討會(huì)

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

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

總結(jié)

以上是生活随笔為你收集整理的Websockets与Spring 4的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。