一、环境准备
在开始安装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";
请将上述属性值修改为您安装时的正确值。
原创文章，作者：NHTK，如若转载，请注明出处：https://www.506064.com/n/146159.html
微信扫一扫 
支付宝扫一扫 