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
