想必大家或多或少都写过消息驱动的代码，它们的模式和实现几乎都是一样的：producer 发送 Message 到消息中间件中，consumer 消费 Message，减轻服务器的压力，达到削峰填谷的效果。但是，我们的代码会与你当前使用的消息中间件存在严重的耦合，导致不能更换中间件或代码不能够实现复用。但是，我们有了 SpringCloud Stream 组件之后，这些耦合和复用性问题就得到了解决，Stream 让我们的代码交互的对象不再是消息中间件，而是 Stream 的统一 API。

1 你写过消息驱动的代码吗？是在什么业务场景下使用的呢？

• 这个场景本身就是『生产者-消费者』模型…
• 这个场景不要求强一致性，只需要达到最终一致性即可…

2 你使用过哪些消息中间件呢？谈谈你对它们的理解？

• Kafka、RocketMQ 是高性能的消息中间件，适合处理大数据量场景…
• Redis 也可以实现消息队列，不过，不适合大规模数据处理…

3 你能总结下 SpringCloud Stream 的应用方法吗？你在工作中会怎样考虑使用呢？

• 对于特定的消息可以建立独立的消息通道…
• 消费分组和消息分区…