如何在Spring Cloud Stream中测试注入了StreamBridge的类？

方案1：使用官方测试绑定器（推荐，可验证消息发送逻辑） #

• 首先确认依赖正确性，你已经引入的test-binder依赖是正确的，需保证${spring.cloud.stream.version}版本 ≥ 3.0.0，低版本不支持该测试绑定器。如果依赖导入后仍然找不到类，可执行mvn clean install强制刷新本地依赖缓存。
• 注意TestChannelBinderConfiguration属于测试依赖的类，仅能在src/test目录下的测试代码中导入，main目录下无法引用。
• 修正注解配置：不需要用@ImportAutoConfiguration，直接在测试类上添加@Import(org.springframework.cloud.stream.test.binder.TestChannelBinderConfiguration.class)即可，配合@SpringBootTest注解启动Spring上下文，会自动注册可用的StreamBridge实例，无需手动Mock。
• 如果需要验证发送的消息内容，可注入MessageCollector实例，绑定对应的目标通道即可获取发送的消息内容做断言。

方案2：手动注册Mock Bean（轻量，无需额外依赖） #

如果不需要验证消息发送逻辑，只需要解决上下文找不到Bean的问题，可直接在测试环境自定义Mock的StreamBridge：

1. 新增测试配置类

@TestConfiguration
public class MockStreamBridgeConfig {
    @Bean
    public StreamBridge streamBridge() {
        return Mockito.mock(StreamBridge.class);
    }
}

2. 在测试类上添加@Import(MockStreamBridgeConfig.class)注解，即可完成StreamBridge的注入，适配静态/非静态字段注入场景。

方案3：解决@MockBean注入静态字段失败问题 #

如果坚持使用@MockBean，但因为业务类用静态字段注入StreamBridge导致Mock不生效，可通过反射手动赋值：

• 在测试类的@BeforeEach方法中添加如下逻辑：

@Mock
private StreamBridge mockStreamBridge;

@BeforeEach
void initStaticStreamBridge() throws NoSuchFieldException, IllegalAccessException {
    // 替换为实际业务类的Class对象、静态字段名
    Field field = YourBusinessClass.class.getDeclaredField("streamBridge");
    field.setAccessible(true);
    field.set(null, mockStreamBridge);
}

测试完成后可在@AfterEach方法中恢复原静态字段值，避免影响其他测试用例。

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