有哪些网站做美食的图片很精致,网站制作论文 优帮云,金湖网站建设公司,网站制作公司拟activemq网络桥接现在#xff0c;我们已经在本博客系列的第1部分和第2 部分中了解了ActiveMQ网络连接器的基础#xff0c;在第3部分中#xff0c;我们将研究ActiveMQ如何平衡连接到代理网络的使用者。 介绍 当可以无序处理队列中的消息时通常使用并发使用者#xff0c;通常… activemq网络桥接 现在我们已经在本博客系列的第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.htmlactivemq网络桥接
