上海专业网站建设排行,网络规划设计师高级证书,德阳seo优化,提供响应式网站建设现在#xff0c;我们已经在本博客系列的第1部分和第2 部分中了解了ActiveMQ网络连接器的基础#xff0c;在第3部分中#xff0c;我们将研究ActiveMQ如何平衡连接到代理网络的使用者。 介绍 当可以无序处理队列中的消息时通常使用并发使用者#xff0c;通常可以提高消息吞吐… 现在我们已经在本博客系列的第1部分和第2 部分中了解了ActiveMQ网络连接器的基础在第3部分中我们将研究ActiveMQ如何平衡连接到代理网络的使用者。 介绍 当可以无序处理队列中的消息时通常使用并发使用者通常可以提高消息吞吐量。 ActiveMQ代理以循环方式在使用者之间调度消息以便在并发使用者之间平衡消息消耗除非将使用者指定为独占 。 让我们看下面的示例其中三个使用者同时处理来自队列foo.bar的消息。 生产者排队60条消息这些消息由三个消费者每个20位以循环方式处理。 在队列foo.bar上启动三个并发使用者 Ashwinis-MacBook-Pro:example akuntamukkala$ pwd
/Users/akuntamukkala/apache-activemq-5.8.0/exampleAshwinis-MacBook-Pro:example akuntamukkala$ ant consumer -Durltcp://localhost:61616 -Dtopicfalse -Dsubjectfoo.bar -DparallelThreads3 -Dmax20 产生60条消息 Ashwinis-MacBook-Pro:example akuntamukkala$ ant producer -Durltcp://localhost:61616 -Dtopicfalse -Dsubjectfoo.bar -Dmax60 以下屏幕快照显示了3个使用者正在处理来自队列foo.bar的消息。 入队和出队60条消息。 如下所示每个使用者处理了20条消息。 以下摘录自日志显示消息被划分为三个使用者。 [Thread-3] Received: Message: 1 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000)[Thread-2] Received: Message: 0 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000)[Thread-1] Received: Message: 2 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000)[Thread-3] Received: Message: 4 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000)[Thread-2] Received: Message: 3 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000)[Thread-1] Received: Message: 5 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000)[Thread-3] Received: Message: 7 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000)[Thread-2] Received: Message: 6 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000)[Thread-1] Received: Message: 8 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000)[Thread-3] Received: Message: 10 sent at: Tue Mar 04 13:46:53 IST 2014 ... (length 1000) 现在我们已经看到了并发消费者在单个经纪人上的工作方式现在我们将研究当消费者跨经纪人网络分布时它们如何工作。 本地与远程消费者 让我们借助下图所示的配置来探索ActiveMQ如何处理本地和远程使用者。 消费者1和消费者2分别使用来自Broker-1和Broker-2上的队列foo.bar的消息。 Broker-1建立了到Broker-2的网络连接器以转发队列消息。 生产者将消息放入Broker-1上的队列foo.bar中 让我们看看这个动作 编辑Broker-1的配置/Users/akuntamukkala/apache-activemq-5.8.0/bridge-demo/broker-1/conf/activemq.xml并打开与Broker-2的网络连接器然后重新启动Broker-1和Broker-2 networkConnectorsnetworkConnectornameT:broker1-broker2uristatic:(tcp://localhost:61626)duplexfalsedecreaseNetworkConsumerPriorityfalsenetworkTTL2dynamicOnlytrueexcludedDestinationsqueue physicalName //excludedDestinations/networkConnectornetworkConnectornameQ:broker1-broker2uristatic:(tcp://localhost:61626)duplexfalsedecreaseNetworkConsumerPriorityfalsenetworkTTL2dynamicOnlytrueexcludedDestinationstopic physicalName //excludedDestinations/networkConnector/networkConnectors 启动本地消费者消费者1 Ashwinis-MacBook-Pro:example akuntamukkala$ ant consumer -Durltcp://localhost:61616 -Dtopicfalse -Dsubjectfoo.bar 启动远程使用者Consumer-2 Ashwinis-MacBook-Pro:example akuntamukkala$ ant consumer -Durltcp://localhost:61626 -Dtopicfalse -Dsubjectfoo.bar 在Broker-1上启动生产者以排队100条消息 Ashwinis-MacBook-Pro:example akuntamukkala$ ant producer -Durltcp://localhost:61616 -Dtopicfalse -Dsubjectfoo.bar -Dmax100 屏幕截图显示了Broker-1的队列 让我们看一下消费者看看消息是如何被分离出来的。 您可能会注意到ActiveMQ代理将消息均匀地分派给本地使用者而不是远程使用者从而赋予它们相同的优先级。 远程使用者Consumer-2仅距离代理1跳其距离配置的networkTTL值2少。 这会导致路由选择欠佳尤其是在连接了经纪人时使得生产者和消费者之间可能有多种路由。 为了确保生产者和消费者之间的最短路径最好将其分发给本地消费者而不是偏远的消费者。 ActiveMQ提供了一种使用该属性在本地使用者和远程使用者之间配置优先级的方法 网络连接器上的reductionNetworkConsumerPriority。 默认情况下此值为false因此将本地和远程代理视为相同。 如果我们在更改了reduceNetworkConsumerPriority “ true”之后重复上述步骤那么我们发现本地消费者Consumer-1的优先级高于远程消费者Consumer-2即距离中间商1的路程。 ActiveMQ可以智能地找出消息生产者和消费者之间的代理网络中的最短路径。 请阅读以下链接以进一步了解ActiveMQ的最佳路由。 http://fusesource.com/docs/esb/4.3/amq_clustering/Networks-OptimizingRoutes.htm l 至此本系列文章的第3部分结束了我们看到了如何区分本地和远程使用者以帮助ActiveMQ确定消息产生者和使用者之间的最佳路径。 一如既往地欢迎您提出意见。 请继续关注第4部分我们将讨论远程并发使用方的负载平衡… 翻译自: https://www.javacodegeeks.com/2014/04/activemq-network-of-brokers-explained-part-3.html
