一般的消息中间件(MQ)只能保证消息不丢,但是不能保证重复发送等问题。 比如在使用Rabbitmq过程中,如何保证消息都能正确的投递被消费,这个是要考虑的问题。 那么可靠性投递所面临的问题有哪些? 1. 如果发送的消息重复怎么办。 2. 如果消息发送过程中丢了怎么办。 3. ...
要想保证消息的可靠型投递,无非保证如下 个阶段的正常执行即可: 生产者将消息成功投递到broker broker将投递过程的消息持久化下来 消费者能从broker消费到消息 发送端消息重试 roducer向broker发送消息后,没有收到broker的ack时,rocketmq会自动重试。重试的次数可以设置,默认为 次 DefaultMQProducer producer new DefaultM ...
2022-01-08 08:50 0 991 推荐指数:
一般的消息中间件(MQ)只能保证消息不丢,但是不能保证重复发送等问题。 比如在使用Rabbitmq过程中,如何保证消息都能正确的投递被消费,这个是要考虑的问题。 那么可靠性投递所面临的问题有哪些? 1. 如果发送的消息重复怎么办。 2. 如果消息发送过程中丢了怎么办。 3. ...
消息丢失分成三种情况,可能出现生产者、RabbitMQ、消费者。 生产者丢失数据 首先要确保写入 RabbitMQ 的消息别丢,消息队列通过请求确认机制,保证消息的可靠传输。生产开启 comfirm 模式,在生产者开启 comfirm 模式之后,每次发送消息都会分配一个唯一的id ...
人生终将是场单人旅途,孤独之前是迷茫,孤独过后是成长。 楔子 本篇是消息队列RabbitMQ的第四弹。 RabbitMQ我已经写了三篇了,基础的收发消息和基础的概念我都已经写了,学任何东西都是这样,先基础的上手能用,然后遇到问题再去解决,无法理解就去深入源码,随着时间的积累对这一 ...
目录 生产者丢失消息 代码模拟 事务 confirm模式确实 数据退回监听 MQ事务相关软文推荐 MQ丢失信息 消费者丢失信息 之前我们简单介绍 ...
1.消费端弄丢了数据 唯一可能导致消费者弄丢数据的情况,就是说,你消费到了这个消息,然后消费者那边自动提交了 offset,让 Kafka 以为你已经消费好了这个消息,但其实你才刚准备处理这个消息,你还没处理,你自己就挂了,此时这条消息就丢咯。 这不是跟 RabbitMQ 差不多吗,大家都知道 ...
1、保证消息不丢失(三步)1.1、开启事务(不推荐)1.2、开启confirm(推荐)1.3、开启RabbitMQ持久化(交换机、队列、消息)1.4、关闭RabbitMQ自动ack(改成手动) 2、保证消息不重复消费2.1、幂等性(每个消息用一个唯一标识来区分,消费前先判断标识有没有被消费 ...
一条消费成功被消费经历了生产者->MQ->消费者,因此在这三个步骤中都有可能造成消息丢失。 一 消息生产者没有把消息成功发送到MQ 1.1 事务机制 AMQP协议提供了事务机制,在投递消息时开启事务支持,如果消息投递失败,则回滚事务。 自定义事务管理器 修改yml ...
消息可靠性的保证基本上我们都要从3个方面来阐述(这样才比较全面,无懈可击) 1 生产者发送消息丢失 kafka支持3种方式发送消息,这也是常规的3种方式,发送后不管结果、同步发送、异步发送,基本上所有的消息队列都是这样玩的。 发送并忘记,直接调用发送send方法,不管结果,虽然可以开启自动 ...