消息系统使用场景

解耦：各位系统之间通过消息系统这个统一的接口交换数据，无须了解彼此的存在。
冗余：部分消息系统具有消息持久化能力，可规避消息处理前丢失的风险。
扩展：消息系统是统一的数据接口，可系统可独立扩展。
峰值处理能力：消息系统可顶住峰值流量，业务系统可根据处理能力从消息系统中获取并处理对应量的请求。
可恢复性：系统中部分组件失效并不会影响整个系统，它恢复后仍然可从消息系统中获取并处理数据。
异步通信：在不需要立即处理请求的场景下，可以将请求放入消息系统，合适的时候再处理。

常用消息系统对比

Kafka设计目标

高吞吐率：在廉价的商用机器上单机可支持每秒100万条消息的读写。
消息持久化：所有消息均被持久化到磁盘，无消息丢失，支持消息重放。
完全分布式：Producer，Broker，Consumer均支持水平扩展。
同时满足适应在线流处理和离线批处理