0

我们正在创建一个 Mule 应用程序，它将在 Kubernetes 上的容器中运行，并将位于将连接到 JMS 2.0 Red Hat AMQ 7（基于 ActiveMQ Artemis）的副本集中。

pom.xml 已配置为获取 jms 客户端：

<dependency>
  <groupId>org.apache.activemq</groupId>
  <artifactId>artemis-jms-client-all</artifactId>
  <version>2.10.1</version>
</dependency>

JMS 配置配置为：

<jms:config name="JMS_Config" doc:name="JMS Config" doc:id="8621b07d-b203-463e-bbbe-76eb03741a61" >
    <jms:generic-connection specification="JMS_2_0" username="${mq.user}" password="${mq.password}" clientId="${mq.client.id}">
        <reconnection >
            <reconnect-forever frequency="${mq.reconnection.frequency}" />
        </reconnection>
        <jms:connection-factory >
            <jms:jndi-connection-factory connectionFactoryJndiName="ConnectionFactory" >
                <jms:name-resolver-builder jndiInitialContextFactory="org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory" jndiProviderUrl="${mq.brokerurl}"/>
            </jms:jndi-connection-factory>
        </jms:connection-factory>
    </jms:generic-connection>
    <jms:consumer-config>
        <jms:consumer-type >
            <jms:topic-consumer shared="true" durable="true"/>
        </jms:consumer-type>
    </jms:consumer-config>
    <jms:producer-config persistentDelivery="true"/>
</jms:config>

然后在 JMS 监听组件中：

<jms:listener doc:name="EMS JMS Listener" doc:id="318b4f08-daf6-41f4-944b-3ec1420d5c12" config-ref="JMS_Config" destination="${mq.incoming.queue}" ackMode="AUTO" >
    <jms:consumer-type >
        <jms:topic-consumer shared="true" subscriptionName="${mq.sub.name}" durable="true"/>
    </jms:consumer-type>
    <jms:response sendCorrelationId="ALWAYS" />
</jms:listener>

变量设置为：

mq.client.id=client-id-135a9514-d4d5-4f52-b01c-f6ca34a76b40
mq.sub.name=my-sub
mq.incoming.queue=my-queue

这是配置客户端的最佳方式吗？正如我们在部署到 K8s 时在日志中看到有关与 AMQ 服务器的连接的错误：

javax.jms.InvalidClientIDException: client-id-135a9514-d4d5-4f52-b01c-f6ca34a76b40 was already set into another connection
4

1 回答 1

2

在 JMS 2.0 中，您不必在创建共享持久订阅时设置客户端标识符。但是，如果您确实设置了客户端标识符，那么每个连接它必须是唯一的。无论出于何种原因（例如由于 Mule 或可能是 K8s），正在创建多个连接，并且由于每个连接都使用相同的客户端标识符，因此您正在接收javax.jms.InvalidClientIDException.

clientId="${mq.client.id}"从您的配置中删除，javax.jms.InvalidClientIDException应该会消失。

于 2020-02-14T02:57:27.233 回答