|
该版本仍在开发中,尚未被视为稳定。对于最新稳定版本,请使用 spring-cloud-stream 5.0.0! |
绑定
如前所述,绑定为外部消息系统(如队列、主题等)与应用提供的生产者和消费者之间提供了桥梁。
以下示例展示了一个完全配置且运行正常的 Spring Cloud Stream 应用,该应用接收了消息的有效载荷
作为字符串输入(见内容类型协商部分),将其日志记录到控制台,并在转换为大写后发送下游。
@SpringBootApplication
public class SampleApplication {
public static void main(String[] args) {
SpringApplication.run(SampleApplication.class, args);
}
@Bean
public Function<String, String> uppercase() {
return value -> {
System.out.println("Received: " + value);
return value.toUpperCase();
};
}
}
上面的例子看起来和普通的Spring Boot应用没什么不同。它定义了一种类型的单一豆子功能就这些。那么,它是如何成为一个春季云流应用的呢?
它之所以成为一个春云流应用,仅仅是因为存在Spring云流和绑定器依赖关系
以及在类路径上设置自动配置类,有效地将启动应用的上下文设置为 Spring-cloud-stream 应用。
在这个语境下,Beans的类型提供商,功能或消费者被视为事实上的消息处理程序,触发
绑定到由提供绑定器暴露的目的地,遵循特定的命名规范 和
避免额外配置的规则。