如何立即终止Spring JmsListener执行并实现JMS Session回滚？

关于回滚异常的疑问 #

你遇到的回滚异常大多是预期内的正常现象。当你主动中断正在处理消息的线程时，JMS容器在尝试回滚Session的过程中，会捕获到线程中断信号或者Session状态变更的异常（比如Session已被关闭），这类异常不会导致消息丢失（你已经确认消息留在队列中），所以不需要额外处理——如果日志太吵，甚至可以在日志配置里过滤掉这类中断或Session状态相关的JMS异常。

更平滑的实现方式（替代定时监听中断） #

Spring的JMS监听容器本身提供了原生的停止控制机制，不需要自己写定时任务去中断线程，推荐以下几种方式：

1. 配置容器的停止超时与接收超时 #

如果使用的是DefaultMessageListenerContainer（Spring默认的JMS容器），可以通过以下配置让容器更优雅地响应停止指令：

@Bean
public DefaultMessageListenerContainer oracleAQListenerContainer(ConnectionFactory connectionFactory) {
    DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setDestinationName("YOUR_ORACLE_AQ_QUEUE");
    container.setMessageListener(this::listenMessage); // 绑定你的listenMessage方法
    // 短接收超时：让容器在空闲时快速响应停止信号
    container.setReceiveTimeout(1000);
    // 停止超时：设置容器等待消息处理线程终止的最长时间，超时后强制中断
    container.setStopTimeout(2000);
    // 使用支持中断的线程池（可选，默认线程池也支持）
    container.setTaskExecutor(Executors.newCachedThreadPool());
    return container;
}

2. 在listenMessage方法中响应中断 #

让你的消息处理方法主动检查线程中断状态，这样容器停止时可以快速终止处理并触发回滚：

@JmsListener(destination = "YOUR_ORACLE_AQ_QUEUE", containerFactory = "oracleAQListenerContainer")
public void listenMessage(Message message) throws JMSException {
    try {
        // 业务处理逻辑，每隔一段时间检查中断状态
        if (Thread.currentThread().isInterrupted()) {
            throw new InterruptedException("Listener thread interrupted during message processing");
        }
        // 你的业务代码...
    } catch (InterruptedException e) {
        // 重置中断状态，让容器正确捕获并触发回滚
        Thread.currentThread().interrupt();
        // 抛出运行时异常，触发容器的回滚逻辑
        throw new RuntimeException("Message processing interrupted, rolling back", e);
    }
}

3. 调用容器的带超时停止方法 #

通过JmsListenerEndpointRegistry获取容器，调用带超时的stop方法，容器会自动处理线程中断和Session回滚：

@Autowired
private JmsListenerEndpointRegistry jmsListenerEndpointRegistry;

public void stopAQListener() {
    MessageListenerContainer container = jmsListenerEndpointRegistry.getListenerContainer("yourListenerId");
    if (container != null) {
        // 设置停止超时，超时后容器会强制中断处理线程
        container.stop(Duration.ofSeconds(2));
    }
}

4. 自定义错误处理忽略预期异常 #

如果还是担心日志里的异常，可以实现ErrorHandler过滤中断相关的异常：

@Bean
public ErrorHandler jmsErrorHandler() {
    return t -> {
        // 判断是否是中断或Session关闭导致的预期异常
        if (t instanceof InterruptedException || 
            (t.getCause() instanceof JMSException && 
             ((JMSException) t.getCause()).getErrorCode().equals("SESSION_CLOSED"))) {
            // 忽略这类预期异常，或者只打印DEBUG级别日志
            log.debug("Expected exception during listener stop: {}", t.getMessage());
        } else {
            // 处理其他异常
            log.error("Unexpected JMS listener error", t);
        }
    };
}

把这个ErrorHandler绑定到容器上：

container.setErrorHandler(jmsErrorHandler());

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