使用Spring Cloud Test测试Spring Cloud Streams

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-test</artifactId>
    <scope>test</scope>
</dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-test-support</artifactId>
    <scope>test</scope>
</dependency>

@SpringBootTest
public class MyStreamApplicationTests {

    @Test
    public void testStream() {
        // 测试代码
    }

}

@SpringBootTest
@EnableBinding(MyStreamProcessor.class)
public class MyStreamApplicationTests {

    @Autowired
    private MyStreamProcessor myStreamProcessor;

    @Test
    public void testStream() {
        // 模拟发送消息
        myStreamProcessor.output().send(MessageBuilder.withPayload("Hello").build());

        // 模拟接收消息
        Message<String> message = myStreamProcessor.input().receive();
        String payload = message.getPayload();

        // 断言
        assertEquals("Hello", payload);
    }

    @MockBean
    private MyStreamProcessor myStreamProcessor;

}