赞
踩
实践来源于官网教程与网上资料
环境:MACBOOK BigSur
安装所需软件环境: Git、Maven、JDK1.8
版本:4.9.2 地址:https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.2/rocketmq-all-4.9.2-source-release.zip
下载后登录命令行
输入su切换高权用户 需要输入密码
切换到下载目录
cd /Users/当前mac用户名/Downloads 一般在下载目录可以找到
rocketmq-all-4.9.2-source-release.zip
对该压缩包进行解压 执行(可以将压缩包用mv移动命令移动到指定目录,这里图省事)
unzip rocketmq-all-4.9.2-source-release.zip
解压后生成 rocketmq-all-4.9.2文件夹
cd rocketmq-all-4.9.2 切换进入此文件夹
执行mvn -Prelease-all -DskipTests clean install -U用maven对项目进行编译 编译完成后可切入target里运行
等待编译完成。。。
切换到编译完成后的文件夹
cd distribution/target/rocketmq-4.9.2/rocketmq-4.9.2
执行
nohup sh bin/mqnamesrv &
表示后台不间断的运行namesrv
tail -f ~/logs/rocketmqlogs/namesrv.log
表示动态查询namesrv.log最后的内容
如果有新的日志,在界面会动态显示最新内容
然后启动Broker
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
这里类似name server,接下来就可以通过localhost:9876来进行一些收发消息的测试
官网例子:
由于之前name server已经悬挂在Linux中运行 且broker也已启动
此时在两个窗口中配置NAMESRV_ADDR地址
这里我打开两个命令窗口,方便观察
export NAMESRV_ADDR=localhost:9876 配置一下name
server的环境地址(两个窗口都要执行一次,不然不知道该变量名配置的值)
一个窗口中执行以下语句生产者发送样例消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
另一个窗口执行以下语句接收上面生产者发送的消息,此窗口即为启动了一个消费者
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
此时一次基本发送消息与接收消息的实践已完成,可以看到收到的消息是一个包装的消息对象,还需慢慢研究,后续会更新利用发送接收api在程序中收发消息,配置集群。。。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。