RocketMQ：Windows下开发环境搭建

一时失言乱红尘 2024-05-09 16:32 119阅读 0赞

### 一、准备工作 ###

从RockitMQ官网[下载 | RocketMQ][_ RocketMQ]下载最新的release包。我这里下载的版本是v5.2.0

![23ec734b0c49422eac55664270b52748.png][]

解压到本地目录，`bin`目录下存放可运行的脚本。

![53bc53b2ac184fbe9ede65f82370f2cf.png][]

### 二、RocketMQ基本结构 ###

在动手开发之前，我们需要了解一下RocketMQ的基本结构

![c3ad3c1be1b44b22b2ea879ecf2a9c72.png][]

如上图所示，一个正常工作的RocketMQ包括四个部分。

1.  NameServer ：基于高可用设计产生的，用于服务发现和路由。正式应用时通常采用集群部署。
2.  Broker：实现队列机制，负责消息存储和转发。正式应用时也采用集群部署。
3.  Producer：消息生产者，生成消息并发送到RocketMQ中，生产者通常是我们自己实现的应用程序。
4.  Consumer：消息消费者，从RocketMQ中接收消息并进行业务处理。这部分也通常是我们自己实现的。

> 这里并不打算深入讲解RocketMQ的架构和特性，因为我觉得，针对于初学者，太早地深入知识细节，会让人感到迷惘，学习起来吃力。为了避免浪费时间，以上的知识己经能满足本文后面要实践的内容。随着实践我们会慢慢加深对RocketMQ的理解，再回过头来一点点深入了解。
> 
> 以上的知识都来源于RocketMQ官网的参考文档，需要更多细节的同学， 可以打开  
> [https://rocketmq.apache.org/docs/quickStart/01quickstart/][https_rocketmq.apache.org_docs_quickStart_01quickstart] 自行阅读。

### 三、Windows环境下启动最小应用 ###

从上面的图可以了解到，RocketMQ自身分为 **NameServer** 和 **Broker** 两个部分，因此，用作本机开发调试用的最小应用，应该分别启动一个NameServer和一个Broker节点。

RocketMQ默认提供了 windows环境 和 linux环境 下的启动脚本。脚本位于`bin`目录下，windows的脚本以`.cmd`为文件名后缀，linux环境的脚本以`.sh`为文件名后缀。

#### 第一步、配置*JAVA\_HOME* 和 *ROCKETMQ\_HOME* 环境变量 ####

*JAVA\_HOME* 的配置已经是老生常谈，这里不再赘述，不懂的话请自行百度。

*ROCKETMQ\_HOME* 应指向解压后的`Readme.md`文件所在目录。

![5e521de8672341e1ac7be614dadfa218.png][]

#### 第二步，启动 *NameServer* ####

`bin`目录下直接双击`mqnamesrv.cmd`脚本启动NameServer

![79d14cab84dd4582b3d9dd30475cdb3d.png][]

看到 `The Name Server boot success` 字样，表示NameServer己启动成功。

> windows环境下，可以在目录`%USERPROFILE%\logs\rocketmqlogs`下找到NameServer的启动日志。文件名为`namesrv.log`。

#### 第三步，启动 *Broker* ####

Broker的启动脚本是`mqbroker.cmd，`脚本启动之前要指定 **NameServer的地址**。

##### **启动方式一：修改`mqbroker.cmd`脚本，增加NameServer的地址。** #####

rem 添加此行，指定NameServer的地址
    set "NAMESRV_ADDR=localhost:9876"
     
    rem 在此行之前添加NameServer的地址
    call "%ROCKETMQ_HOME%\bin\runbroker.cmd" org.apache.rocketmq.broker.BrokerStartup %*

双击mqbroker.cmd脚本启动Broker。

##### 启动方式二：不修改mqbroker.cmd脚本，直接使用cmd命令启动 #####

先进入rocketmq安装目录的bin目录下面，然后执行下面命令启动broker

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

![340601ac275342328f4bd53546db2d70.png][]

> 看到 `The broker ... boot success` 字样，表示Broker己启动成功，
> 
> 与NameServer类似，可以在目录`%USERPROFILE%\logs\rocketmqlogs`下找到Broker的启动日志。文件名为`broker.log`。

### 四、使用RocketMQ仪表盘 ###

RocketMQ Dashboard是一个Web界面应用程序，用于管理和监控Apache RocketMQ消息中间件的运行状态。RocketMQ Dashboard提供了一系列的监控指标和管理功能，包括Broker配置、集群概览、主题状态、消费者状态、生产者状态和消息跟踪等。

[https://github.com/apache/rocketmq-dashboard][https_github.com_apache_rocketmq-dashboard]直接下载源码到本地部署

用idea打开，修改配置文件application.yml

rocketmq:
      config:
        namesrvAddrs:
          - 192.168.10.100:9876
          - 192.168.10.101:9876

namesrvAddrs地址就是服务的地址，192.168.10.100是我虚拟主机的ip，如果是window环境下，改成localhost或者127.0.0.1

然后启动程序，访问http://localhost:8080/\#/

![3ba0a8e9636a47608d3e5a2e27c4804c.png][]

[_ RocketMQ]: https://rocketmq.apache.org/download/
[23ec734b0c49422eac55664270b52748.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/09/571efecfac224ef8b7bc32f8e48191db.png
[53bc53b2ac184fbe9ede65f82370f2cf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/09/1e9b1a45a94e48dd90796265c05f2243.png
[c3ad3c1be1b44b22b2ea879ecf2a9c72.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/09/5824ce0943884cc6a95dbc7b7747e099.png
[https_rocketmq.apache.org_docs_quickStart_01quickstart]: https://rocketmq.apache.org/docs/quickStart/01quickstart/
[5e521de8672341e1ac7be614dadfa218.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/09/3dccef9096f047dcbc3a98ce29ff29cb.png
[79d14cab84dd4582b3d9dd30475cdb3d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/09/81bacc88e9a64fb18405d0dfe8bf5ecc.png
[340601ac275342328f4bd53546db2d70.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/09/75b93f744a274c1aac446a5e28e36b14.png
[https_github.com_apache_rocketmq-dashboard]: https://github.com/apache/rocketmq-dashboard
[3ba0a8e9636a47608d3e5a2e27c4804c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/05/09/83a3e69d372446b6bcf99635f43745f3.png