RocketMQ Windows安装

DPEHC • 2025-04-12 13:00 • 编程

一、安装前准备工作

在安装RocketMQ之前，需要进行以下准备工作：

1. 安装JDK

首先需要到Oracle官网下载JDK安装文件，选择适合自己操作系统的文件进行下载并安装。安装好JDK之后，需要设置环境变量，将JDK的bin目录添加到系统的PATH中。

2. 安装Maven

Maven是一个自动化构建工具，可以用于管理Java项目的构建过程。使用Maven可以自动下载依赖库，并按照一定的规则进行编译和打包。在安装RocketMQ之前，需要先安装Maven，并设置相关的环境变量。

3. 下载RocketMQ安装包

在官网上下载对应的RocketMQ安装包。

二、安装RocketMQ

1. 解压安装包

将下载好的RocketMQ安装包进行解压，得到如下文件夹：

apache-rocketmq-all-4.9.1-bin-release/
|-bin/
|-conf/
|-doc/
|-lib/

2. 配置环境变量

在用户变量中添加变量名：ROCKETMQ_HOME，默认值为解压出来的目录。

在系统变量中找到Path变量，进行编辑，在变量值最后追加%ROCKETMQ_HOME%\bin;

3. 启动NameServer

在控制台中执行如下命令：

bin\mqnamesrv.cmd

若启动成功，将会看到如下信息：

NamesrvStartup running
The Name Server boot success. serializeType=JSON

4. 启动Broker

在控制台中执行如下命令：

bin\mqbroker.cmd -n localhost:9876

若启动成功，将会看到如下信息：

The broker[%s, %s] boot success. serializeType=JSON

5. 验证安装

在浏览器中访问 http://localhost:8080 查看控制台界面。如果可以看到RocketMQ的控制面板，则证明RocketMQ已经安装成功。

三、配置RocketMQ

1. 修改配置文件

在安装目录下的conf文件夹中，找到broker.conf和namesrv.conf两个文件，进行如下修改：

a. broker.conf

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
storePathRootDir=E:/store/rocketmq/
storePathCommitLog=E:/store/rocketmq/commitlog
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
listenPort=10911

b. namesrv.conf

listenPort=9876
# name server的存储路径
storePathRootDir=E:/store/rocketmq/

2. 重启服务

在控制台中按下CTRL+C停止服务，在重新执行第3、4步启动服务。

四、总结

RocketMQ是一款高可用、高性能、分布式消息中间件，也是一种解决消息异步处理和吞吐量问题的技术架构。在Windows环境中，安装配置RocketMQ需要进行相应的准备工作，包括安装JDK、Maven以及下载RocketMQ安装包。接着，需要进行解压和配置环境变量等操作，在控制台中启动NameServer和Broker进行安装。安装完成后，可以对RocketMQ进行配置，如修改配置文件等。

原创文章，作者：DPEHC，如若转载，请注明出处：https://www.506064.com/n/369151.html