Spring Boot集成测试替换全局Bean为Mock后方法调用验证失败问题

核心问题结论 #

完全可以在Spring全上下文中全局替换指定Bean为Mock对象，同时保证测试类和所有业务组件注入的是同一个Mock实例。

问题根因分析 #

第一阶段（@MockBean实例不一致） #

你在测试子类单独加@MockBean会触发Spring测试上下文重新加载，和父类的上下文不是同一个缓存实例，导致UserEventSQSListener里注入的是旧上下文的原始Bean，测试类里拿到的是新上下文的Mock实例，自然验证不到调用。

第二阶段（反射替换后仍验证失败） #

你把反射替换KeycloakService的逻辑放在了接口调用之后，此时接口触发的SQS事件已经被Listener消费了，Listener用的还是替换前的实例，你替换后的Mock根本没有被调用的机会，所以验证失败。

正确解决方案 #

方案1：全局统一声明MockBean（推荐） #

删掉自定义的TestBeanConfig，也删除所有反射替换逻辑，直接在抽象测试父类中声明@MockBean，保证所有继承该父类的测试用例共享同一个上下文，所有组件注入的都是同一个Mock实例：

@Transactional
@Testcontainers
@ActiveProfiles("it")
@AutoConfigureMockMvc
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.MOCK)
@ContextConfiguration(initializers = PostgresITConfig.DockerPostgreDataSourceInitializer.class, classes = {AwsITConfig.class})
public class AbstractSpringIntegrationTest {
    @Autowired
    public MockMvc mockMvc;
    @Autowired
    public AmazonSQSAsync amazonSQS;
    // 全局替换KeycloakService为Mock实例
    @MockBean
    public KeycloakService keycloakService;
}

子类测试代码无需再单独声明@MockBean，直接使用父类的keycloakService做验证即可。

方案2：调整反射替换时机 #

如果你坚持要在子类单独维护Mock实例，只需要把反射替换逻辑移到接口调用之前即可：

@ParameterizedTest
@ValueSource(booleans = {true, false})
void changeUserStatus_shouldEnableOrDisableTheUser(boolean enabled) throws Exception {
    // 先替换Listener里的依赖
    ReflectionTestUtils.setField(userEventSQSListener, "keycloakService", keycloakService);
    assertThat(userEventSQSListener.getKeycloakService()).isEqualTo(keycloakService);
    
    // 再调用接口触发业务逻辑和SQS消息投递
    ChangeUserStatusRequest request = new ChangeUserStatusRequest()
            .setEnabled(enabled);
    String responseString = mockMvc.perform(patch(USERS_BASE_URL + "/{id}/status", id)
                    .contentType(APPLICATION_JSON)
                    .content(objectMapper.writeValueAsString(request)))
            .andExpect(status().isOk())
            .andReturn()
            .getResponse()
            .getContentAsString();
    // 后续断言和验证
    await().atMost(10, SECONDS)
            .untilAsserted(() -> verify(keycloakService).changeUserStatus(anyString(), anyBoolean()));
}

额外排查点 #

如果修改后仍然验证失败，可在UserEventSQSListener的handleUserStatusChangedEvent方法中添加日志/断点，确认SQS消息确实被投递到了该方法，排除Localstack配置错误、队列名不匹配、消息序列化失败等问题。

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