目 录CONTENT
以下是
RocketMQ
相关的文章
-
-
RocketMQ—存储、检索、刷盘、过期删除机制 本文介绍了RocketMQ Broker的存储目录结构及其功能，包括CommitLog、ConsumeQueue、Index、Config等文件夹的作用。CommitLog保存消息数据，每个文件默认1GB大小；ConsumeQueue提供消费队列索引；Index用于按消息key创建Hash索引；Config保存Topic、订阅关系和消费进度。此外，还详细说明了消息构成、CommitLog的作用及写入机制、索引机制（基于MessageID和Tag查询）、过期文件删除策略以及同步与异步刷盘的区别和配置方法。过期文件删除条件包括时间间隔、磁盘使用率和手动删除，并且删除过程涉及多步骤检查以确保安全。同步刷盘保证消息一致性但性能较低，而异步刷盘提高性能但可能丢失少量消息。
-
-
RocketMQ—生产者发送消息 RocketMQ支持五种消息类型：普通消息、分区有序消息、全局有序消息、延迟消息和事务消息。普通消息并发生产消费，性能可达十万级别的TPS；分区有序消息在一个分区内遵循FIFO原则；全局有序消息将Topic设为单分区以保证所有消息顺序；延迟消息允许消费者在指定时间后消费；事务消息通过发送Half消息、处理本地事务、提交或回滚消息来实现分布式事务。Broker、分区和队列之间的关系是，一个Broker可以有多个分区，每个分区对应一个队列，确保消息的存储和消费。代码示例展示了如何使用这些消息类型，包括配置和执行流程。对于事务消息，RocketMQ提供了回查机制，确保在异常情况下也能保持数据一致性。
-
RocketMQ—部署 本文详细介绍了RocketMQ的生产拓扑结构及其部署方式，包括单Master部署和多Master多Slave环境部署。文章首先概述了RocketMQ的主要组件如Namesrv集群、Broker集群、生产者集群及消费者集群，并解释了它们各自的作用。接着，文章详述了几种不同的Broker集群部署模式，从单Master到多Master多Slave同步复制，每种模式都有其适用场景与优缺点。随后，文章提供了具体的单Master部署步骤，包括NameServer和Broker的安装配置过程。此外，还介绍了如何快速部署RocketMQ Dashboard监控中心，以及通过Dashboard创建主题的方法。最后，文章展示了在多Master多Slave环境下部署RocketMQ的具体操作步骤，涵盖NameServer和多个Broker实例的配置方法。
-
