ActiveMQ-CPP中getCMSMessageID返回ID与Broker端不一致问题求助

核心原因 #

activemq-cpp默认由客户端生成JMSMessageID（格式如ID:hostname.xy.hu-12445-1718189421186-0:0:1:1:1），但ActiveMQ Artemis Broker会将其替换为自身生成的UUID格式ID（如ID:ad50ab28-28a3-11ef-a29a-0a580a800369）。外部应用使用Broker生成的ID作为响应的JMSCorrelationID，导致客户端用本地生成的ID做选择器时无法匹配响应。

可行解决方案 #

方案一：禁用客户端生成MessageID，获取Broker分配的ID #

修改代码，在创建MessageProducer后调用setDisableMessageID(true)，让Broker负责生成MessageID并返回给客户端：

std::unique_ptr<cms::TextMessage> request;
std::unique_ptr<cms::MessageProducer> msgProducer(session->createProducer(queue));
// 关键配置：禁用客户端生成MessageID，由Broker生成
msgProducer->setDisableMessageID(true);

msgProducer->send(request.get());
// 此时getCMSMessageID()将返回Broker生成的UUID格式ID
std::string messageid = request->getCMSMessageID();

// 后续创建消费者时用该ID做选择器
std::unique_ptr<cms::MessageConsumer> msgConsumer(
    session->createConsumer(queue, "JMSCorrelationID = '" + messageid + "'"));
const cms::Message * message = msgConsumer->receive(timeoutSeconds * 1000);

原理：禁用客户端生成ID后，Broker接收消息时会生成自己的UUID，发送确认时将该ID返回给客户端，因此send方法返回后即可获取正确的Broker端ID，与外部应用复制的JMSCorrelationID一致。

方案二：切换为同步发送模式确保获取Broker ID #

若方案一不生效，可将生产者设置为同步发送，等待Broker确认后再获取ID：

std::unique_ptr<cms::MessageProducer> msgProducer(session->createProducer(queue));
// 禁用异步发送，等待Broker确认
msgProducer->setUseAsyncSend(false);

msgProducer->send(request.get());
// 同步发送完成后，可获取Broker生成的ID
std::string messageid = request->getCMSMessageID();

// 后续消费逻辑同前

原理：异步发送时send方法立即返回，此时Broker可能尚未返回ID；同步发送会等待Broker的确认消息，确保客户端已拿到最终的Broker生成ID。

方案三：绕过MessageID，自定义标识匹配（备选） #

若上述方法均无法获取Broker ID，可通过自定义属性+全量消费匹配：

1. 发送请求时添加唯一自定义属性：

   // 生成唯一标识（如UUID，需自行实现生成逻辑）
   std::string customRequestID = "unique-uuid-here";
   request->setStringProperty("CustomRequestID", customRequestID);
   

2. 不使用选择器，消费队列中所有消息，手动匹配响应：

   std::unique_ptr<cms::MessageConsumer> msgConsumer(session->createConsumer(queue));
   const cms::Message* message = nullptr;
   while((message = msgConsumer->receive(1000)) != nullptr) {
       std::string correlationID = message->getCMSCorrelationID();
       // 需要提前维护请求的Broker ID与CustomRequestID的映射（可通过监听请求队列获取）
       if(correlationID == mappedBrokerIDForCustomID) {
           // 找到目标响应
           break;
       }
       // 非目标消息需手动处理（如丢弃或转发）
   }
   

注：此方案需额外维护请求ID映射，需通过监听请求队列获取自己发送消息的Broker端ID，实现复杂度较高，仅作为备选。

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