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模式。
- 在 Local 模式下,Broker 和 Proxy 是同进程部署,只是在原有 Broker 的配置基础上新增 Proxy 的简易配置就可以运行。
- 在 Cluster 模式下,Broker 和 Proxy 分别部署,即在原有的集群基础上,额外再部署 Proxy 即可。
具体可以参考:部署方式
部署 Dashboard
获取源码编译
从官方地址获取源码
git clone https://github.com/apache/rocketmq-dashboard
进行构建
mvn clean package -Dmaven.test.skip=true
小贴士:默认的端口配置为 8080,很容易和其他产品冲突,因此可以根据需求对源码进行修改src/test/resources/application.properties
和src/main/resources/application.yml
。
启动
也可以对其使用配置进行修改
java -Dserver.port=10010 -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar
测试代码
可以参考其他开发者制作的示例程序:rocketmq-example
附录
参考链接
本文由 柒 创作,采用 知识共享署名4.0
国际许可协议进行许可。
转载本站文章前请注明出处,文章作者保留所有权限。
最后编辑时间: 2023-08-21 13:25 PM