分类目录归档：消息队列

2026
01-16

RocketMQ 常见错误与解决方案

.... Read More >

2025
12-30

万字长文讲透 RocketMQ 的消费逻辑

RocketMQ 是笔者非常喜欢的消息队列，4.9.X 版本是目前使用最广泛的版本，但它的消费逻辑相对较重，很多同学学习起来没有头绪。 这篇文章，笔者梳理了 RocketMQ 的消费逻辑，希望对大家有所启发。 1 架构概览 在展开集群消费逻辑细节前，我们先对 Rocket.... Read More >

2025
06-04

RocketMQ 4.5 vs RocketMQ 5.0 版本对比

一、架构变化 RocketMQ 5.0 架构上的变化主要是为了更好的走向云原生。 RocketMQ 4.x 架构如下： Broker 向 Name Server 注册 Topic 路由信息，Producer 和 Consumer 则从 Name Server 获取路由信息.... Read More >

2024
10-10

[ RabbitMQ ] 重要知识点备忘录

Rabbitmq 集群异常故障处理流程 1. slave 挂掉 当 slave 挂掉之后，除了与 slave 相连的客户端连接全部断开，没有其他影响。 2. master 挂掉 当 master 挂掉之后，会有以下连锁反应： （1）与 master 连接的客户端连接全.... Read More >

2024
07-05

RabbitMQ 测试方案及结果

RabbitMQ测试方案 Qos：举例说明：Qos=2 如果消费者A 有2个消息没有回应，则MQ不会再往消费者A中发消息，直到收到消息确认后才会再次发送。 Ack：消息确认。 方案1：启动一个生产者，无消费者。 测试结果：每秒生产大约6250条消息，磁盘写入是6250/s，.... Read More >

2024
05-24

[ Kafka ] 重要知识点备忘录

kafka的消费者是pull(拉)还是push(推)模式，这种模式有什么好处？ Kafka 遵循了一种大部分消息系统共同的传统的设计： producer 将消息推送到 broker，consumer 从broker 拉取消息。 优点：pull模式消费者自主决定是否批量从broke.... Read More >

2024
03-01

RabbitMQ避坑01：HAProxy+RabbitMQ 集群报错 Channel shutdown: connection error

一、问题描述 MQ集群具体错误信息： 2018-05-04 11:21:48.116 ERROR 60848 --- [.168.0.202:8001] o.s.a.r.c.CachingConnectionFactory : Channel shutdow.... Read More >