集群ActiveMQ中的负载平衡

Question

假设我在一个集群中有3个ActiveMQ Artemis代理：

1. 经纪人_01

在给定的时间点，我有每个经纪人的消费者数量：

1. 经纪人有50名消费者

让我们假设在这个给定的时间点，有70条消息要发送到集群中的一个队列。

我们期望集群完成负载平衡，以便Broker_01将接收50条消息，Broker_0210条消息，Broker_0310条消息，但目前我们正在经历70条消息通过所有3个代理随机分发。

是否有任何配置可以根据每个代理中的消费者数量分发消息？

我刚刚读了留档。所以，据我所知，如果我们配置集群连接，ActiveMQ会基于循环进行负载平衡。我们的broker.xml如下所示：

        <cluster-connections>
            <cluster-connection name="my-cluster">
                <connector-ref>amq-v01_connector</connector-ref>
                <min-large-message-size>524288</min-large-message-size>
                <call-timeout>120000</call-timeout>
                <retry-interval>500</retry-interval>
                <retry-interval-multiplier>1.5</retry-interval-multiplier>
                <max-retry-interval>2000</max-retry-interval>
                <use-duplicate-detection>true</use-duplicate-detection>
                <message-load-balancing>ON_DEMAND</message-load-balancing>
                <max-hops>1</max-hops>
                <notification-interval>800</notification-interval>
                <notification-attempts>2</notification-attempts>
                <static-connectors>
                    <connector-ref>amq-v02_connector</connector-ref>
                </static-connectors>
            </cluster-connection>
        </cluster-connections>

此外，队列的地址设置如下所示：

            <address-setting match="MyQueue">
                <address-full-policy>BLOCK</address-full-policy>
                <max-size-bytes>50Mb</max-size-bytes>
            </address-setting>

我是否遗漏了一些东西，以便进行负载平衡？

下一点将如文档中所述，负载平衡总是基于循环进行的，不可能基于每个节点中的使用者数量进行负载平衡的配置。

我假设我需要客户端连接负载平衡，因为我们希望根据每个代理中的消费者数量对到达3个代理的消息进行负载平衡。正如文档中所述，我们可以使用5种开箱即用的策略（循环、第一元素等）。此外，我们还可以通过实施连接负载平衡策略来实施我们自己的策略。假设我想实施我自己的政策，那么根据消费者的数量，我的想法是什么？

Answer 1

没有现成的方法让制作人知道每个代理上有多少消费者，然后将消息发送给相应的代理。

您可以实施自己的连接负载平衡策略。然而，为了确定队列负载平衡策略实现中存在多少消费者，需要知道集群中所有代理的URL以及向其发送消息的队列的名称，并且无法提供这些信息。连接负载平衡策略界面非常简单。

如果每个节点上的消息太少，我建议您首先重新考虑对3节点集群的需求。在某些用例中，单个代理可以处理数百万条消息的吞吐量。如果每个节点处理的消息少于50条，那么您可能根本不需要集群。