Spring Integration整合JMS/IBM MQ超时无响应如何实现告警业务逻辑

问题1：超时配置不生效的原因与解决方案 #

• 核心原因1：你当前使用的是单向的jms:outbound-channel-adapter，不支持请求-应答关联机制，Spring Integration Gateway无法匹配发出的请求和后续收到的响应，同步等待逻辑不会触发，超时配置自然不生效。
• 核心原因2：你的responseChannel配置为队列通道，异步消息投递模式下Gateway默认的同步超时机制无法绑定对应请求的等待上下文。
• 核心原因3：如果你的Gateway接口方法定义为void返回，Gateway不会启动应答等待流程，超时配置不会生效。

解决方案：

1. 将单向的出站适配器替换为jms:outbound-gateway，开启请求-应答模式，自动处理消息关联ID匹配：

<!-- 替换原来的jms:outbound-channel-adapter -->
<jms:outbound-gateway id="request.queue.gateway"
    connection-factory="ibmConnectionFactory"
    destination="requestQueue"
    reply-destination="responseQueue"
    receive-timeout="120000"
    correlation-key="JMSCorrelationID"/>

2. 调整Gateway配置，新增错误通道用于接收超时异常，同时确保Gateway接口方法有非void返回值：

<integration:gateway id="serviceAdaptedGateway" 
    service-interface="com.mycompany.service.gatewayServiceInterface"
    default-request-channel="requestChannel"
    default-reply-timeout="120000"
    error-channel="gatewayErrorChannel"/>

3. 移除原来responseChannel绑定的jms消息驱动适配器，因为jms outbound-gateway会自行接收响应消息，不需要额外的入站适配器消费响应队列。

问题2：超时告警逻辑的添加位置 #

Gateway触发超时后会抛出MessageTimeoutException，并将异常包装为消息投递到你配置的error-channel中，你只需要在错误通道后挂载服务激活器，在对应的处理方法中实现告警邮件发送逻辑即可：

<!-- 错误通道配置 -->
<integration:channel id="gatewayErrorChannel"/>

<!-- 超时异常处理服务激活器 -->
<integration:service-activator input-channel="gatewayErrorChannel"
    ref="timeoutAlertService" method="sendAlertEmail"/>

对应的业务实现类示例：

@Component
public class TimeoutAlertService {
    public void sendAlertEmail(Message<MessageTimeoutException> errorMsg) {
        // 从异常中获取原始请求信息
        Message<?> originalRequest = errorMsg.getPayload().getFailedMessage();
        // 调用邮件服务发送告警
        mailService.sendTimeoutAlert(originalRequest);
    }
}

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