春云溪流参考文档
春云溪介绍
Spring Cloud Stream 是一个用于构建消息驱动微服务应用的框架。Spring Cloud Stream 基于 Spring Boot 构建独立的生产级 Spring 应用，并使用 Spring Integration 提供与消息代理的连接。它提供了多个厂商中间件的主观配置，引入了持久发布-订阅语义、消费者组和分区的概念。
加入春云溪流依赖于你的应用类路径，你会立即获得连接与由所提供的消息代理暴露的春云溪流Binder（后面会详细说），你可以实现你的函数式需求，这个需求由（基于收到的消息）执行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());
}
}