手把手教你从 0 到 1 搭建一套 RocketMQ 集群

大家好，我是君哥。今天来分享怎样搭建 RocketMQ 集群。,本文搭建集群使用的环境是 2 个云主机，架构如下：,,在 47.xx.xx.xx 和 39.xx.xx.xx 上分别部署一个 Name Server 和 Broker 主节点，这里不搭建从节点。也就是官网介绍的 2m-noslave 构建模式。,注意：官网有三种配置模式：2m-2s-sync、2m-2s-async、2m-noslave。这三种配置都是使用异步刷盘策略：ASYNC_FLUSH。,集群搭建成功后，Broker 会向 Name Server 注册 Topic 路由信息，Producer 和 Consumer 则从 Name Server 获取路由信息，然后 Producer 根据路由信息向 Broker 发送消息，Consumer 则根据路由信息从 Broker 拉取消息。,要安装 RocketMQ，首先需要在云主机上安装 Java 环境，Maven 环境。这里就不做详细介绍了。,Java 和 Maven 环境安装好以后，从官网下载最新版本，地址如下：,https://dlcdn.apache.org/rocketmq/4.9.4/rocketmq-all-4.9.4-bin-release.zip,下载完成后，进行解压和编译，执行如下命令：,看到下图输出时，编译成功:,,因为我的云主机内存比较小，而 RocketMQ 默认启动 Name Server 需要的 JVM 堆内存默认是 4g，所以需要修改默认堆内存。修改文件为：,修改后的配置如下：,修改完成后，执行下面命令：,启动成功后，nohup.out 文件中打印如下日志：,搭建好一台机器后，用同样的方式搭建第二台机器。,同样，RocketMQ 启动 Broker 需要的 JVM 堆内存默认是 8g，所以需要修改堆内存。修改文件为：,修改后的配置如下：,创建 conf.properties 文件，内容如下：,配置好后，启动 broker-a 节点，启动 命令如下：,Broker 启动成功后，Name Server 的日志如下图：,,用同样的方式启动 broker-b，conf.properties 文件配置如下：,启动成功后，执行 mqadmin 命令查看集群信息：,注意：执行上面命令需要修改 bin/tools.sh 中的 JVM 参数，配置如下：,安装 dashboard，需要编译源代码，源码 github 地址如下：,https://github.com/apache/rocketmq-dashboard,下载之后，修改 application.yml 参数，我这里只修改了 Name Server 地址：,然后执行 Maven 打包命令，打出 jar 包：,打好 jar 包后上传到服务器，执行下面命令启动：,启动成功后，输出下图的日志：,,浏览器输入 http://39.xx.xx.xx:8080/ 界面如下:,,使用下面命令创建一个 Topic，名字叫 MyTestTopic：,这是可以在界面上看到创建的 Topic，如下图:,,使用命令发送一条消息：,在界面上查看消息，如下图：,,这篇文章主要讲述了 RocketMQ 集群的搭建，希望能对大家理解 RocketMQ 有所帮助。