RabbitMQ 简介

【简单】RabbitMQ 是什么？⭐

RabbitMQ 是一个开源的消息队列中间件，基于 AMQP（Advanced Message Queuing Protocol，高级消息队列协议）标准实现。

开篇词 为什么要学习 Kafka？

消息引擎系统 ABC

设计消息引擎的关键点：

• 序列化：CSV、XML、JSON、Protocol Buffer、Thrift。Kafka 默认使用纯二进制字节序列
• 传输模型：同时支持点对点模型和发布/订阅模型

Kafka 简介

【简单】Kafka 是什么？⭐

Kafka 是一个开源分布式事件流平台。最初由 LinkedIn 开发，现在是 Apache 顶级项目。

读源代码前的准备

源代码目录结构

• broker：Broker 模块（Broker 启动进程）
• client：消息客户端（生产者、消费者）
• common：公共包
• namesrv：NameServer 实现（NameServer 启动进程）
• remoting：远程通信模块（基于 Netty）
• store：消息存储实现
• tools：工具类、监控命令

RocketMQ 简介

【简单】RocketMQ 是什么？⭐

RocketMQ 是一个开源分布式消息中间件。最初由阿里巴巴开发，现在是 Apache 顶级项目。

RocketMQ 的核心概念

• 核心组件
  • 生产者（Producer）：从 NameServer 获取路由信息后，将消息发送到 Broker。
  • 消费者（Consumer）：从 NameServer 获取路由信息后，从 Broker 拉取并消费消息。
  • 代理（Broker）：负责消息的存储、投递和查询。采用主从结构保证高可用。
  • 命名服务（NameServer）：管理所有 Broker 的地址列表。无状态，简单高效。
• 逻辑存储
  • 主题（Topic）：消息的一级分类，生产者和消费者操作的逻辑对象。
  • 标签（Tag）：Topic 下的二级分类，用于对消息进行过滤。
  • 消息（Message）：包含 Body（消息体）、Topic、Tags（标签）、Keys（唯一键）等属性。
  • 消息队列（Message Queue）：Topic 在物理上的分区，是负载均衡和并行处理的最小单位。
• 物理存储
  • 提交日志（Commit Log）：所有 Topic 的消息都顺序追加到这一个文件中。这是实现高吞吐写入的关键。
  • 消费队列（Consume Queue）：作为 CommitLog 的索引文件。每个 Queue 对应一个，记录消息在 CommitLog 中的位置，实现高效的读取。
  • 索引文件（Index File）：提供按 Message Key 或时间范围查询消息的能力。

📖 内容

• RocketMQ 快速入门 - 关键词：RocketMQ、消息模型、NameServer、Broker、消息类型
• RocketMQ 面试 💯

开篇词

Kafka 源码四大模块：

• 服务器端源码：实现架构和特性
• Java 客户端源码：与 Broker 交互机制
• Connect 源码：与外部系统的数据传输
• Streams 源码：实时流处理

为什么需要消息队列？

核心应用：异步处理、系统解耦、流量削峰、系统间通信、数据缓冲、数据一致性。

该如何选择消息队列？

选型维度：是否开源（能否商用）> 社区活跃度 > 技术生态适配性 > 高可用 > 高性能 > 可靠传输。

简介

ActiveMQ 是 Apache 软件基金会旗下的一个开源消息中间件，由 Java 语言编写。它完全支持 JMS（Java Message Service）规范，提供了企业级的消息传递能力，是早期 Java 生态中最流行的消息中间件之一。

ActiveMQ 主要解决分布式系统中的异步通信、应用解耦、流量削峰、可靠传输等问题。通过引入消息中间件，生产者无需等待消费者处理完毕即可返回，提升了系统的响应速度；同时，生产者和消费者之间的耦合度大大降低，各自可以独立演进和扩展。

ActiveMQ 支持多种语言客户端（Java、C/C++、.NET、Python、Ruby 等），支持多种传输协议（OpenWire、STOMP、MQTT、AMQP 等），既可以作为点对点模型的消息队列使用，也可以作为发布/订阅模型的消息主题使用。它还支持持久化存储（KahaDB、JDBC、LevelDB 等）、消息事务、消息确认机制等企业级特性。

MQ 简介

【简单】MQ 是什么？⭐

MQ（Message Queue，消息队列） 是一种异步通信机制，用于在不同服务、应用或系统组件之间可靠地传递消息。它的核心思想是解耦生产者和消费者，通过缓冲消息来提高系统的可靠性、扩展性和可维护性。

MQ 的核心概念

• 生产者（Producer）：发送消息的应用或服务。
• 消费者（Consumer）：接收并处理消息的应用或服务。
• 消息（Message）：传输的数据单位，可以是文本、JSON、二进制等格式。
• 队列（Queue）：存储消息的缓冲区，遵循 FIFO（先进先出） 或优先级策略。
• Broker（消息代理）：负责接收、存储和转发消息的中间件（如 RabbitMQ、Kafka）。
• 背压：背压是一种消息传递机制中的流控策略。当消费者处理速度跟不上生产者发送速度时，通过反向施加压力，迫使生产者降速或停止发送，以防止系统被压垮。