一、安装前准备工作
在安装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进行配置,如修改配置文件等。