Quarkus应用能否连接多个JMS Broker及ActiveMQ Artemis实例？

没问题！Quarkus完全支持连接多个JMS Broker实例，包括多个独立的ActiveMQ Artemis节点，而且完全不需要依赖Camel组件——下面我给你详细拆解实现方法：

1. 核心原理：利用命名配置实例创建多连接工厂 #

Quarkus的JMS相关扩展（不管是Artemis JMS还是Qpid JMS）都支持通过命名配置节点来定义多个独立的连接工厂，每个实例可以单独配置自己的Broker URL、认证信息等。这就完美解决了你提到的“配置URL为必填字符串”的限制——每个Broker实例对应一个独立的配置项，各自指定URL即可。

2. ActiveMQ Artemis的具体配置步骤 #

以quarkus-artemis-jms扩展为例，在application.properties中添加多个实例的配置：

# 第一个Artemis Broker实例配置
quarkus.artemis.jms."artemis-east".url=tcp://broker-east.example.com:61616
quarkus.artemis.jms."artemis-east".username=east-user
quarkus.artemis.jms."artemis-east".password=east-pass

# 第二个Artemis Broker实例配置
quarkus.artemis.jms."artemis-west".url=tcp://broker-west.example.com:61616
quarkus.artemis.jms."artemis-west".username=west-user
quarkus.artemis.jms."artemis-west".password=west-pass

这里的"artemis-east"和"artemis-west"是自定义的实例名称，你可以根据业务场景命名（比如按地域、业务线区分）。

3. 在代码中注入并使用不同的连接工厂 #

配置完成后，通过@Named注解注入对应实例的ConnectionFactory，就能分别操作不同的Broker了：

import javax.enterprise.context.ApplicationScoped;
import javax.inject.Named;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Session;

@ApplicationScoped
public class MultiBrokerJmsService {

    // 注入东部区域的Artemis连接工厂
    @Named("artemis-east")
    ConnectionFactory eastBrokerFactory;

    // 注入西部区域的Artemis连接工厂
    @Named("artemis-west")
    ConnectionFactory westBrokerFactory;

    // 向东部Broker发送消息
    public void sendToEastBroker(String messageContent) {
        sendMessage(eastBrokerFactory, "east-business-queue", messageContent);
    }

    // 向西部Broker发送消息
    public void sendToWestBroker(String messageContent) {
        sendMessage(westBrokerFactory, "west-business-queue", messageContent);
    }

    // 通用消息发送方法
    private void sendMessage(ConnectionFactory factory, String queueName, String content) {
        try (var connection = factory.createConnection();
             var session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
             var producer = session.createProducer(session.createQueue(queueName))) {
            connection.start();
            producer.send(session.createTextMessage(content));
        } catch (JMSException e) {
            throw new RuntimeException("Failed to send message to target broker", e);
        }
    }
}

4. Qpid JMS（AMQP）的同理实现 #

如果你使用的是Qpid JMS扩展，配置逻辑完全一致，只是配置前缀换成quarkus.qpid-jms：

# 第一个AMQP Broker实例
quarkus.qpid-jms."amqp-prod".url=amqp://prod-broker:5672
quarkus.qpid-jms."amqp-prod".username=prod-user

# 第二个AMQP Broker实例
quarkus.qpid-jms."amqp-test".url=amqp://test-broker:5672
quarkus.qpid-jms."amqp-test".username=test-user

同样通过@Named("amqp-prod")和@Named("amqp-test")注入对应的连接工厂即可。

补充说明：集群URL vs 多独立Broker #

这里要区分两个场景：

• 如果是同一个Artemis集群的多个节点，你可以在单个URL中用逗号分隔多个地址（比如tcp://broker1:61616,tcp://broker2:61616），这是集群高可用的配置方式；
• 而我们上面讲的命名实例方式，是针对完全独立的多个Broker实例（比如分属不同环境、不同业务的Broker），这正是你需要的场景。

内容的提问来源于stack exchange，提问作者aboudirawas