1、为什么MQ?
异步、削峰、解耦
2、RocketMQ选型及设计
10w级吞吐量、高可用、消息可以0丢失、毫秒级延迟、有活跃的中文社区
3、消息堆积
生产者限速(发送延迟、批量发送大小等,来控制发送速度)。
消费者改逻辑(增加单机线程并发量)、扩容。
Broker扩容、同步刷盘改异步、
对消息进行过滤,只消费关心的消息,减少不必要的消费。丢弃不必要消息。
启用消息重试和死信队列、持效监控
https://juejin.cn/post/7305983336496840714
4、消息丢失
生产者-->Broker
Broker-->消费者
集群消费模式:一个消费者组共同消费一个主题的多个队列,一个队列只会被一个消费者消费
【RocketMQ面试题(23道)】-CSDN博客