今天来介绍下RocketMQ的安装和发送消息的模拟。
软件要求
安装RocketMQ需要的环境：
1、64位OS，推荐使用Linux/unix/mac系统
2、64位的JDK1.8+
3、Maven 3.2.x
4、git
5、磁盘要求4G以上
下载并构建
点击以下地址下载传送门下载4.6.0版本的源代码，也可以下载二进制版本传送门
执行下面命令来解压压缩包并使用maven来构建
：
unzip rocketmq-all-4.6.0-source-release.zip
mv rocketmq-all-4.6.0-source-release rocketmq-all-4.6.0
cd rocketmq-all-4.6.0/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq
启动NameServer
nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log
输出以下内容表示启动成功
The Name Server boot success...
启动Broker
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
输出以下内容表示启动成功
The broker[%s, 172.30.30.233:10911] boot success...
发送并接收消息
在发送或者接收消息之前，我们需要告诉客户端NameServer的地址，RocketMQ提供多种方式去设置NameServer的地址，一种简单的方式是使用NAMESRV_ADDR环境变量
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId= ...
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_%d Receive New Messages: [MessageExt...
停止服务
sh bin/mqshutdown broker
看到以下内容表示停止成功
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK
sh bin/mqshutdown namesrv
看到以下内容表示停止成功
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK
本文为博主原创文章，未经博主允许不得转载。
更多内容请访问：IT源点
注意：本文归作者所有，未经作者允许，不得转载
