|
该版本仍在开发中，尚未被视为稳定。对于最新稳定版本，请使用 spring-cloud-stream 5.0.0！ |
春云溪流参考文档
春云溪介绍
Spring Cloud Stream 是一个用于构建消息驱动微服务应用的框架。 Spring Cloud Stream 基于 Spring Boot 构建独立的生产级 Spring 应用程序，并使用 Spring 集成实现与消息代理的连接。 它提供了多个厂商的中间件配置，介绍了持久发布-订阅语义、消费者组和分区的概念。
加入春云溪流依赖于你的应用类路径，你就能立即实现连接
到由所提供的消息代理暴露春云溪流绑定器（稍后会详细说），你可以实现函数式
需求，该需求由一个java.util.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());
}
}