原文:面试题:如何保证消息不丢失?处理重复消息?消息有序性?消息堆积处理?

如何保证消息不丢失 就我们市面上常见的消息队列而言,只要配置得当,我们的消息就不会丢。 先来看看这个图, 可以看到一共有三个阶段,分别是生产消息 存储消息和消费消息。我们从这三个阶段分别入手来看看如何确保消息不会丢失。 生产消息 生产者发送消息至Broker,需要处理Broker的响应,不论是同步还是异步发送消息,同步和异步回调都需要做好try catch,妥善的处理响应,如果Broker返回写入 ...

2020-07-23 15:34 0 573 推荐指数:

查看详情

如何处理RabbitMQ 消息堆积消息丢失问题

消息堆积  为什么会产生消息堆积?     大多数是因为Consumer 出问题了,没有及时发现,或者故障恢复需要较长时间,导致大量消息积压在消息队列中。 消息队列堆积会造成什么后果? 消息被丢弃 磁盘满了 海量消息需要处理  解决方案: 增加消费者 ...

Sat Jul 17 19:18:00 CST 2021 0 572
消息队列如何确保消息有序性

要想实现消息有序,需要从 Producer 和 Consumer 两方面来考虑。 首先,Producer 生产消息的时候就必须要有序。 然后,Consumer 消费的时候,也要按顺序来,不能乱。 Producer 有序 像 RabbitMQ 这类普通的消息系统,队列结构简单 ...

Sat May 15 17:34:00 CST 2021 0 239
你知道 Kafka 是如何做到消息有序性

kafka 中的每个 partition 中的消息在写入时都是有序的,而且单独一个 partition 只能由一个消费者去消费,可以在里面保证消息的顺序。但是分区之间的消息是不保证有序的。 ...

Wed May 27 13:33:00 CST 2020 1 1204
rocketMQ的消息堆积如何处理

下游消费系统如果宕机了,导致几百万条消息消息中间件里积压,此时怎么处理?你们线上是否遇到过消息积压的生产故障?如果没遇到过,你考虑一下如何应对?首先要找到是什么原因导致的消息堆积,是Producer太多了,Consumer太少了导致的还是说其他情况,总之先定位问题。然后看下消息消费速度是否正常 ...

Fri Jun 04 04:22:00 CST 2021 0 10880
rocketMQ处理消息堆积

首先要找到原因,是producer太多了,还是说consumer太少了。定位问题,然后看下消息的消费速度是否正常,正常的话,可以通过临时上线更多consumer解决问题。 如果consumer和queue不对等,上线了多台consumer也无法解决的话,可以 准备一个临时 ...

Wed Dec 08 05:38:00 CST 2021 0 909
mq消息堆积处理

1.大量消息在mq里积压 场景:几千万条数据在MQ里积压了七八个小时,从下午4点多,积压到了晚上很晚,10点多,11点多。线上故障了,这个时候要不然就是修复consumer的问题,让他恢复消费速度,然后傻傻的等待几个小时消费完毕。这个肯定不行。一个消费者一秒是1000条,一秒3个消费者是3000 ...

Sat Feb 01 04:50:00 CST 2020 0 4601
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM