本地启动 RocketMQ 5.1.0 集群：零基础教程

后端

2023-12-08 12:07:24

本地搭建 RocketMQ 5.1.0 集群：深入理解其内部原理

简介

RocketMQ 是一个功能强大的分布式消息队列系统，在互联网领域应用广泛。其最新的 5.x 版本引入了主从同步机制，并优化了集群部署方式。如果你想深入了解 RocketMQ 的内部运作原理，搭建一个本地集群是一个绝佳的选择。

准备工作

在开始搭建之前，你需要准备以下环境：

Java 8 或更高版本
Maven
Git

搭建步骤

1. 克隆 RocketMQ 源码

打开终端窗口，进入你希望安装 RocketMQ 的目录，运行以下命令克隆源码：

git clone https://github.com/apache/rocketmq.git

2. 编译 RocketMQ

切换到 RocketMQ 源码目录，运行以下命令编译：

cd rocketmq
mvn clean install -DskipTests

3. 启动 Nameserve

切换到 rocketmq/bin 目录，依次启动三个 Nameserve：

./mqnamesrv start
./mqnamesrv start -n 1
./mqnamesrv start -n 2

4. 启动 Broker

切换到 rocketmq/bin 目录，依次启动两个 Broker：

./mqbroker start
./mqbroker start -n 1

5. 验证集群

打开浏览器，访问 http://localhost:9876/console/index.html，如果集群启动成功，你会看到三个 Nameserve 和两个 Broker 的信息。

深入探索

理解 RocketMQ 架构

RocketMQ 集群由 Nameserve、Broker 和 Producer/Consumer 组成。Nameserve 负责管理元数据和路由消息，Broker 负责存储和转发消息，Producer/Consumer 负责发送和接收消息。

主从同步机制

5.x 版本中引入了主从同步机制，以提高可靠性。每个 Broker 由一个主节点和一个或多个从节点组成。主节点负责写入和转发消息，从节点从主节点同步数据，提供读操作。

代码示例

下面是一个发送和接收消息的代码示例：

// 创建 Producer
Producer producer = MQClientFactory.getProducer("default");

// 创建 Message
Message message = new Message("TestTopic", "Hello World");

// 发送消息
producer.send(message);

// 创建 Consumer
Consumer consumer = MQClientFactory.getConsumer("default");

// 订阅 Topic
consumer.subscribe("TestTopic", "*");

// 接收消息
consumer.registerMessageListener(new MessageListener() {
  @Override
  public void consumeMessage(List<MessageExt> msgs) {
    // 处理消息
  }
});