您的位置:

RocketMQ Windows安装

一、安装前准备工作

在安装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进行配置,如修改配置文件等。