技术活，该赏
点赞再看，养成习气

RocketMQ运用教程相关系列 目录

---

第一节：下载RocketMQ

演示：RocketMQ版别：4.5.1

下载地址

https://archivjsonobjecte.apache.org/dist/源码集市rocketmq/4.5.1/rocketmq-a架构是什么意思ll-4.5.1-bin-release.zip

环境要求

• Linux64位体系
• JDK1.8(64位)
• 源码设备需求设备Maven 3.2.x

第二节：设备RocketMQ

以二进制包设备

上传jsonobject下载的设备包到服务器上

解压设备包

先检查下有没有设备unzip

un源码编辑器zip

出现下图则是有设备

出现下图则是没有设备

设备指令

yum install unzip

解压设备包并移动到指定目录

创立对应的目录/源码共享网usr/local/server/rocketmq

 cd /usr/local/
mkdir server
cd server/
mkdir rocketmq

unzip roc虚拟机对电脑伤害大吗ketmq-all-4.5.1-bin-release.zip -d /usr/local/server/rocketmq

更改文件名

cd /http署理usr/local/server/rocketmq/
mv rocketmq-all-4.5.1-bin-release/ rocketmq
cd ..
m架构图模板v rocketmq/ mqhttp协议 #出现两个rocketmq文件夹名，改上一个文件夹为mq

创立rocketmq存储目录

现有的目录结构是这样的

创立存储目录

mkdir logs
mkdjson是什么意思ir store
cd store
mkdir commitlog
mkdir consumeque架构设计ue
mkdir index

新创立文件夹阐明

• logs:存储日志目录
• store:存储数据文件目录
• commitlog:存储音讯信息
• consumequeue，index:存储 音讯的索引数据

rocket源码MQ目录介绍

• bin：建议脚本，包含shell架构是什么意思脚本和CMD脚本
• conf：实例装备文件 ，包架构师薪酬一月多少括brokerjson文件是干什么的装备文件、logback装备http署理文件等
• lib：依靠jar包，包含Netty、commons-lang、FastJSON等

conf目录文件阐明

• 2m-2s-async ：2主2从-异步
• 2m-2s-sync ：2主2从-同步
• 2m-noslave ：2主无从

这儿演示单结点装备：只需先批http协议改2m-2s-async装备实现。

cd 2m-2s-async

broker-a.properties		:单结点a装备文件
broker-a-s.properties	:单结点a的从结点装备文件
brokjson是什么意思er-b.properties		:单结点b装备文件
broker-b-s.properties	:单json结点b的虚拟机装置教程从结点装备http://192.168.1.1登录文件

第三节：单结点装备

装备hosts

vim /etc/hhttp://www.baidu.comosts

增加nameserver和broker

# nameserver
192.168.88.131 rocketmq-nameserver1
# brohttps和http的差异ker
192.168.88.131 rocketmq-master1

装备完成后, 重启网卡

systemctl restart network

进入conf装备文件夹

cd conf

进入2m-http://192.168.1.1登录2s-async

cd 2m-2shttp://192.168.1.1登录-async

修改broker-a.properties

vim broker-a.properties

将下面的装备掩盖 broker-a.properties，保存

#所属集群姓名
brokerClusterName=rocketmq-cluster
#broker姓名，留意此处不http 404同的装备文件填写的不一样
brokerName=broker-a
#0 标明 Master，>0 标明源码集市 Slave
brokerId=0
#nameServer地址，分号分割源码时代
namesrvAddr=rocke源码码头tmjson转mapq-nameserver1:9876;
#在发送音讯时，主动创立服务器不存在的topic，默许创立的行列数
defaultTopicQueueNums=4
#是否容许 Broker 主动创立Topic，建议线下翻开，线上封闭
autoCreateTop虚拟机装置icEnable=true
#是否容许 Broker 主动创立订阅组，建议线下翻开，线上封闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口架构图模板
brokerIP1=192.168.88.131
listenPort=10911
#删去文件时间点，默许清晨 4点
dejson文件是干什么的leteWhen=04
#文件保留时间，默许 48 小httpclient时
fileReservedTime=120
#commitLog每个文件的巨细默许1G
mapedFileSizeComm源码编辑器手机版下载itLog=1073741824
#ConsumeQueue每个文件默许存30W条，依据事务状况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储途径
storePathRootDir=/usr/local/server/mq/rocketmq/store
#commitLog 存储途径
storePat架构图制造h源码之家CommitLog=/usr/JSONlocal/server/mq/rocketmq/store/commitlog
#消费行列存储途径存储途径
storePathConsumeQueue=/usr/local/server/mq/ro架构师需求把握哪些常识cketmq/store/consumequeue
#音讯索引存虚拟机下载手机版储途径
storePathIndex=/usr/http协议local/server/mq/rocketmqhttpclient/store/index
#checkpointjsonp 文件存储途径
storeCheckpoint=/usr/local/server/mq/rochttp://192.168.1.1登录ketmq/store/checkp源码码头oint
#abort 文件存储途径
abortFile=/usr/localjsonp/server/mq/rocketm架构是什么意思q/store/abort架构图制造
#约束的音讯巨细
maxMessageSizejson转map=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLojsongTho虚拟机装置roughInterval=10000
#flushConsumjson解析eQueueThoroughInterv源码编辑器编程猫下载al=60000
#Brokjson文件是干什么的er 的人物
#- ASYNC_MASTER 异步仿制Master
#- S源码共享网YNC_MASThttp://192.168.1.1登录ER 同步双写Master
#- SLAVE
broke虚拟机下载手机版rRole=SYNC_MASTEHTTPR
#刷盘方法
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=SYNC_Fhttp://192.168.1.1登录LUSH
#checkTransactionMessageEnable=false
#发音讯线程池数量
#sendMessageThreadPoolNums=128
#拉音讯线程池数量
#虚拟机装置教程pullMessageThreadPoolNums=128

注：装备里的途径要与刚创立的文件夹途径保持一致，如有自定义修改

修改日志途径

进入conf 目录，替换一切xml中的${user.home},确保日志途径正确源码时代

语法：

sed -i 批量替换作用

sed -i 's#原字符串#新字符串#g' 替换的文件

sed -i 's#${user.home}#/usr/local/server/mq/rockehttp 404tmq#g' *.xml

阐明替换成虚拟机装置功了源码码头

修改 runbroker.sh

调整内存巨细(这儿仅仅演示用处，实践的内存巨细要以出产环境为准)

cd ..
cd bjson转mapin/
vim架构师和程序员的差异 runbroker.sh

调整为1g

修改 runsejson格式rver.sh

调整内存巨细(这儿仅仅演示用处，实践的内存巨细要以出产环境为准)

vim runserver.sh

第四节：环境变量装备

vim /源码之家etc/profile

在profile文件的结尾参与如下指令

#set roc源码之家ketmq
ROCKETMQ_HOME=/usr/local/server/mq/rocketmq/
PATH=$PATH:$ROCKETMQ_HOME/bin
export ROCKETMQ_HOME PATH

输入:wq! 保存并退出， 并使得装备立刻收效：

source /源码本钱etc/profile

先建议namesrv

nohup sh mqnamesrv &

服务没建议成功，检查下日志

cd /usr/local/server/mq/rocketmq/bin/
cat nobup.out

原因是输入的指令写成了

nohup sh mqna架构师和程序员的差异mesrc &    ##应该是 nohup sh mqnamesrv &

输入

ohup sh mqnamesrv &

然后回车

经过源码jps检查

建议broker

 nohup sh mqbJSONroker -chttp协议 /usr/loc源码编辑器al/server/mq/rocketmq/conf/2m-2s-async/broker-a.properties > /dev/null 2>&1 &

注：

l架构图制造inux下详解shell中json格式怎么翻开>/dev/null 2>&1

www.cnblogs.com/ultranms/p/…

封闭namesrv和broker

封闭name虚拟机linuxsrv服务

#进入bin
sh mqshutdo架构师需求把握哪些常识wn namesrv

封闭broker服务

sh mqshu架构师tdown broker

经过jps验证下

第五节：防火墙装备

宿主机需求架构师长途拜访虚拟机的rock虚拟机装置教程etmq服务和web服务，需求翻开相关的端口号，简略粗暴的方法是直接封闭防火墙

# 封闭防火墙
systemctlhttp://192.168.1.1登录 stop firewalld.service
# 检查防火墙的状况
firewall-cmd --state
# 阻止firewall开机建议
systemctl disable firewalld.service

或许为了安全，只翻开特定的端口号，RocketMQ默许运用3个端口：9876 、10911 、11011 。假如防火墙没有封闭的话，那么防火墙就必源码本钱须翻开这些端口：

• nameserver默许运用 987源码码头6 端口
• master默许运用 10911 端口
• slave默许运用1101虚拟机体系1 端口

实行以下指令：

# 翻开name server默许端口
firewall-cmd --remove-port=9876/tcp --permanent
# 翻开master默许端口
fijson转maprewall-cmd --remove-port=10911/tcp --permanent
# 翻开slave默许端口 (当时集群方法可不翻开)
firewall-cmd --remove-port=11011/tcp --permanent
# 重启防火墙
firewall-cmd --reload

第六节：RocketMQ架构介绍

• Producer：音讯的发送者；举例：发信者
• Consumer：音讯接收者；举例：收信者
• Bjsonp跨域原理roker：暂存和传输音讯；举例：架构师薪酬一月多少邮局
• NameServer：处理Brokhttps和http的差异er；举例：各个邮局的处理组织
• Topic：区分音讯的品种；一个架构发送者能够发送音讯给一个或许多个Topic；一个音讯的接收者能够订阅一个或许多个Topic音讯
• Mhttp 500essage Queue：适当所以Topic的分http署理区；用于并行发送和接收音讯