缓冲和削峰 :上游数据时有突发流量,下游可能扛不住,或者下游没有⾜够多的机器来保证冗余, kafka在中间可以起到⼀个缓冲的作⽤,把消息暂存在kafka中,下游服务就可以按照⾃⼰的节奏进⾏慢慢处理。
解耦和扩展性 :项⽬开始的时候,并不能确定具体需求。消息队列可以作为⼀个接⼝层,解耦重要的业务流程。只需要遵守约定,针对数据编程即可获取扩展能⼒。冗余 :可以采⽤⼀对多的⽅式,⼀个⽣产者发布消息,可以被多个订阅topic的服务消费到,供多个毫⽆关联的业务使⽤。健壮性 :消息队列可以堆积请求,所以消费端业务即使短时间死掉,也不会影响主要业务的正常进⾏。异步通信 :很多时候,⽤户不想也不需要⽴即处理消息。消息队列提供了异步处理机制,允许⽤户把⼀个消息放⼊队列, 但并不⽴即处理它。想向队列中放⼊多少消息就放多少,然后在需要的时候再去处理它们。
🚀 为什么使用消息队列?为什么选择Kafka?—— 现代系统架构的核心支柱
从系统解耦到实时流处理,深入解析消息队列的核心价值及Kafka的不可替代性,附典型场景和选型对比。
1. 🌉 消息队列的六大核心价值
价值
说明
典型场景
系统解耦
生产者和消费者无需相互感知
订单系统与库存系统的异步通信
削峰填谷
缓冲突发流量,避免系统过载
秒杀活动中的请求排队
异步处理