|
此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 spring-cloud-stream 4.1.4！ |
Spring Cloud Stream 参考文档
Spring Cloud Stream 简介
Spring Cloud Stream 是一个用于构建消息驱动微服务应用程序的框架。 Spring Cloud Stream 基于 Spring Boot 构建，用于创建独立的生产级 Spring 应用程序，并使用 Spring 集成提供与消息代理的连接。 它提供了来自多个供应商的中间件的原汁原味的配置，引入了持久发布-订阅语义、消费者组和分区的概念。
通过将依赖项添加到应用程序的 Classpath 中，您可以立即获得连接
传递给由提供的 Binder 公开的消息代理（稍后会详细介绍），您可以实现您的函数
requirement，它由 .spring-cloud-streamspring-cloud-streamjava.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());
}
}