Spring Cloud Stream 3.1.3 Function生产者单元测试收不到消息如何解决

问题核心原因 #

1. 上下文不互通：你已使用@SpringBootTest初始化了一个应用上下文，又在测试方法内手动启动了独立的新上下文，两者的Bean完全隔离。你自动注入的Producer属于@SpringBootTest的上下文实例，调用produce方法发送的消息只会进入该上下文的通道，从新上下文获取的OutputDestination自然收不到数据。
2. 无超时等待：OutputDestination.receive()无参方法默认超时时间极短，消息还未完成处理就会返回null。
3. 未指定绑定名：未显式指定要接收的输出绑定名称，可能无法匹配到produceMessage对应的输出通道。

调整方案 #

方案一：移除@SpringBootTest，完全基于手动上下文测试 #

所有Bean统一从手动启动的测试上下文获取，避免上下文隔离问题：

class ProducerTest {
    private final ObjectMapper objectMapper = new ObjectMapper();

    @Test
    void produceOk() {
        try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration.getCompleteConfiguration(Producer.class)).run()) {
            // 从当前测试上下文获取Producer实例
            Producer producer = context.getBean(Producer.class);
            producer.produce(1, new MyMessage(1, "Hello"));
            
            OutputDestination output = context.getBean(OutputDestination.class);
            // 指定输出绑定名+1000ms超时，等待消息处理完成
            Message<byte[]> received = output.receive(1000, "produceMessage-out-0");

            Assertions.assertNotNull(received);
            // 可选扩展断言：校验消息内容和头信息
            MyMessage payload = objectMapper.readValue(received.getPayload(), MyMessage.class);
            Assertions.assertEquals("Hello", payload.getContent());
            Assertions.assertEquals("MyMessage", received.getHeaders().get("type"));
       }
    }
}

方案二：保留@SpringBootTest，整合测试Binder #

直接在@SpringBootTest中引入测试通道Binder，不用手动启动新上下文：

@SpringBootTest
@Import(TestChannelBinderConfiguration.class)
class ProducerTest {
    @Autowired
    private Producer producer;
    @Autowired
    private OutputDestination output;
    @Autowired
    private ObjectMapper objectMapper;

    @Test
    void produceOk() {
        producer.produce(1, new MyMessage(1, "Hello"));
        Message<byte[]> received = output.receive(1000, "produceMessage-out-0");
        
        Assertions.assertNotNull(received);
        // 可选扩展断言
        MyMessage payload = objectMapper.readValue(received.getPayload(), MyMessage.class);
        Assertions.assertEquals("Hello", payload.getContent());
        Assertions.assertEquals("MyMessage", received.getHeaders().get("type"));
   }
}

额外注意 #

请确认你的application.yaml中存在正确的函数定义配置：

spring:
  cloud:
    function:
      definition: produceMessage

没有该配置的话Function不会被框架自动注册绑定，消息也无法正常流转。

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