该版本仍在开发中,尚未被视为稳定。对于最新稳定版本,请使用 spring-cloud-stream 5.0.0!spring-doc.cadn.net.cn

绑定

如前所述,绑定为外部消息系统(如队列、主题等)与应用提供的生产者消费者之间提供了桥梁。spring-doc.cadn.net.cn

以下示例展示了一个完全配置且运行正常的 Spring Cloud Stream 应用,该应用接收了消息的有效载荷 作为字符串输入(见内容类型协商部分),将其日志记录到控制台,并在转换为大写后发送下游。spring-doc.cadn.net.cn

@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的类型提供商,功能消费者被视为事实上的消息处理程序,触发 绑定到由提供绑定器暴露的目的地,遵循特定的命名规范 和 避免额外配置的规则。spring-doc.cadn.net.cn