Spring Cloud Stream（消息驱动）介绍

一、概述 1、发布/订阅 简单的讲就是生产者，消费者模式。发布者是生产者，将数据发布到数据中心，订阅者是消费者，订阅自己感兴趣的数据。当有数据到达数据中心时候，就把数据发送给对应的订阅者。 未处理的传感数据发布到raw-sensor-data的Topic进行广播，Averages 和IngestHDFS同时订阅了此消息，收到消息后触发自身的处理逻辑。 Topic可能对应不同的概念，在RabbitM

>>阅读原文<<