一、RabbitMQ 1）生产者弄丢了数据 　　生产者将数据发送到rabbitmq的时候，可能因为网络问题导致数据就在半路给搞丢了。 1.可以选择用rabbitmq提供的事务功能，在生产者发送数据之前开启rabbitmq事务（channel.txSelect），然后发送 ...

消息队列 - 关于消息队列的消息丢失问题的一点思考 　　 　　使用消息中间件必须面对的两大问题 - 消息丢失 和 消息重复。 　　 消息丢失的解决办法主要是通过消息重发的补偿手段，消息重发后导致消息重复，消息重复需要使用幂等解决。 　　　 　　消息从生产到消费，一般需要 ...

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

大家好，我是 yes。 最近我一直扎在消息队列实现细节之中无法自拔，已经写了 3 篇Kafka源码分析，还剩很多没肝完。之前还存着RocketMQ源码分析还没整理。今儿暂时先跳出来盘一盘大方向上的消息队列有哪些核心注意点。 核心点有很多，为了更贴合实际场景，我从常见的面试问题入手 ...

RabbitMQ 生产者弄丢了数据 　　生产者将数据发送到RabbitMQ的时候，可能数据就在半路给搞丢了，因为网络啥的问题，都有可能。 　　此时可以选择用RabbitMQ提供的事务功能，就是生产者发送数据之前开启RabbitMQ事务（channel.txSelect ...

消息队列防止消息不丢失 1、 生产者发送消息到broker失败；生产者使用事务消息。 2、 Broker集群主从同步失败；两阶段提交，多数节点成功后提交。 3、 MQ异步刷盘，可能会消息丢失；改为同步刷盘。 4、 Broker发送消息到消费者失败；消费者ack机制。 5、 MQ集群 ...

使用消息队列，绕不开的一个问题就是如何保证消息不丢失，现在主流的消息中间件都提供了完整的消息可靠性保证机制，可以确保消息的可靠传递，本文以rocketMq为例介绍如何保证消息不丢失，其他消息队列类似。原文地址 消息传递过程 基本上所有的消息都划分为三个阶段生产、存储、消费，如下图 ...

一、消息重复现象 　　在 MQTT 协议中，给出了三种传递消息时能够提供的服务质量标准： At most once:最多一次，这种情况会丢失部分数据，一般日志收集这种对数据不严格的可以使用 At least once:最少一次，这种会导致一条消息重复 ...