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

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

消费端出了问题，导致消息队列消息积压了很多或者集群的磁盘都快写满了。 解决思路有两个： 1、MQ动态扩容，将MQ容量增大，让其能容纳更多的消息 2、消费端加大消费能力，迅速处理掉积压。 第一个例子： 如果你积压了几百万到上千万的数据，即使消费者恢复了，也需要大概1小时 ...

一、MQ消息发送 　　　　　　　　 　　1、发送端MQ-client(消息生产者：Producer)将消息发送给MQ-server； 　　2、MQ-server将消息落地； 　　3、MQ-server回ACK给MQ-client（Producer）； 　　4、MQ-server将消息 ...

目录 前置知识 实现思路 注意 前置知识 以RocketMQ为例 使用IDR启动RocketMQ，参考Eclpse启动RocketMq 大多数消息中间件都支持固定延时队列，比如RocketMQ支持的默认延时等级 ...

MQ系列1：消息中间件执行原理 MQ系列2：消息中间件的技术选型 MQ系列3：RocketMQ 架构分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的发送模式 MQ系列6：消息的消费 MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障 ...

①消息队列的优缺点 优点:异步解耦和削峰 缺点:系统引入mq之后可能存在的一些问题1系统可用性降低(mq出问题 整个系统就挂了 多了一道环节)2 系统变复杂 考虑的问题变多(如果系统和mq协调出现问题 往里面加了两条一样的数据 或 是消息积压 或是丢消息 )3 一致性的问题:a系统给bcd都执行 ...

如果要你实现一个支付宝向余额宝转账的功能，比如：账户a从支付宝转出5000余额宝转入5000，该怎么做呢？ 可能有些人会说，这还不简单，直接上图 支付宝先给账户a减50 ...