IBM MQ消息未被消费时如何实现自动定时重处理？

核心方案（推荐） #

IBM MQ 8及以上版本原生提供Delivery Delay特性，无需额外引入中间件、自研定时调度逻辑，即可实现消息的延迟投递，完全匹配你的需求场景。

实现步骤 #

1. 前置校验：确认IBM MQ服务端版本、项目依赖的IBM MQ客户端版本均≥8.0
2. 调整消费逻辑：在@JmsListener方法中判断处理失败且不需要回滚事务时，先确认原消息消费成功，再将消息内容重新发送到原业务队列，发送前设置延迟时长即可。

代码示例 #

首先注入JmsTemplate实例：

@Autowired
private JmsTemplate jmsTemplate;

@Value("${QueueName}")
private String businessQueue;

调整@JmsListener消费逻辑：

@JmsListener(destination = "${QueueName}")
public void readMessages(TextMessage msg) {
    try {
        // 原有业务处理逻辑
        doBusiness(msg);
    } catch (Exception e) {
        // 捕获到需要延迟重处理的异常场景
        if (needDelayRetry(e)) {
            // 先确认原消息消费成功，避免回滚立即重投
            // 注：如果是手动确认模式，此处调用msg.acknowledge()
            // 设置5分钟延迟，单位为毫秒
            jmsTemplate.setDeliveryDelay(300000L);
            // 重新发送消息到业务队列
            jmsTemplate.send(businessQueue, session -> {
                TextMessage newMsg = session.createTextMessage(msg.getText());
                // 可选：传递重试次数，避免无限重投
                int retryCount = msg.getIntProperty("retryCount") == null ? 0 : msg.getIntProperty("retryCount");
                newMsg.setIntProperty("retryCount", retryCount + 1);
                return newMsg;
            });
        } else {
            // 其他异常走原有回滚/死信队列逻辑
            throw new RuntimeException(e);
        }
    }
}

低版本兼容方案（IBM MQ < 8.0） #

如果使用的是不支持Delivery Delay的低版本IBM MQ，可通过自研逻辑实现：

• 新增独立的延迟等待队列，处理失败的消息先写入该队列，消息上标记需要重新投递的时间
• 新增定时调度任务，每分钟扫描延迟等待队列，将达到投递时间的消息转写到原业务队列处理
• 自研逻辑需要额外处理重试次数上限、消息去重、调度幂等问题，运维和开发成本远高于原生特性方案。

注意事项 #

• 建议给消息添加自定义重试次数字段，设置最大重试上限，超过上限的消息转入死信队列做人工排查，避免无效循环占用资源
• 如果使用事务型会话，要确保原消息的消费事务提交成功后再发送延迟消息，避免异常场景下出现消息重复问题
• setDeliveryDelay方法设置的延迟时间单位为毫秒，5分钟对应值为300000L

内容的提问来源于stack exchange，提问作者M.Love