rocketmq 文档

RocketMQ 是阿里巴巴开源的一款分布式消息中间件，它在大规模分布式系统中扮演着重要的角色，用于处理高并发、低延迟的消息传递。RocketMQ 提供了可靠的消息传输和大规模数据处理能力，广泛应用于电子商务、金融、物联网等领域。以下是 RocketMQ 的主要知识点： 1. **消息模型**： - **点对点（P2P）模型**：RocketMQ 支持队列模型，消费者可以从队列中拉取消息，每个消息只能被一个消费者消费。 - **发布/订阅（Pub/Sub）模型**：消息发送到主题，多个订阅者可以订阅同一个主题并接收消息。 2. **消息类型**： - **普通消息**：最基本的单条消息。 - **顺序消息**：保证消息的严格顺序，常用于金融交易等场景。 - **定时/延时消息**：消息可以在指定时间后投递，用于实现定时任务或延迟操作。 - **事务消息**：提供分布式事务的一致性，确保消息发送与业务操作的原子性。 3. **消息队列与 Topic**： - **Topic**：消息的主题，类似于分类，多个消费者组可以订阅同一个 Topic。 - **Queue**：消息队列，每个 Topic 下可以有多个队列，队列是实际存储消息的地方。 4. **Producer**： - 生产者负责发送消息到 RocketMQ 服务器，可以配置为同步或异步发送。 - 发送模式包括：Oneway、Normal、Batch。 5. **Consumer**： - 消费者订阅 Topic 并消费消息，分为集群消费和广播消费。 - 集群消费：多台消费者实例分担消费，消息仅被一个消费者消费。 - 广播消费：所有消费者实例都会收到每条消息。 6. **NameServer**： - 负责管理 Topic 和 Broker 之间的映射关系，提供服务发现功能。 - NameServer 采用无状态设计，可集群部署，提高可用性。 7. **Broker**： - 存储和转发消息，负责实际的消息持久化和投递。 - 分为 Master 和 Slave，Master 用于写入，Slave 用于备份，实现高可用。 8. **Pull & Push 模式**： - **Pull**：消费者主动拉取消息。 - **Push**：消费者注册消费策略，由 Broker 根据策略推消息。 9. **消息过滤**： - 支持基于 Tag 的消息过滤，方便在消费者端进行消息筛选。 10. **监控与管理**： - 提供监控工具和管理控制台，用于查看消息发送、消费情况，监控系统性能。 - 支持通过 JMX 进行远程管理和监控。 11. **扩展性**： - RocketMQ 设计为水平扩展，可以通过增加 Broker 实例来提高吞吐量和存储容量。 12. **高可用与容错**： - 通过 Master-Slave 结构实现数据冗余，保障数据安全。 - 利用 Pull/Push 机制和重试队列保证消息至少被消费一次。 以上是对 RocketMQ 的核心知识点的概述，实际使用中还需要根据具体业务场景进行详细配置和优化。文档中将涵盖更多细节，如集群搭建、API 使用、性能调优等方面的内容，帮助开发者更好地理解和应用 RocketMQ。