一、环境准备
在开始安装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";
请将上述属性值修改为您安装时的正确值。