上篇文章我们分析完RocketMQ发送消息的原理，得到结果客户端会通过RPC组件向Broker进行通信

上篇文章主要介绍消息中间件并以RocketMQ架构展开描述其核心组件以及MQ运行流程

在队列的基础上，加入生产者与消费者模型，使用队列作为载体就能够组成简单的消息队列，在队列中“运输”的数据被称为消息

官方文档: https://rocketmq.apache.org/zh/docs/introduction/02concepts

有了NameServer,生产者和消费者只需要通过NameServer建立连接无需关心BrokerServer.类似Spring Cloud中注册中心和服务之间...

1、启动NameServer 安装完RocketMQ包后，我们启动NameServer

当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发RocketMQ等。

消息队列是一种中间件，它的作用类似于一个电子邮箱。在这个模型中，生产者（应用程序）生成消息，就像发送邮件一样，而消费者（另一个应用程序）则接收这些消息。消息队列...

消费幂等是指：当出现 RocketMQ 消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响。

“分享RocketMQ5.X Pop，Ack源码解读。内容较多建议PC上对照代码查看，手机你可能会晕”

MQ（消息队列）是一种FIFO（先进先出）的数据结构，主要用于实现异步通信、削峰平谷和解耦等功能。它通过将生产者生成的消息发送到队列中，然后由消费者进行消费。这...

🌊 关注我不迷路，如果本篇文章对你有所帮助，或者你有什么疑问，欢迎在评论区留言，我一般看到都会回复的。大家点赞支持一下哟~ 💗

当出现 RocketMQ 消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这个消费者的...

订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例所订阅的 Topic 、Tag 必须完全一致。

RocketMQ5.0中的几个角色NameServer、Broker 和 Proxy，它们的作用如下：

这篇文章我们聊聊广播消费，因为广播消费在某些场景下真的有奇效。笔者会从基础概念、实现机制、实战案例、注意事项四个方面一一展开，希望能帮助到大家。

Disruptor 是英国外汇交易公司 LMAX 开发的一个高性能队列。很多知名开源项目里，比如 canal 、log4j2、 storm 都是用了 Disru...

canal 是阿里知名的开源项目，主要用途是基于 MySQL 数据库增量日志解析，提供增量数据订阅和消费。