您的位置:

RocketMQ Windows安装指南

一、环境准备

在开始安装RocketMQ之前,我们需要准备以下环境:

1、JDK:请确保已经在Windows操作系统中安装了JDK,并能够正常运行。

2、存储:确保有足够的硬盘空间用于存储RocketMQ程序和数据。

3、下载RocketMQ:从官方网站http://rocketmq.apache.org/release_notes/release-notes-4.8.0下载安装包。

二、安装步骤

1、解压安装包

tar -zxvf rocketmq-all-4.8.0-bin-release.zip

解压后的文件夹包含了大部分文件,我们将在此文件夹中完成RocketMQ的安装。

2、创建Name Server和Broker实例

在解压后的根目录下,有两个主要的文件夹实例文件夹和namesrv文件夹。

在实例目录文件夹中,我们将创建Broker实例文件夹:

mkdir broker-a
mkdir broker-b

在namesrv文件夹中,我们将创建Name Server实例文件夹:

mkdir namesrv-a

3、修改配置文件

修改 namesrv-a/conf 目录下的配置文件:

rocketmq.namesrv.addr=192.168.0.1:9876

修改 broker-a/conf 文件夹下的配置文件:

brokerClusterName = MyBroker_Cluster
brokerName = MyBroker_A
brokerId = 0
deleteWhen= 04
fileReservedTime = 48

修改 broker-b/conf 文件夹下的配置文件:

brokerClusterName = MyBroker_Cluster
brokerName = MyBroker_B
brokerId = 1
deleteWhen= 04
fileReservedTime = 48

4、启动Name Server

在解压后的根目录中,进入 namesrv 目录,然后运行以下命令:

nohup sh bin/mqnamesrv &

5、启动Broker

在解压后的根目录中,进入 broker-a 目录,然后运行以下命令:

nohup sh bin/mqbroker -c conf/broker-a.properties &

在解压后的根目录中,进入 broker-b 目录,然后运行以下命令:

nohup sh bin/mqbroker -c conf/broker-b.properties &

三、检查RocketMQ是否启动

1、检查Name Server状态

在任意命令窗口中输入以下命令:

ps -ef|grep mqnamesrv |grep -v grep

如果看到一个名称为 mqnamesrv 的进程,表示Name Server已经启动。

2、检查Broker状态

在任意命令窗口中输入以下命令:

ps -ef|grep mqbroker |grep -v grep

如果看到两个名称为 mqbroker 的进程,表示两个Broker都已经启动。

四、使用RocketMQ

现在可以在您的应用程序中使用 Apache RocketMQ。

在您的应用程序中,您需要指定以下属性:

 namesrvAddr = "localhost:9876";
 producerGroup = "producer";
 consumerGroup = "consumer";

请将上述属性值修改为您安装时的正确值。