RocketMQ使用教程相关系列 目录
目录
第一节:下载RocketMQ
下载地址
环境要求
第二节:安装RocketMQ
以二进制包安装
解压安装包
解压安装包并移动到指定目录
更改文件名
创建rocketmq存储目录
新创建文件夹说明
rocketMQ目录介绍
conf目录文件说明
第三节:单结点配置
配置hosts
进入conf配置文件夹
修改日志路径
修改 runbroker.sh
修改 runserver.sh
第四节:环境变量配置
先启动namesrv
启动broker
关闭namesrv和broker
关闭namesrv服务
关闭broker服务
第五节:防火墙配置
第六节:RocketMQ架构介绍
第一节:下载RocketMQ
演示:RocketMQ版本:4.5.1
下载地址
https : //archive.apache.org/dist/rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip
环境要求
Linux64位系统
JDK1.8(64位)
源码安装需要安装Maven 3.2.x
第二节:安装RocketMQ
以二进制包安装
上传下载的安装包到服务器上
新创建文件夹说明
logs:存储日志目录
store:存储数据文件目录
commitlog:存储消息信息
consumequeue,index:存储 消息的索引数据
rocketMQ目录介绍
bin:启动脚本,包括shell脚本和CMD脚本
conf:实例配置文件 ,包括broker配置文件、logback配置文件等
lib:依赖jar包,包括Netty、commons-lang、FastJSON等
conf目录文件说明
2m-2s-async :2主2从-异步
2m-2s-sync :2主2从-同步
2m-noslave :2主无从
这里演示单结点配置:只要先修改2m-2s-async配置实现。
#所属集群名字 brokerClusterName=rocketmq-cluster #broker名字,注意此处不同的配置文件填写的不一样 brokerName=broker-a #0 表示 Master,>0 表示 Slave brokerId=0 #nameServer地址,分号分割 namesrvAddr=rocketmq-nameserver1:9876; #在发送消息时,自动创建服务器不存在的topic,默认创建的队列数 defaultTopicQueueNums=4 #是否允许 Broker 自动创建Topic,建议线下开启,线上关闭 autoCreateTopicEnable=true #是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭 autoCreateSubscriptionGroup=true #Broker 对外服务的监听端口 brokerIP1=192.168.88.131 listenPort=10911 #删除文件时间点,默认凌晨 4点 deleteWhen=04 #文件保留时间,默认 48 小时 fileReservedTime=120 #commitLog每个文件的大小默认1G mapedFileSizeCommitLog=1073741824 #ConsumeQueue每个文件默认存30W条,根据业务情况调整 mapedFileSizeConsumeQueue=300000 #destroyMapedFileIntervalForcibly=120000 #redeleteHangedFileInterval=120000 #检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 #存储路径 storePathRootDir=/usr/local/server/mq/rocketmq/store #commitLog 存储路径 storePathCommitLog=/usr/local/server/mq/rocketmq/store/commitlog #消费队列存储路径存储路径 storePathConsumeQueue=/usr/local/server/mq/rocketmq/store/consumequeue #消息索引存储路径 storePathIndex=/usr/local/server/mq/rocketmq/store/index #checkpoint 文件存储路径 storeCheckpoint=/usr/local/server/mq/rocketmq/store/checkpoint #abort 文件存储路径 abortFile=/usr/local/server/mq/rocketmq/store/abort #限制的消息大小 maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 异步复制Master #- SYNC_MASTER 同步双写Master #- SLAVE brokerRole=SYNC_MASTER #刷盘方式 #- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 flushDiskType=SYNC_FLUSH #checkTransactionMessageEnable=false #发消息线程池数量 #sendMessageThreadPoolNums=128 #拉消息线程池数量 #pullMessageThreadPoolNums=128