在我以前的文章中，我介紹了幾個有趣的用例，這些用例使用著名的消息代理HornetQ和ActiveMQ通過Websockects實現STOMP消息傳遞。 但是我沒有介紹的是Apollo，因為我個人認為它的API是冗長的，并且不像Java開發人員那樣表現力強。 盡管如此，我花更多的時間在Apollo上玩耍，就更加確信我已經擁有了很大的潛力。 所以這篇文章全是關于阿波羅的 。

我們正在嘗試解決的問題保持不變：簡單的發布/訂閱解決方案，其中JavaScript Web客戶端發送消息并偵聽特定主題。 每當收到任何消息時，客戶端都會顯示警報窗口（請注意，我們需要使用支持Websockets的現代瀏覽器，例如Google Chrome或Mozilla Firefox ）。

讓我們從index.html （導入了很棒的stomp.js JavaScript庫）開始著手吧 ：

<script src="stomp.js"></script><script type="text/javascript">var client = Stomp.client( "ws://localhost:61614/stomp", "v11.stomp" );client.connect( "", "",function() {client.subscribe("/topic/test",function( message ) {alert( message );}, { priority: 9 } );client.send("/topic/test", { priority: 9 }, "Pub/Sub over STOMP!");}); </script>

客戶端部分沒有什么不同，只是主題名稱現在為/ topic / test 。 但是服務器端相差很多。 Apollo是用Scala編寫的，并包含異步，非阻塞編程模型。 我認為，這是一件非常好的事情。 雖然它帶來了一個新的編程范式，但也不一定是一件壞事。 AppConfig類是用于配置嵌入式Apollo代理的類：

package com.example.messaging;import java.io.File;import org.apache.activemq.apollo.broker.Broker; import org.apache.activemq.apollo.broker.jmx.dto.JmxDTO; import org.apache.activemq.apollo.dto.AcceptingConnectorDTO; import org.apache.activemq.apollo.dto.BrokerDTO; import org.apache.activemq.apollo.dto.TopicDTO; import org.apache.activemq.apollo.dto.VirtualHostDTO; import org.apache.activemq.apollo.dto.WebAdminDTO; import org.apache.activemq.apollo.stomp.dto.StompDTO; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;@Configuration public class AppConfig {@Beanpublic Broker broker() throws Exception {final Broker broker = new Broker();// Configure STOMP over WebSockects connectorfinal AcceptingConnectorDTO ws = new AcceptingConnectorDTO();ws.id = "ws";ws.bind = "ws://localhost:61614"; ws.protocols.add( new StompDTO() );// Create a topic with name 'test'final TopicDTO topic = new TopicDTO();topic.id = "test";// Create virtual host (based on localhost)final VirtualHostDTO host = new VirtualHostDTO();host.id = "localhost"; host.topics.add( topic );host.host_names.add( "localhost" );host.host_names.add( "127.0.0.1" );host.auto_create_destinations = false;// Create a web admin UI (REST) accessible at: http://localhost:61680/api/index.html#!/ final WebAdminDTO webadmin = new WebAdminDTO();webadmin.bind = "http://localhost:61680";// Create JMX instrumentation final JmxDTO jmxService = new JmxDTO();jmxService.enabled = true;// Finally, glue all together inside broker configurationfinal BrokerDTO config = new BrokerDTO();config.connectors.add( ws );config.virtual_hosts.add( host );config.web_admins.add( webadmin );config.services.add( jmxService );broker.setConfig( config );broker.setTmp( new File( System.getProperty( "java.io.tmpdir" ) ) );broker.start( new Runnable() { @Overridepublic void run() { System.out.println("The broker has been started started.");}} );return broker;} }

我想很清楚我的意思是冗長，不夠表達，但至少很容易理解。 首先，我們在ws：// localhost：61614創建Websockects連接器，并要求它支持STOMP協議。 然后，我們使用名稱測試創建一個簡單的主題（在客戶端將其稱為/ topic / test ）。 下一個重要步驟是創建虛擬主機，并將主題（和隊列（如果有）綁定到該主機 ）。 主機名列表非常重要，因為目標解析邏輯在很大程度上依賴它。 在接下來的步驟中，我們將配置Web管理員 UI和JMX工具 ，使我們能夠訪問配置，統計信息和監視。 要進行檢查，請在Apollo代理啟動后在Web瀏覽器中打開此URL 。 最后，通過應用配置并啟動代理，我們一切順利！ 如您所見，異步編程模型會導致回調和匿名函數（ Java 8在哪里？）。

現在，完成配置后，該看一下放置在Starter類中的啟動邏輯了（同樣，回調和匿名函數用于執行正常的關閉邏輯）：

package com.example.messaging;import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit;import org.apache.activemq.apollo.broker.Broker; import org.springframework.context.annotation.ConfigurableApplicationContext;public class Starter {public static void main( String[] args ) throws Exception {try( ConfigurableApplicationContext context = new AnnotationConfigApplicationContext( AppConfig.class ) ) {final Broker broker = context.getBean( Broker.class ); System.out.println( "Press any key to terminate ..." );System.in.read(); final CountDownLatch latch = new CountDownLatch( 1 );broker.stop( new Runnable() { @Overridepublic void run() { System.out.println("The broker has been stopped.");latch.countDown();}} );// Gracefully stop the brokerif( !latch.await( 1, TimeUnit.SECONDS ) ) {System.out.println("The broker hasn't been stopped, exiting anyway ...");}}} }

與前面的示例一樣 ，在運行Starter類并在瀏覽器中打開index.html之后，我們應該看到類似以下內容：

很好，效果很好！ 我非常確定，只是在Scala中重寫代碼，此Apollo API使用示例將看起來更加緊湊和簡潔。 無論如何，如果您正在尋找杰出的消息傳遞體系結構，我認為Apollo消息代理絕對值得考慮。

所有資源均可在GitHub： Apollo示例上獲得 。

參考： Andriy Redko {devmind}博客上的JCG合作伙伴 Andrey Redko 使用ActiveMQ和HornetQ通過WebSockets通過STOMP進行了簡單消息傳遞 。

翻譯自: https://www.javacodegeeks.com/2013/09/easy-messaging-with-stomp-over-websockets-using-apollo.html

總結

以上是生活随笔為你收集整理的使用Apollo通过WebSocket通过STOMP轻松进行消息传递的全部內容，希望文章能夠幫你解決所遇到的問題。

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