Spring JMS全局ErrorHandler失效问题排查（附配置类代码）

我之前也碰到过Spring JMS全局异常处理器不生效的坑，结合你给出的配置代码片段，大概率是配置环节漏了关键一步，下面给你梳理排查方向和修正方案：

一、先检查配置类的核心遗漏点 #

从你的代码看，你已经注入了自定义的MyProjectJmsGlobalErrorHandler，但很可能没把它绑定到JmsListenerContainerFactory上。这是最常见的原因，修正后的完整配置类应该是这样：

@Configuration
public class MyProjectJmsListenerContainerFactory {

    @Bean
    public JmsListenerContainerFactory<?> myFactory(
            ConnectionFactory connectionFactory,
            DefaultJmsListenerContainerFactoryConfigurer configurer,
            MyProjectJmsGlobalErrorHandler errorHandler) {
        
        DefaultJmsListenerContainerFactory containerFactory = new DefaultJmsListenerContainerFactory();
        
        // 配置ActiveMQ重发策略（你的原有逻辑）
        ActiveMQConnectionFactory activeMQConnectionFactory = (ActiveMQConnectionFactory) connectionFactory;
        RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
        redeliveryPolicy.setMaximumRedeliveries(3); // 示例：设置最大重发3次
        redeliveryPolicy.setInitialRedeliveryDelay(1000); // 1秒后首次重发
        activeMQConnectionFactory.setRedeliveryPolicy(redeliveryPolicy);
        
        // 让Spring自动填充容器工厂的默认配置
        configurer.configure(containerFactory, connectionFactory);
        
        // 关键！把自定义全局ErrorHandler绑定到容器工厂
        containerFactory.setErrorHandler(errorHandler);
        
        return containerFactory;
    }
}

二、确认自定义ErrorHandler的实现正确性 #

你的MyProjectJmsGlobalErrorHandler必须正确实现Spring的ErrorHandler接口，并且被Spring容器管理（比如加@Component注解）：

@Component
public class MyProjectJmsGlobalErrorHandler implements ErrorHandler {
    @Override
    public void handleError(Throwable t) {
        // 这里写你的全局异常处理逻辑：日志记录、告警通知等
        System.err.println("[全局JMS异常处理器] 捕获异常：" + t.getMessage());
        t.printStackTrace();
    }
}

三、排查消息监听器的异常捕获逻辑 #

如果你的@JmsListener方法里用try-catch捕获了所有Throwable，异常不会抛到容器层面，全局ErrorHandler自然不会触发。比如要避免这种写法：

// 错误示例：捕获所有异常，导致全局ErrorHandler失效
@JmsListener(destination = "test-queue", containerFactory = "myFactory")
public void listen(String message) {
    try {
        // 你的业务逻辑
    } catch (Exception e) {
        // 这里如果吞掉了所有异常，容器感知不到
        log.error("处理消息失败", e);
    }
}

正确的做法是：要么只捕获特定业务异常，要么在catch块中重新抛出RuntimeException，让容器能捕获到异常：

// 正确示例：抛出异常给容器处理
@JmsListener(destination = "test-queue", containerFactory = "myFactory")
public void listen(String message) {
    try {
        // 你的业务逻辑
    } catch (BusinessException e) {
        // 处理业务异常，或者直接抛出
        throw new RuntimeException("业务处理失败", e);
    }
}

四、确认监听器指定了正确的容器工厂 #

别忘了在@JmsListener注解里明确指定containerFactory = "myFactory"，否则Spring会使用默认的容器工厂，而默认工厂没有绑定你的自定义ErrorHandler。

五、重发策略对ErrorHandler的影响 #

注意：只有当消息重发达到RedeliveryPolicy设置的最大次数后，才会触发全局ErrorHandler的handleError方法。如果你的重发次数设置得很大，可能需要等重发完成后才能看到效果，可以先把setMaximumRedeliveries设小一点（比如3次）来测试。

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