首页 > 其他 > 详细

MQ在高并发环境下,如果队列满了,如何防止消息丢失?

时间:2019-02-16 13:14:50      阅读:386      评论:0      收藏:0      [点我收藏+]

1、为什么MQ能解决高并发环境下的消息堆积问题?

技术分享图片

MQ消息如果堆积,消费者不会立马消费所有的消息,不具有实时性,所以可以解决高并发的问题。

性能比较好的消息中间件:Kafka、RabbitMQ,RocketMQ.

2、什么情况下会产生消息丢失的现象?

消息队列满了的情况下。

3、如何解决消息丢失的问题?

(1)生产者可以采用重试机制。因为消费者会不停的消费消息,可以重试将消息放入队列。

如果还是不行,可以将消息记录到数据库,后期做补偿。(不太推荐,不方便)

(2)死信队列,可以理解为备胎。(推荐使用)

即在消息过期,队列满了,消息被拒绝的时候,都可以扔给死信队列。

如果出现死信队列和普通队列都满的情况,此时考虑消费者消费能力不足,可以对消费者开多线程进行处理。

技术分享图片

最后:谢谢蚂蚁课堂老师的讲解。

 

MQ在高并发环境下,如果队列满了,如何防止消息丢失?

原文:https://www.cnblogs.com/fengli9998/p/10387323.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!