Spring Boot集成IBM MQ报2027 MQRC_MISSING_REPLY_TO_Q错误排查

数据老陈

2026-8-29

问题根因

2027（MQRC_MISSING_REPLY_TO_Q）错误的触发逻辑是IBM MQ客户端发送消息前，校验原生MQMD（消息描述符）结构中的ReplyToQ字段为空或无效，和Spring抽象层封装的消息头属性没有直接关联。
你debug看到的ReplyToQ、jms_replyTo、reply_destination_queue等字段，都是Spring Messaging层存在消息头Map里的自定义属性，如果没有配置正确的映射规则，这些值不会同步写入MQ原生消息的MQMD结构。MQ客户端做发送校验时只会读取MQMD结构内的字段，读不到合法的回复队列配置就会抛出该错误。
常见触发场景包括：

JMS出站网关配置了请求-应答模式（requires-reply="true"），但未显式配置头映射规则，Spring不会自动把消息头里的回复队列值写入MQMD结构
回复队列配置不符合MQ规范：仅配置了队列名未带所属队列管理器名、队列名包含不可见空格/非法字符，MQ判定字段无效等同于缺失
MQQueueConnectionFactory未开启MQMD上下文写入权限，ReplyTo字段写入操作被静默丢弃，直到发送校验阶段才报错
DynamicJmsTemplate的临时队列创建逻辑异常，回复队列仅作为字符串存在于Spring消息头中，MQ层面未实际创建对应队列对象
独立部署的消费者回发响应时，没有直接引用入站消息的JMSReplyTo目标对象，而是自行拼接队列名字符串构造目标，导致MQ识别失败

解决方案

按以下顺序排查修正配置即可：

修正生产者端DynamicJmsTemplate配置，强制开启MQ原生字段同步

<bean id="jmsTemplate" class="org.springframework.jms.core.DynamicJmsTemplate">
    <property name="connectionFactory" ref="cachingConnectionFactory"/>
    <property name="messageIdEnabled" value="true"/>
    <property name="explicitQosEnabled" value="true"/>
    <!-- 明确指定使用点到点队列模式，避免被误识别为主题 -->
    <property name="pubSubDomain" value="false"/>
    <property name="receiveTimeout" value="30000"/>
</bean>

修正JMS出站网关配置，显式指定头映射规则，强制将Spring层的回复队列属性写入MQMD结构

<int-jms:outbound-gateway 
    connection-factory="cachingConnectionFactory"
    request-destination-name="YOUR_REQUEST_QUEUE"
    reply-destination-name="YOUR_REPLY_QUEUE"
    requires-reply="true"
    jms-template="jmsTemplate">
    <int-jms:header-mapper>
        <bean class="org.springframework.jms.support.SimpleJmsHeaderMapper">
            <property name="mappedReplyToFields" value="REPLY_TO_QUEUE,REPLY_TO_QUEUE_MANAGER"/>
        </bean>
    </int-jms:header-mapper>
</int-jms:outbound-gateway>

修正MQQueueConnectionFactory和CachingConnectionFactory配置，开启MQMD写入权限，避免跨会话导致临时队列失效

<!-- MQ原生连接工厂 -->
<bean id="mqQueueConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
    <property name="hostName" value="MQ服务地址"/>
    <property name="port" value="MQ服务端口"/>
    <property name="queueManager" value="队列管理器名称"/>
    <property name="channel" value="服务器连接通道名称"/>
    <property name="transportType" value="1"/>
    <!-- 开启全上下文写入权限，允许修改MQMD字段 -->
    <property name="options" value="com.ibm.mq.constants.CMQC.MQOO_SET_ALL_CONTEXT"/>
</bean>

<!-- 缓存连接工厂 -->
<bean id="cachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory" ref="mqQueueConnectionFactory"/>
    <property name="username" value="MQ认证用户名"/>
    <property name="password" value="MQ认证密码"/>
    <property name="sessionCacheSize" value="1"/>
    <property name="cacheProducers" value="true"/>
    <property name="cacheConsumers" value="false"/>
</bean>

修正独立消费者端的出站通道适配器配置，回发响应时直接引用入站消息携带的JMSReplyTo对象，不要硬编码或自行拼接队列名

<int-jms:outbound-channel-adapter 
    connection-factory="consumerCachingConnectionFactory"
    channel="replySendChannel"
    destination-expression="headers.jms_replyTo"/>

增加发送前校验逻辑，直接读取MQ原生消息的MQMD结构确认配置生效，不要仅检查Spring层消息头

jmsTemplate.setProducerInterceptor((session, destination, messageCreator) -> {
    javax.jms.Message jmsMessage = messageCreator.createMessage(session);
    if (jmsMessage instanceof com.ibm.mq.jms.MQMessage) {
        com.ibm.mq.MQMessage nativeMqMsg = ((com.ibm.mq.jms.MQMessage) jmsMessage).getUnderlyingMessage();
        // 这两个字段有合法值才代表MQ能正确识别回复队列
        System.out.printf("MQMD校验：ReplyToQ=%s, ReplyToQMgr=%s%n",
                nativeMqMsg.replyToQueueName.trim(),
                nativeMqMsg.replyToQueueManagerName.trim());
    }
    return jmsMessage;
});

校验提示：如果打印出的replyToQueueName为空，说明头映射规则未生效，回头检查header-mapper配置；如果字段值存在但包含空格、和MQ上创建的队列名不匹配，直接修正队列名配置即可。

内容的提问来源于stack exchange，提问作者İlkay Gunel