RocketMQ 开源项目安装与使用指南

目录结构及介绍

当你成功克隆了 RocketMQ 的仓库后, 你会看到如下目录结构:

├── bin                # 包含一些用于操作 Broker 和 NameServer 的 shell 脚本, 如: mqadmin, tools.sh等
│   ├── mqadmin        # 用于管理RocketMQ,如查询消息消费情况,向指定topic发送消息等功能
│   └── tools.sh       # 提供了一系列的工具命令,如数据导出,性能测试等
└── conf               # 存放RocketMQ相关配置文件的目录
    ├── broker.conf    # Broker 配置文件, 决定Broker如何运行(例如监听端口,队列数量)
    └── namesrv.conf   # Name Server 配置文件, 它决定了Name Server的基本行为(例如监听端口,日志存储位置)

在根目录下还有其他的重要组成部分：

• LICENSE: Apache License Version 2.0 授权许可说明。
• NOTICE: 文件中记录了对RocketMQ有贡献的人或组织。

启动文件介绍

Broker启动脚本

Broker 是 RocketMQ 中的数据处理节点，它负责接收和存储来自生产者的消息以及将消息推送给消费者进行消费。要启动一个Broker实例，你需要执行以下步骤：

1. 首先修改conf/broker.conf中的参数来适配你的环境，比如设置broker IP（brokerIP1），broker name（brokerName），存储路径(storePathRootDir)等。
2. 使用bin/start-broker.sh（Linux/Mac）或bin\start-broker.cmd（Windows）命令来启动Broker服务。如果想要以守护进程的方式运行，则可以添加 -c conf/broker.conf 参数指向配置文件。

NameServer启动脚本

NameServer 是 RocketMQ 系统的核心组件之一，主要功能是提供对Broker地址的管理和发现机制。要启动NameServer，你可以执行以下指令：

1. 修改conf/namesrv.conf文件，以便正确设定NameServer的监听端口和其他参数。
2. 执行bin/start-namesrv.sh（Linux/Mac）或bin\start-namesrv.cmd（Windows）。你同样可以通过加入 -c conf/namesrv.conf 来明确指定配置文件的位置。

此外，在bin目录下还有一个mqadmin工具，提供了丰富的操作，如查询、控制Broker和NameServer状态、检查主题和队列的状态等。

配置文件介绍

NameServer配置文件 (namesrv.conf)

• listenPort: 指定NameServer监听的端口号，默认为9876。
• mixAll=false: 这个选项通常设置为false，表示NameServer不参与混杂模式下的数据传输。
• logApp=namesrv: 日志前缀，用于区分不同类型的日志文件。

Broker配置文件 (broker.conf)

• brokerID=-1: 根据集群类型来决定，对于主备集群，需要给Master和Slave分配不同的ID。
• brokerRole=SINGLE_BROKER: 表示Broker的角色，可以选择 SINGLE_BROKER, MASTER 或者 SLAVE。
• brokerIP1=: 设置Broker的IP地址。
• storePathRootDir=: 消息的存储路径，必须存在且具备读写权限。
• flushDiskType=ASYNC_FLUSH: 控制数据持久化的策略，包括同步(SYNC_FLUSH)和异步(ASYNC_FLUSH)两种方式。

请注意，启动任何服务前都要确保已正确配置相关的配置项，否则可能会导致服务无法正常工作。