Java MDB监听器强制停止时的消息确认与重试机制问题

问题根源 #

当前配置使用Auto-acknowledge模式，WAS在MDB接收消息后立即确认，导致强制停止应用时，未完成处理的消息已从队列移除。CLIENT_ACKNOWLEDGEMENT未生效的核心原因是：若未明确配置事务类型为Bean管理（BMT），容器事务（CMT）会覆盖消息确认模式，导致手动ack不生效。

方案1：Bean管理事务（BMT）+客户端确认 #

修改MDB代码，明确使用BMT并配置CLIENT_ACKNOWLEDGEMENT，确保只有业务处理完成后才手动确认消息：

@MessageDriven(name = "queueMDB", activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "CLIENT_ACKNOWLEDGEMENT"),
    @ActivationConfigProperty(propertyName = "transactionType", propertyValue = "Bean"),
})
public class TestMdb implements MessageListener {

    @Resource
    private MessageDrivenContext messageDrivenContext;

    @Override
    public void onMessage(Message message) {
        try {
            // 执行业务逻辑（数据库更新等）
            // Some usefull code...
            
            // 业务处理成功后手动确认消息
            message.acknowledge();
        } catch (Exception e) {
            // 异常时不确认，消息将重回队列
            messageDrivenContext.setRollbackOnly();
        }
    }
}

方案2：容器管理事务（CMT）（更简便） #

若偏好容器管理事务，可依赖事务提交/回滚自动控制消息确认，此时无需手动调用acknowledge()：

@MessageDriven(name = "queueMDB", activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "transactionType", propertyValue = "Container"),
})
@TransactionAttribute(TransactionAttributeType.REQUIRED) // 显式声明事务属性（默认即为REQUIRED）
public class TestMdb implements MessageListener {

    @Resource
    private MessageDrivenContext messageDrivenContext;

    @Override
    public void onMessage(Message message) {
        try {
            // 执行业务逻辑（数据库更新等）
            // Some usefull code...
            
            // 事务自动提交，消息确认
        } catch (Exception e) {
            // 标记事务回滚，消息重回队列
            messageDrivenContext.setRollbackOnly();
        }
    }
}

配套MQ激活规范配置 #

在WAS控制台找到jms/TestQueueAS激活规范，调整以下参数：

• 事务支持：对应选择Bean-Managed（方案1）或Container-Managed（方案2）
• 重新传递尝试次数：设置合理值（如5次），避免消息无限循环
• 回退队列：指定一个队列，用于接收重试失败的消息，便于后续排查
• 消息传递策略：设为Unshared，确保单消息仅被一个MDB实例处理

重要注意事项 #

• 强制停止应用时，只要消息未确认/事务未提交，MQ会自动将消息放回队列，重启后MDB会重新处理
• 业务逻辑必须实现幂等性，因为消息可能被多次投递
• 不同WAS版本的激活规范配置项可能略有差异，需参照对应版本官方文档调整

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