从零开始的 RocketMQ 5 入门教程及简单测试

后知后觉 暂无评论

RocketMQ 5 版本是一个很大的变革,从底层逻辑到上层服务都有很大程度的变化。

安装 RocketMQ

官网:rocketmq.apache.org/download

下载安装

解压安装包,记得下载 binary 版本。

unzip rocketmq-all-5.1.3-bin-release.zip

授权文件并移动到安装目录中

sudo chown -R $USER:$USER rocketmq-all-5.1.3-bin-release/
sudo mv rocketmq-all-5.1.3-bin-release/ /opt/

配置守护进程

编辑守护单元文件 /usr/lib/systemd/system/rocketmq-namesrv.service

[Unit]
Description=Apache RocketMQ NameServer

[Service]
User=rocketmq
Group=rocketmq
Environment="ROCKETMQ_HOME=/opt/rocketmq-all-5.1.3-bin-release"
WorkingDirectory=/opt/rocketmq-all-5.1.3-bin-release
ExecStart=/opt/rocketmq-all-5.1.3-bin-release/bin/mqnamesrv
ExecStop=/opt/rocketmq-all-5.1.3-bin-release/bin/mqshutdown namesrv
Restart=on-failure

[Install]
WantedBy=multi-user.target

编辑守护单元文件 /usr/lib/systemd/system/rocketmq-broker.service

[Unit]
Description=Apache RocketMQ Broker with Proxy

[Service]
User=rocketmq
Group=rocketmq
Environment="ROCKETMQ_HOME=/opt/rocketmq-all-5.1.3-bin-release"
WorkingDirectory=/opt/rocketmq-all-5.1.3-bin-release
ExecStart=/opt/rocketmq-all-5.1.3-bin-release/bin/mqbroker -n localhost:9876 --enable-proxy
ExecStop=/opt/rocketmq-all-5.1.3-bin-release/bin/mqshutdown broker
Restart=on-failure

[Install]
WantedBy=multi-user.target
小贴士:单元中的用户名按需要进行配置,不推荐使用 root 用户,建议配置为普通用户。

在 RocketMQ 5 版本开始,服务被拆分为三份,分别为 NameServer、Broker、Proxy 组件,在 5.0 版本中 Proxy 和 Broker 根据实际诉求可以分为 Local 模式和 Cluster 模式,一般情况下如果没有特殊需求,或者遵循从早期版本平滑升级的思路,可以选用Local模式。

具体可以参考:部署方式

部署 Dashboard

获取源码编译

从官方地址获取源码

git clone https://github.com/apache/rocketmq-dashboard

进行构建

mvn clean package -Dmaven.test.skip=true
小贴士:默认的端口配置为 8080,很容易和其他产品冲突,因此可以根据需求对源码进行修改 src/test/resources/application.propertiessrc/main/resources/application.yml

启动

也可以对其使用配置进行修改

java -Dserver.port=10010 -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar

控制面板

测试代码

可以参考其他开发者制作的示例程序:rocketmq-example


附录

参考链接

如果遇到问题或者对文章内容存疑,请在下方留言,博主看到后将及时回复,谢谢!
禁用 / 当前已拒绝评论,仅可查看「历史评论」。