Spring Boot集成ActiveMQ Artemis：如何避免MQTT队列带客户端ID前缀？

我在Spring Boot应用中嵌入了ActiveMQ Artemis，尝试用Spring Integration的Mqttv5PahoMessageDrivenChannelAdapter连接MQTT端口，配置代码如下：

@Bean
public ClientManager<IMqttAsyncClient, MqttConnectionOptions> clientManager(MqttConnectionOptions connectionOptions, MqttClientPersistence mqttClientPersistence) {
    Mqttv5ClientManager clientManager = new Mqttv5ClientManager(connectionOptions, "client-manager-client-id-v5");
    clientManager.setPersistence(mqttClientPersistence);
    return clientManager;
}

@Bean
public Mqttv5PahoMessageDrivenChannelAdapter agentRegistrationInputAdapter(
            ClientManager<IMqttAsyncClient, MqttConnectionOptions> clientManager,
            @Qualifier(AGENT_REGISTRATION_INPUT_CHANNEL) final MessageChannel channel) {
    final var adapter = new Mqttv5PahoMessageDrivenChannelAdapter(clientManager);
    adapter.setOutputChannel(channel);
    adapter.addTopic("agent.registration", 1);
    return adapter;
}

但我在Artemis的日志中看到以下内容：

o.a.a.a.core.server.impl.QueueImpl       : Scanning for expires on client-manager-client-id-v5.agent.registration
o.a.a.a.core.server.impl.QueueImpl       : Scanning for expires on client-manager-client-id-v5.agent.registration done

ActiveMQ Artemis创建了地址agent.registration，并在该地址下创建了队列client-manager-client-id-v5.agent.registration。

如何避免队列带有客户端ID前缀？

更新#1 #

如果队列已在初始化阶段通过定义创建，则Paho客户端不会再创建带前缀的队列。

这种行为是预期的吗？所有客户端创建的队列都会带有前缀吗？

解答 #

1. 队列带客户端ID前缀的原因
   这是ActiveMQ Artemis处理MQTT非共享订阅的默认行为：当客户端以非共享方式订阅主题时，Artemis会自动创建与该客户端绑定的专属队列，命名规则为{客户端ID}.{主题名}，目的是确保该客户端能独立接收对应主题的消息，避免和其他客户端的消息混淆。

2. 移除前缀的两种方案

• 使用MQTT共享订阅
  将订阅主题改为共享订阅格式，例如$share/groupName/agent.registration。此时Artemis会创建以共享组名为标识的队列，而非带客户端ID前缀的队列，同一组内的客户端可负载均衡接收消息。
  调整代码中的订阅逻辑：

adapter.addTopic("$share/myGroup/agent.registration", 1);

• 预创建Artemis队列
  在Artemis的配置文件（如broker.xml）中手动定义agent.registration地址对应的队列，指定自定义队列名称，客户端订阅时会直接复用该预创建队列，不会再生成带客户端ID前缀的新队列。
  示例配置片段：

<address name="agent.registration">
  <multicast>
    <queue name="agent.registration.queue"/>
  </multicast>
</address>

3. 关于更新#1的疑问
   这种行为是完全符合预期的。当提前预创建队列后，客户端订阅会复用已有队列，不会生成新的客户端专属队列；而默认情况下，客户端发起的非共享订阅都会触发Artemis创建带客户端ID前缀的专属队列，这是MQTT协议在Artemis中的标准实现逻辑。

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