Spring Cloud（11）——基于RocketMQ的Stream实现

Posted 2022-06-25 elim168

基于RocketMQ的Stream实现

Spring Cloud Stream是一个消息收发的框架，它提供了一套标准，应用程序只需要按照它的标准进行消息的收发，而不用关注具体的实现机制。具体的实现可以基于不同的消息中间件进行不同的实现，比如Kafka的实现、RabbitMQ的实现、RocketMQ的实现等。官方已经提供了Kafka和RabbitMQ的实现，RocketMQ的实现由Alibaba负责。本文将基于RocketMQ的实现进行讲解。

Binder和Binding

org.springframework.cloud.stream.binder.Binder是Spring Cloud对消息容器的抽象，不同的消息容器有不同的实现，通过它可以屏蔽各消息容器的内部细节。

public interface Binder<T, C extends ConsumerProperties, P extends ProducerProperties