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/logsunzip rocketmq-all-4.8.0-bin-release.zipmv 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改成256mcd /home/rocketmq/rocketmq-4.8.0/binnohup sh mqnamesrv &nohup sh mqbroker -c /home/rocketmq/rocketmq-4.8.0/conf/broker.conf &查看日志：tail -f ~/logs/rocketmqlogs/namesrv.logtail -f ~/logs/rocketmqlogs/broker.log关闭服务：cd /home/rocketmq/rocketmq-4.8.0/bin/sh mqshutdown namesrvsh mqshutdown broker

rocketmq-console搭建

cd /home/rocketmq/rocketmq-externals-master/rocketmq-console/src/main/resourcescd /home/rocketmq/rocketmq-externals-master/rocketmq-consolemvn clean package -Dmaven.test.skip=truemvn clean package -Dcheckstyle.skip=truecd targetnohup 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

超强干货来袭 云风专访：近40年码龄，通宵达旦的技术人生