RocketMQ的部署

1.机器上先安装java环境(安装JDK,maven等)

2.下载RocketMQ的源码来编译构建

执行如下命令来构建Dledger:

git clone https://github.com/openmessaging/openmessaging-storage-dledger.git
cd openmessaging-storage-dledger
mvn clean install -DskipTests

执行下面命令构建RocketMQ

git clone https://github.com/apache/rocketmq.git
cd rocketmq
##git checkout -b store_with_dledger origin/store_with_dledger 新版已经删除该分支,直接checkout 发布的release最新版本即可,或者自己选定的版本。
git checkout -b release-4.9.3 origin/release-4.9.3
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq

在上述目录中修改三个文件,一个是bin/runserver.sh,一个是bin/runbroker.sh,另一个是bin/tools.sh在里面找到如下三行,然后将第二行和第三行都删除掉,同时将第一行的值修改为自己的JDK的主目录。

[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"

注:查看JDK的目录命令:/usr/libexec/java_home -V,
执行下面的命令进行快速RocketMQ集群的启动

sh bin/dledger/fast-try.sh start

这个命令会在当前这台机器上启动一个NameServer和三个Broker,三个Broker其中一个是Master,另外两个是Slave,瞬间就可以组成一个最小的Rocker集群
使用以下命令检查一下RocketMQ的集群状态

sh bin/mqadmin clusterList -n 127.0.0.1:9876

image.png

看到如上图就说明启动成功了,BID为0的就是Master,BID大于0的就是Slave。
尝试slave自动切换为master

##找到master的进程号
lsof -i:30931
kill -9 58798 ##干掉它

通过上面查看集群状态的命令再次查看集群状态详情


image.png

3.完成正式的三台NameServer的部署

还是先在三台机器上安装java环境,以及根据上述步骤把RockerMQ和Dledger全都构建好。
启动NameServer

nohup sh mqnamesrv & ##NameServer监听的接口默认就是9876,

4.完成一组Broker集群的部署

同样的还是在机器上先安装好java环境以及构建好Dledger和RockerMQ,然后编辑好对应的文件。
执行如下命令:

nohup sh bin/mqbroker -c conf/dledger/broker-n0.conf &

注:第一个Broker的配置文件是broker-n0.conf,第二个broker的配置文件可以是broker-n1.conf,第三broker
的配置文件可以是broker-n2.conf。
对broker-n0.conf配置文件的说明:

brokerClusterName = RaftCluster
这个是集群的名称,你整个broker集群都可以用这个名称

brokerName=RaftNode00
这是Broker的名称,比如你有一个Master和两个Slave,那么他们的Broker名称必须是一样的,因为他们三个是一个分组,如果你有另外一组Master和两个Slave,你可以给他们起个别的名字,比如说RaftNode01

listenPort=30911
这个就是你的Broker监听的端口号,如果每台机器上就部署一个Broker,可以考虑就用这个端口号,不用修改

namesrvAddr=127.0.0.1:9876
这里是配置NameServer的地址,如果你有很多个NameServer的话,可以在这里写入多个NameServer的地址

storePathRootDir=/tmp/rmqstore/node00
storePathCommitLog=/tmp/rmqstore/node00/commitlog
下面两个目录是存放Broker数据的地方,你可以换成别的目录,类似于是/usr/local/rocketmq/node00之类的

enableDLegerCommitLog=true
这个是非常关键的一个配置,就是是否启用DLeger技术,这个必须是true

dLegerGroup=RaftNode00
这个一般建议和Broker名字保持一致,一个Master加两个Slave会组成一个Group

dLegerPeers=n0-127.0.0.1:40911;n1-127.0.0.1:40912;n2-127.0.0.1:40913
这个很关键,对于每一组Broker,你得保证他们的这个配置是一样的,在这里要写出来一个组里有哪几个Broker,比如在这里假设有三台机器部署了Broker,要让他们作为一个组,那么在这里就得写入他们三个的ip地址和监听的端口号

dLegerSelfId=n0
这个是代表了一个Broker在组里的id,一般就是n0、n1、n2之类的,这个你得跟上面的dLegerPeers中的n0、
n1、n2相匹配

sendMessageThreadPoolNums=24
这个是发送消息的线程数量,一般建议你配置成跟你的CPU核数一样,比如我们的机器假设是24核的,那么这里就修改成24核

其实最关键的是,你的Broker是分为多组的,每一组是三个Broker,一个Master和两个Slave。对每一组Broker,他们的Broker名称、Group名称都是一样的,然后你得给他们配置好一样的dLegerPeers(里面是组内三台Broker的地址)然后他们得配置好对应的NameServer的地址,最后还有就是每个Broker有自己的ID,在组内是唯一的就可以了,比如说不同的组里都有一个ID为n0的broker,这个是可以的。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,590评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 86,808评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,151评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,779评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,773评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,656评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,022评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,678评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 41,038评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,659评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,756评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,411评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,005评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,973评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,053评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,495评论 2 343

推荐阅读更多精彩内容

  • 本节将介绍生产就绪的部署解决方案。一般来说,我们将部署一个弹性的RocketMQ集群,没有单点故障。 先决条件 在...
    Kohler阅读 3,516评论 1 0
  • 这部分介绍生产环境部署方案。通常,部署弹性集群避免单点。 准备工作 在开始这部分前,拜托先阅读“Quick Sta...
    偷油考拉阅读 762评论 0 0
  • RocketMQ介绍 Apache RocketMQ是一个分布式消息传递和流媒体平台,具有低延迟、高性能和可靠性、...
    fantasymango阅读 47,181评论 9 27
  • RocketMQ总结 1 rocketmq是什么? 是一个队列模型的消息中间件,具有高性能、高可靠、高实时、分布式...
    随意多好阅读 6,162评论 1 14
  • 表情是什么,我认为表情就是表现出来的情绪。表情可以传达很多信息。高兴了当然就笑了,难过就哭了。两者是相互影响密不可...
    Persistenc_6aea阅读 124,060评论 2 7