如何避免缓存测试上下文中的@Scheduled及消息监听器Bean活跃？

针对你遇到的Spring Boot集成测试中，旧上下文的定时任务、Kafka/JMS监听器持续活跃导致测试不稳定的问题，以下是无需修改生产代码的可行方案：

1. 按需销毁测试上下文 #

使用@DirtiesContext注解标记测试类或方法，让Spring在测试结束后销毁对应的应用上下文，不加入缓存。根据需求选择不同的销毁模式：

• 每个测试方法结束后销毁：@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
• 测试类结束后销毁：@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS)
  这种方式简单直接，但会失去上下文缓存带来的性能优势，适合测试用例不多的场景。

2. 测试环境全局禁用自动启动 #

通过配置属性在测试环境中直接关闭定时任务和监听器的自动启动：

• 禁用定时任务：在src/test/resources/application.yml中添加

  spring:
    scheduling:
      enabled: false
  

• 禁用Kafka监听器：

  spring:
    kafka:
      listener:
        auto-startup: false
  

• 禁用JMS监听器：

  spring:
    jms:
      listener:
        auto-startup: false
  

如果某个测试需要启用这些组件，可以在测试方法中通过对应的注册表手动启动，比如操作KafkaListenerEndpointRegistry启动指定监听器。

3. 用测试配置覆盖生产Bean #

创建测试专用的配置类，替换生产环境中的定时任务或监听器Bean为无实际逻辑的测试实现：

@TestConfiguration
public class TestTaskOverrideConfig {

    @Bean
    @Primary
    public InventorySyncTask inventorySyncTask() {
        // 返回空实现，避免定时执行生产逻辑
        return new InventorySyncTask() {
            @Override
            public void syncInventory() {
                // 测试环境不执行同步操作
            }
        };
    }
}

在需要覆盖的测试类上通过@Import(TestTaskOverrideConfig.class)引入该配置，Spring会优先使用测试Bean替代生产Bean。

4. 自定义JUnit 5扩展管理组件状态 #

编写JUnit 5扩展，在测试前后自动控制监听器和定时任务的启停，无需修改生产代码：

public class TestComponentLifecycleExtension implements BeforeEachCallback, AfterEachCallback {

    @Override
    public void beforeEach(ExtensionContext context) {
        ApplicationContext appContext = SpringExtension.getApplicationContext(context);
        // 测试开始时启动需要的监听器（可选）
        KafkaListenerEndpointRegistry kafkaRegistry = appContext.getBean(KafkaListenerEndpointRegistry.class);
        kafkaRegistry.start();
    }

    @Override
    public void afterEach(ExtensionContext context) {
        ApplicationContext appContext = SpringExtension.getApplicationContext(context);
        
        // 停止Kafka监听器
        KafkaListenerEndpointRegistry kafkaRegistry = appContext.getBean(KafkaListenerEndpointRegistry.class);
        kafkaRegistry.stop();
        
        // 取消所有定时任务
        TaskScheduler scheduler = appContext.getBean(TaskScheduler.class);
        scheduler.getScheduledTasks().forEach(task -> task.cancel(true));
    }
}

在测试类上添加@ExtendWith(TestComponentLifecycleExtension.class)，即可自动在每个测试前后清理后台组件，避免旧上下文的组件干扰当前测试。

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