Spring Cloud Stream 知识点

发布-订阅模式

在Spring Cloud Stream中的消息通讯方式遵循了发布-订阅模式，当一条消息被投递到消息中间件以后，它会经过共享的Topic主题进行广播，消息消费者在订阅的主题中收到它并触发自身的业务逻辑处理。这里所提到的Topic主题是Spring Cloud Stream中的一个抽象概念，用来表明发布共享消息给消费者的地方。在不一样的消息中间件中，Topic可能对应着不一样的概念，好比：在RabbitMQ中的它对应了Exchange、而在Kakfa中则对应了Kafka中的Topic。

经过RabbitMQ的 Channel 发布消息给咱们编写的应用程序消费，而实际上Spring Cloud Stream应用启动的时候，在RabbitMQ的Exchange中也建立了一个名为input的Exchange交换器，因为Binder的隔离做用，应用程序并没有法感知它的存在，应用程序只知道本身指向Binder的输入或是输出通道。为了直观的感觉发布-订阅模式中，消息是如何被分发到多个订阅者的，咱们可使用快速入门的例子，经过命令行的方式启动两个不一样端口的进程。此时，咱们在RabbitMQ控制页面的Channels标签页中看到以下图所示的两个消息通道，它们分别绑定了启动的两个应用程序。

咱们启动的两个应用程序分别是“订阅者-1”和“订阅者-2”，他们都创建了一条输入通道绑定到同一个Topic（RabbitMQ的Exchange）上。当该Topic中有消息发布进来后，链接到该Topic上的全部订阅者能够收到该消息并根据自身的需求进行消费操做。

相对于点对点队列实现的消息通讯来讲，Spring Cloud Stream采用的发布-订阅模式能够有效的下降消息生产者与消费者之间的耦合，当咱们须要对同一类消息增长一种处理方式时，只须要增长一个应用程序并将输入通道绑定到既有的Topic中就能够实现功能的扩展，而不须要改变原来已经实现的任何内容。

消费组

虽然Spring Cloud Stream经过发布-订阅模式将消息生产者与消费者作了很好的解耦，基于相同主题的消费者能够轻松的进行扩展，可是这些扩展都是针对不一样的应用实例而言的，在现实的微服务架构中，咱们每个微服务应用为了实现高可用和负载均衡，实际上都会部署多个实例。不少状况下，消息生产者发送消息给某个具体微服务时，只但愿被消费一次，按照上面咱们启动两个应用的例子，虽然它们同属一个应用，可是这个消息出现了被重复消费两次的状况。为了解决这个问题，在Spring Cloud Stream中提供了消费组的概念。

若是在同一个主题上的应用须要启动多个实例的时候，咱们能够经过spring.cloud.stream.bindings.input.group属性为应用指定一个组名，这样这个应用的多个实例在接收到消息的时候，只会有一个成员真正的收到消息并进行处理。

默认状况下，当咱们没有为应用指定消费组的时候，Spring Cloud Stream会为其分配一个独立的匿名消费组。因此，若是同一主题下全部的应用都没有指定消费组的时候，当有消息被发布以后，全部的应用都会对其进行消费，由于它们各自都属于一个独立的组中。大部分状况下，咱们在建立Spring Cloud Stream应用的时候，建议最好为其指定一个消费组，以防止对消息的重复处理，除非该行为须要这样作（好比：刷新全部实例的配置等）。

消息分区

经过引入消费组的概念，咱们已经可以在多实例的状况下，保障每一个消息只被组内一个实例进行消费。经过上面对消费组参数设置后的实验，咱们能够观察到，消费组并没有法控制消息具体被哪一个实例消费。也就是说，对于同一条消息，它屡次到达以后多是由不一样的实例进行消费的。可是对于一些业务场景，就须要对于一些具备相同特征的消息每次均可以被同一个消费实例处理，好比：一些用于监控服务，为了统计某段时间内消息生产者发送的报告内容，监控服务须要在自身内容聚合这些数据，那么消息生产者能够为消息增长一个固有的特征ID来进行分区，使得拥有这些ID的消息每次都能被发送到一个特定的实例上实现累计统计的效果，不然这些数据就会分散到各个不一样的节点致使监控结果不一致的状况。而分区概念的引入就是为了解决这样的问题：当生产者将消息数据发送给多个消费者实例时，保证拥有共同特征的消息数据始终是由同一个消费者实例接收和处理。

Spring Cloud Stream为分区提供了通用的抽象实现，用来在消息中间件的上层实现分区处理，因此它对于消息中间件自身是否实现了消息分区并不关心，这使得Spring Cloud Stream为不具有分区功能的消息中间件也增长了分区功能扩展。

以上出处：http://blog.didispace.com/spring-cloud-starter-dalston-7-2/

• 将输入通道 input 的目标设置为 raw-sensor-data 主题
  将spring.cloud.stream.bindings.input.destination设置成raw-sensor-data，程序会从命名为raw-sensor-data的kafka主题中读取数据，或者从一个绑定到raw-sensor-data的rabbitmq交换机的队列中读取数据

spring.cloud.stream.bindings.input.destination=raw-sensor-data

spring.cloud.stream.bindings. .destination= ：绑定中间件的destination (e.g., the RabbitMQ exchange or Kafka topic)。若是channel绑定的是消费者，那么能够绑定多个destination，用逗号分隔。若是不设置则channel名称会替代这个值。