Spring Cloud Stream 參考文件
Spring Cloud Stream 簡介
Spring Cloud Stream 是一個用於構建訊息驅動微服務應用程式的框架。Spring Cloud Stream 基於 Spring Boot 構建獨立的、生產級的 Spring 應用程式，並使用 Spring Integration 提供與訊息代理的連線。它提供了對來自多個供應商的中介軟體的意見化配置，引入了持久釋出-訂閱語義、消費者組和分割槽等概念。
透過將 spring-cloud-stream 依賴項新增到應用程式的類路徑中，您可以立即連線到由提供的 spring-cloud-stream 繫結器（稍後會詳細介紹）公開的訊息代理，並且可以實現您的功能需求，該需求由 java.util.function.Function（根據傳入訊息）執行。
以下清單顯示了一個快速示例
@SpringBootApplication
public class SampleApplication {
public static void main(String[] args) {
SpringApplication.run(SampleApplication.class, args);
}
@Bean
public Function<String, String> uppercase() {
return value -> value.toUpperCase();
}
}以下清單顯示了相應的測試
@SpringBootTest(classes = SampleApplication.class)
@EnableTestBinder
class BootTestStreamApplicationTests {
@Autowired
private InputDestination input;
@Autowired
private OutputDestination output;
@Test
void contextLoads() {
input.send(new GenericMessage<byte[]>("hello".getBytes()));
assertThat(output.receive().getPayload()).isEqualTo("HELLO".getBytes());
}
}
