【RocketMQ】单机安装

  |   0 评论   |   279 浏览

今天来介绍下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

也可以关注我的公众号:程序之声
图片
关注公众号,领取更多资源

本文为博主原创文章,未经博主允许不得转载。

评论

发表评论