Spring Integration IBM MQ配置验证：单队列读多队列发送

首先，你的核心思路是对的——使用recipient-list-router实现消息广播到多个目标队列，这完全符合Spring Integration的最佳实践。不过你的配置里有几个关键问题需要修正，才能正常工作：

1. 目标队列Bean的配置错误 #

你所有的writerQueueX Bean都使用了同一个队列名属性${jms.receiver.queue.name}（也就是读取消息的源队列），这会导致所有消息都发回源队列，而不是七个不同的目标队列。每个writerQueueX都应该对应一个独立的目标队列属性，比如${jms.writer.queue.name1}、${jms.writer.queue.name2}等。

另外，你缺少了writerQueue1的Bean定义，但在writerChannel1里引用了它，这会导致启动时抛出Bean找不到的异常。

2. JMS通道的拼写错误 #

writerChannel3的queue-name属性值是writerQueue，应该改为writerQueue3，否则会错误关联到未定义的Bean。

3. JMS入站/出站适配器的误用 #

你使用的<jms:channel>是基于JMS队列的Spring Integration消息通道，它主要用于在集成流内部通过JMS队列传递消息，而不是直接从IBM MQ队列读取或发送消息。正确的做法是：

• 使用<jms:message-driven-channel-adapter>监听源队列，将消息导入Spring Integration的内存通道
• 使用<jms:outbound-channel-adapter>将路由后的消息发送到各个目标队列

修正后的配置示例 #

<!-- 连接工厂和源队列Bean保持不变 -->
<bean id="jmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
    <property name="transportType" value="${jms.transportType}"/>
    <property name="queueManager" value="${jms.queueManager}"/>
    <property name="hostName" value="${jms.hostName}"/>
    <property name="port" value="${jms.port}" />
    <property name="channel" value="${jms.channel}"/>
</bean>

<bean id="readerQueue" class="com.ibm.mq.jms.MQQueue">
    <constructor-arg index="0" value="${jms.queueManager}"/>
    <constructor-arg index="1" value="${jms.receiver.queue.name}"/>
</bean>

<!-- 修正后的目标队列Bean，每个对应独立的队列名 -->
<bean id="writerQueue1" class="com.ibm.mq.jms.MQQueue">
    <constructor-arg index="0" value="${jms.queueManager}"/>
    <constructor-arg index="1" value="${jms.writer.queue.name1}"/>
</bean>

<bean id="writerQueue2" class="com.ibm.mq.jms.MQQueue">
    <constructor-arg index="0" value="${jms.queueManager}"/>
    <constructor-arg index="1" value="${jms.writer.queue.name2}"/>
</bean>

<!-- 省略writerQueue3到writerQueue7的定义，每个都使用对应的${jms.writer.queue.nameX} -->

<!-- Spring Integration内存通道，用于连接适配器和路由器 -->
<int:channel id="inputChannel"/>

<!-- JMS消息驱动适配器：监听源队列，将消息发送到inputChannel -->
<jms:message-driven-channel-adapter id="jmsInboundAdapter"
                                    connection-factory="jmsConnectionFactory"
                                    destination="readerQueue"
                                    channel="inputChannel"/>

<!-- 收件人列表路由器：将inputChannel的消息广播到所有目标通道 -->
<int:recipient-list-router id="customRouter" 
                           input-channel="inputChannel" 
                           timeout="1234" 
                           ignore-send-failures="true" 
                           apply-sequence="true">
    <int:recipient channel="writerChannel1"/>
    <int:recipient channel="writerChannel2"/>
    <int:recipient channel="writerChannel3"/>
    <int:recipient channel="writerChannel4"/>
    <int:recipient channel="writerChannel5"/>
    <int:recipient channel="writerChannel6"/>
    <int:recipient channel="writerChannel7"/>
</int:recipient-list-router>

<!-- 每个目标通道对应一个JMS出站适配器，发送到对应的目标队列 -->
<int:channel id="writerChannel1"/>
<jms:outbound-channel-adapter id="jmsOutboundAdapter1"
                              channel="writerChannel1"
                              connection-factory="jmsConnectionFactory"
                              destination="writerQueue1"/>

<int:channel id="writerChannel2"/>
<jms:outbound-channel-adapter id="jmsOutboundAdapter2"
                              channel="writerChannel2"
                              connection-factory="jmsConnectionFactory"
                              destination="writerQueue2"/>

<!-- 省略writerChannel3到writerChannel7的出站适配器配置 -->

<!-- JmsTemplate可以保留，如果你需要手动发送消息的场景 -->
<bean id="receiverJMSTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
    <property name="pubSubDomain" value="false"/>
    <property name="receiveTimeout" value="30000"/>
</bean>

额外建议 #

• 开启Spring Integration的调试日志，方便排查消息流动问题：logging.level.org.springframework.integration=DEBUG
• 如果你使用Spring Boot，可以考虑使用Java配置替代XML，更简洁且类型安全
• ignore-send-failures="true"会忽略发送到某个队列的失败，如果你需要处理失败场景，可以添加错误通道（error-channel）来捕获异常

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