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
相关文章
|
消息中间件 JavaScript 小程序
聊聊银行的信息科技岗(含各大银行薪资)
聊聊银行的信息科技岗(含各大银行薪资)
|
2天前
|
人工智能 JSON 安全
|
2天前
|
云安全 人工智能 安全
|
4天前
|
人工智能
Qwen3.8抢先体验!正式版即将发布并开源!
千问Qwen3.8即将开源,参数达2.4T,进化速度以“天”计,实力媲美Fable 5。预览版Qwen3.8-Max已上线阿里Token Plan等平台,限时优惠:日间Credits低至1折,夜间更优,个人/团队版月付仅35元起!
562 21
|
3天前
|
人工智能 自然语言处理 数据挖掘
Qwen3.8-Max 预览版全解析:2.4 万亿参数旗舰模型,Token Plan 限时优惠指南
Qwen3.8-Max-Preview是通义千问Qwen3系列旗舰MoE大模型,参数达2.4万亿,综合推理能力居行业第一梯队。支持思考/快速双模式,擅长大模型五大高难场景。现于阿里云百炼Token Plan、Qoder及QoderWork上线体验,个人版低至39元/月。在阿里云百炼官网:https://t.aliyun.com/U/fPVHqY 免费领取千万Tokens
461 1
Qwen3.8-Max 预览版全解析:2.4 万亿参数旗舰模型,Token Plan 限时优惠指南
|
3天前
|
人工智能 测试技术 语音技术
Qwen-Audio-3.0-TTS 正式发布!AI 语音从 “能说话” 升级到 “会带情绪表达”
阿里云发布Qwen-Audio-3.0-TTS语音合成大模型,支持细粒度标签控制(如[gasp][angry])、freestyle自由风格、16种语言及20种方言,声学鲁棒性强。含Flash(首包延时300ms)和Plus(全球榜单冠军)双版本,已在百炼平台开放调用。在阿里云百炼官网:https://t.aliyun.com/U/fPVHqY 免费领取千万Tokens
498 0
|
9天前
|
缓存 UED 开发者
Codex109天重置23次,明天还要再送一次
Codex近109天完成23次额度重置,7月14日将迎来第24次。Tibo高频响应用户反馈:优化GPT-5.6高消耗问题、补发失效福利、调整重置时间——形成“反馈→回应→修复→补偿”正向闭环,彰显以用户为中心的产品哲学。(239字)
850 12
|
2天前
|
人工智能 自然语言处理 数据挖掘
最新版通义千问(Qwen3.8-Max-Preview)功能介绍
2026年,通义千问正式推出全新旗舰级大模型 **Qwen3.8-Max-Preview 预览版**,作为首款突破万亿参数规格的新一代基座模型,该模型总参数量达到**2.4万亿**,采用全新迭代的MoE混合专家架构,综合推理性能、长文本处理、多模态理解、复杂任务规划能力全面超越前代Qwen3.7-Max版本,整体实力跻身全球第一梯队,可对标海外顶级旗舰模型,是当前面向复杂工程开发、多智能体协同、超长文档解析、专业办公自动化场景的最优国产基座模型。
616 0