当前位置:   article > 正文

RabbitMq如何保证消息不丢失

rabbitmq如何保证消息不丢

rabbitMq在由于网络传输的不稳定因素,在以下四点可能出现消息丢失的情况。

针对于第1点:

1、消息发送+回调。

2、采用事务的方式chanle.txSelect(),但是会阻塞通道,造成吞吐量下降。

3、publisher confirm方式,采用RocketMQ的思想,分布式事务,也是RabbitMq新版本的扩展点。

针对于第2点:

1、使用镜像队列,rabbitMq普通集群每一个节点之间的数据是不会同步的,自己存自己的,当消费者消费消息在某个几点找不到时,就会去其他的节点同步数据返回给消费者。使用镜像队列,就会把所有节点的数据都同步之后才会返回生产者成功,保证消息分布在各个节点。

针对于第3点:

1、开启消息持久化。

 针对于第4点:

1、关闭自动消费确认,改成手动ACK确认。

保证RabbitMq消息消费顺序

一个交换机对应一个队列,一个队列对应一个消费者,即可保证mq消息的顺序消费。但影响性能。

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/不正经/article/detail/513159
推荐阅读
相关标签
  

闽ICP备14008679号