kafka基本结构和特性

发布和订阅 使用原因 1、解耦，可以确保两个系统互不干扰 2、冗余，消息队列把数据进行持久化直到它们已经被完全处理，通过这一方式规避了数据丢失风险。许多消息队列采用的”插入-获取-删除”范式，确保处理数据过程失败后不会数据丢失 3、扩展性，增大消息入队和处理是先对容易的 4、峰值处理能力，在访问量剧增的情况下，可以在不增加机器的情况下确保系统的稳定运行 5、可恢复性，即使一个处理消息的进程挂掉，加

>>阅读原文<<