RocketMQ常备知识汇总

简介: RocketMQ常备知识汇总

基础篇


阿里巴巴开源 参考kafka实现

应用场景:应用解耦,流量削峰,数据分发

源码地址:https://github.com/apache/rocketmq

中文文档:https://github.com/apache/rocketmq/tree/master/docs/cn

商业版:https://www.aliyun.com/product/rocketmq

官网翻译:http://www.itmuch.com/books/rocketmq/

FAQ:http://rocketmq.apache.org/docs/faq/

RocketMQ常用管理命令:https://blog.csdn.net/gwd1154978352/article/details/80829534

RocketMQ默认配置:https://www.cnblogs.com/jice/p/11981107.html

Linux基础搭建

下载地址:https://rocketmq.apache.org/dowloading/releases/

单机版broker搭建

创建文件目录:
mkdir -p /home/rocketmq/store/broker-a /home/rocketmq/store/broker-a/consumequeue /home/rocketmq/store/broker-a/commitlog /home/rocketmq/store/broker-a/index /home/rocketmq/broker-a/logs
unzip rocketmq-all-4.8.0-bin-release.zip
mv rocketmq-all-4.8.0-bin-release rocketmq-4.8.0

修改配置文件:

vim broker.conf
#Broker 对外服务的监听端口
listenPort=10911
##是否允许 Broker 自动创建Topic,建议线下开启,线上关闭
autoCreateTopicEnable=true
##是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭
autoCreateSubscriptionGroup=true
##nameServer地址,分号分割
namesrvAddr=localhost:9876
##存储路径
storePathRootDir=/home/rocketmq/store/broker-a
##commitLog 存储路径
storePathCommitLog=/home/rocketmq/store/broker-a/commitlog
##消费队列存储路径存储路径
storePathConsumeQueue=/home/rocketmq/store/broker-a/consumequeue
##消息索引存储路径
storePathIndex=/home/rocketmq/store/broker-a/index
##checkpoint 文件存储路径
storeCheckpoint=/home/rocketmq/store/broker-a/checkpoint
##abort 文件存储路径
abortFile=/home/rocketmq/store/broker-a/abort
启动:
修改bin目录下的runbroker.sh 和 runserver.sh 文件
比如把8g 4g 改成512m, 4g 2g改成256m
cd /home/rocketmq/rocketmq-4.8.0/bin
nohup sh mqnamesrv &
nohup sh mqbroker -c /home/rocketmq/rocketmq-4.8.0/conf/broker.conf &
查看日志:
tail -f ~/logs/rocketmqlogs/namesrv.log
tail -f ~/logs/rocketmqlogs/broker.log
关闭服务:
cd /home/rocketmq/rocketmq-4.8.0/bin/
sh mqshutdown namesrv
sh mqshutdown broker

rocketmq-console搭建

cd /home/rocketmq/rocketmq-externals-master/rocketmq-console/src/main/resources
cd /home/rocketmq/rocketmq-externals-master/rocketmq-console
mvn clean package -Dmaven.test.skip=true
mvn clean package -Dcheckstyle.skip=true
cd target
nohup java -jar rocketmq-console-ng-2.0.0.jar &

其他信息

Producer:消息生产者

Producer Group:消息生产者组,发送同类消息的一个消息生产组

Consumer:消费者

Consumer Group:消费同个消息的多个实例

Tag:标签,子主题(二级分类),用于区分同一个主题下的不同业务的消息

Topic:主题

Message:消息

Broker:MQ程序,接收生产的消息,提供给消费者消费的程序

Name Server:给生产和消费者提供路由信息,提供轻量级的服务发现和路由


MQ大对比

https://blog.csdn.net/u010800804/article/details/113846163

相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
数据采集 自然语言处理 程序员
ChatGPT 调教日记(一):Markdown 解析器
ChatGPT 调教日记(一):Markdown 解析器
306 0
|
JavaScript Java 关系型数据库
毕设项目-基于Springboot和Vue实现蛋糕商城系统(一)
毕设项目-基于Springboot和Vue实现蛋糕商城系统
379 0
|
Cloud Native Java 应用服务中间件
Docker容器实战【三】搭建Docker镜像私服Harbor
每个企业都有自己的镜像私服仓库,和nexus一样,公司内部的镜像制品都存放在自己的私服仓库中,今天我们来学习Harbor
1256 1
Docker容器实战【三】搭建Docker镜像私服Harbor
|
9月前
|
Python
【12月更文挑战第23天】
【12月更文挑战第23天】
89 5
|
安全 算法 Android开发
Android10.0 人脸解锁(上)
Android10.0 人脸解锁(上)
Android10.0 人脸解锁(上)
|
算法 计算机视觉
【Qt&OpenCV 图像边缘检测 Sobel/Laplace/Canny】
【Qt&OpenCV 图像边缘检测 Sobel/Laplace/Canny】
203 0
|
存储 网络协议 Java
【TCP 连接手段】C++编程视角下的TCP:短连接与长连接深度解析
【TCP 连接手段】C++编程视角下的TCP:短连接与长连接深度解析
327 1
|
缓存 监控 算法
Linux内存碎片深度剖析:原理、处理与分析全指南
Linux内存碎片深度剖析:原理、处理与分析全指南
2589 0
Linux内存碎片深度剖析:原理、处理与分析全指南
|
SQL 分布式计算 数据挖掘
Kylin使用心得
Kylin使用心得
141 0
|
Android开发
Android源代码定制:Overlay目录定制|调试Overlay资源是否生效
Android源代码定制:Overlay目录定制|调试Overlay资源是否生效
1290 0

热门文章

最新文章