如何使应用程序的一个实例只接收每个AMQP主题消息（消费者群体行为）

Question

我正在使用Apache Camel的AMQP组件来收听来自ActiveMQ Artemis主题的消息。

此应用程序在Kubernetes上运行，有两个副本。

我已经配置了一个持久订阅，每个pod有一个唯一的clientId和一个通用订阅名称：

<route autoStartup=true" id="myRoute">
    <from id="_amqp_topic" uri="amqp:topic:xxx?connectionFactory=#amqpCF&amp;disableReplyTo=true&amp;transacted=false&amp;subscriptionDurable=true&amp;clientId={{container-id}}&amp;durableSubscriptionName=eventSubscription"/>
    <log loggingLevel="INFO" message="Received event: ${body}"/>
    ...
</route>

问题是两个pod都接收消息，而只有一个应该接收。我正在尝试实现类似于Kafka的消费者组的东西，其中只有一个组成员接收每条消息。

Answer 1

如果只希望一个订阅者接收消息，则订阅者必须共享同一订阅。因此，你需要：

• 在\u amqp\u主题中设置subscriptionShared=true，uri

例如：

xml prettyprint-override"><route autoStartup=true" id="myRoute">
    <from id="_amqp_topic" uri="amqp:topic:xxx?connectionFactory=#amqpCF&amp;disableReplyTo=true&amp;transacted=false&amp;subscriptionDurable=true&amp;clientId=myClientID&amp;durableSubscriptionName=eventSubscription&amp;subscriptionShared=true"/>
    <log loggingLevel="INFO" message="Received event: ${body}"/>
    ...
</route>

另一种选择是使用队列而不是主题，例如：

<route autoStartup=true" id="myRoute">
    <from id="_amqp_queue" uri="amqp:queue:xxx?connectionFactory=#amqpCF&amp;disableReplyTo=true&amp;transacted=false"/>
    <log loggingLevel="INFO" message="Received event: ${body}"/>
    ...
</route>