百度网站排名搜行者seo,查网站是不是用shopify做的,网站 网络架构,一个几个人做网站的几个故事电影apollo 参数传递在我以前的文章中#xff0c;我介绍了几个有趣的用例#xff0c;这些用例使用著名的消息代理HornetQ和ActiveMQ通过Websockects实现STOMP消息传递。 但是我没有介绍的是Apollo#xff0c;因为我个人认为它的API是冗长的#xff0c;并且不像Java开发人员那样… apollo 参数传递 在我以前的文章中我介绍了几个有趣的用例这些用例使用著名的消息代理HornetQ和ActiveMQ通过Websockects实现STOMP消息传递。 但是我没有介绍的是Apollo因为我个人认为它的API是冗长的并且不像Java开发人员那样表现力强。 尽管如此我花更多的时间在Apollo上玩耍就更加确信我已经拥有了巨大的潜力。 所以这篇文章全是关于阿波罗的 。 我们要解决的问题保持不变简单的发布/订阅解决方案其中JavaScript Web客户端发送消息并侦听特定主题。 每当收到任何消息时客户端都会显示警报窗口请注意我们需要使用支持Websockets的现代浏览器例如Google Chrome或Mozilla Firefox 。 让我们从index.html 导入了很棒的stomp.js JavaScript库开始着手吧 script srcstomp.js/scriptscript typetext/javascriptvar 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 testfinal 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// localhost61614创建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 hasnt 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.htmlapollo 参数传递
