1蕉扮、安裝RocketMQ

RocketMQ 安裝

官網(wǎng)http://rocketmq.apache.org/

1.安裝

需要先安裝環(huán)境所需要的工具: JDK汹来、Maven记舆。

構(gòu)建Dledger:

[root@localhost ~]# git clone https://github.com/openmessaging/openmessaging-storage-dledger.git
[root@localhost ~]# cd openmessaging-storage-dledger/
[root@localhost openmessaging-storage-dledger]# mvn clean install -DskipTests

構(gòu)建RocketMQ:

[root@localhost ~]# git clone https://github.com/apache/rocketmq.git
[root@localhost rocketmq]# cd rocketmq
[root@localhost rocketmq]# git checkout -b store_with_dledger origin/store_with_dledger
[root@localhost rocketmq]# mvn -Prelease-all -DskipTests clean install -U

修改文件:

[root@localhost rocketmq]# cd distribution/target/apache-rocketmq

分別修改三個文件: bin/runserver.sh院尔、 bin/runbroker.sh御板、 bin/tools.sh。

修改內(nèi)容如下:

找到以下三行虚吟,刪除后面的兩行寸认,并將第一行的值修改為 系統(tǒng)安裝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)!"
[root@localhost bin]# vim runserver.sh 
[root@localhost bin]# vim runbroker.sh 
[root@localhost bin]# vim tools.sh 

修改后如下:

[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java/jdk1.8.0_221

啟動RocketMQ:

[root@localhost apache-rocketmq]# sh bin/dledger/fast-try.sh start

上面的啟動指令會在當(dāng)前機(jī)器上啟動一個 nameserver 和三個 broker,三個 broker 其中一個是 master串慰,另外兩個是 slave偏塞,可以組成一個最小可用的 RocketMQ 集群。

檢查 RocketMQ 的集群狀態(tài):

[root@localhost apache-rocketmq]# sh bin/mqadmin clusterList -n 127.0.0.1:9876
最小的rocketMq集群狀態(tài)

如上模庐,說明 RocketMQ 集群啟動成功了。

BID 為 0 的就是 Master油宜, BID 大于 0 的就都是 Slave掂碱,其實(shí)這里也可以叫做 Leader 和 Follower怜姿。

嘗試 Slave 自動切換為 Master 。

三臺機(jī)器的地址分別是:

10.20.0.50:30931 (master)

10.20.0.50:30911

10.20.0.50:30921

通過 lsof -i:30931 (或者 netstat -tunlp | grep 30931 ) 找出對應(yīng)端口的進(jìn)程PID疼燥, kill -9 殺死進(jìn)程沧卢。然后再查看集群信息:

[root@localhost apache-rocketmq]# netstat -tunlp | grep 30931
tcp6       0      0 :::30931                :::*                    LISTEN      23484/java          
[root@localhost apache-rocketmq]# kill -9 23484
[root@localhost apache-rocketmq]# sh bin/mqadmin clusterList -n 127.0.0.1:9876

image-20210926141000831

此時可以看到 BID 為 0 的節(jié)點(diǎn),變成了另一個 Broker醉者,即 Slave 切換成了 Master但狭。

關(guān)閉的指令:

# sh bin/dledger/fast-try.sh stop

2.部署正式三臺 NameServer

按照上述步驟,安裝好JDK撬即、maven立磁,構(gòu)建好 Dledger 和 RocketMQ,編輯修改對應(yīng)的文件剥槐,設(shè)置 JAVA_HOME 即可唱歧。

啟動 NameServer :

[root@localhost apache-rocketmq]# nohup sh bin/mqnamesrv &

NameServer 監(jiān)聽的端口默認(rèn)是 9876。三臺設(shè)備上都啟動了 NameServer粒竖, 他們的端口就都是 9876颅崩。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市蕊苗,隨后出現(xiàn)的幾起案子沿后,更是在濱河造成了極大的恐慌,老刑警劉巖朽砰,帶你破解...
    沈念sama閱讀 221,820評論 6 515
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件尖滚,死亡現(xiàn)場離奇詭異,居然都是意外死亡锅移,警方通過查閱死者的電腦和手機(jī)熔掺,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 94,648評論 3 399
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來非剃,“玉大人置逻,你說我怎么就攤上這事”刚溃” “怎么了券坞?”我有些...
    開封第一講書人閱讀 168,324評論 0 360
  • 文/不壞的土叔 我叫張陵,是天一觀的道長肺素。 經(jīng)常有香客問我恨锚,道長,這世上最難降的妖魔是什么倍靡? 我笑而不...
    開封第一講書人閱讀 59,714評論 1 297
  • 正文 為了忘掉前任猴伶,我火速辦了婚禮,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘他挎。我一直安慰自己筝尾,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 68,724評論 6 397
  • 文/花漫 我一把揭開白布办桨。 她就那樣靜靜地躺著筹淫,像睡著了一般。 火紅的嫁衣襯著肌膚如雪呢撞。 梳的紋絲不亂的頭發(fā)上损姜,一...
    開封第一講書人閱讀 52,328評論 1 310
  • 那天,我揣著相機(jī)與錄音殊霞,去河邊找鬼摧阅。 笑死,一個胖子當(dāng)著我的面吹牛脓鹃,可吹牛的內(nèi)容都是我干的逸尖。 我是一名探鬼主播,決...
    沈念sama閱讀 40,897評論 3 421
  • 文/蒼蘭香墨 我猛地睜開眼瘸右,長吁一口氣:“原來是場噩夢啊……” “哼娇跟!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起太颤,我...
    開封第一講書人閱讀 39,804評論 0 276
  • 序言:老撾萬榮一對情侶失蹤苞俘,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后龄章,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體吃谣,經(jīng)...
    沈念sama閱讀 46,345評論 1 318
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,431評論 3 340
  • 正文 我和宋清朗相戀三年做裙,在試婚紗的時候發(fā)現(xiàn)自己被綠了岗憋。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 40,561評論 1 352
  • 序言:一個原本活蹦亂跳的男人離奇死亡锚贱,死狀恐怖仔戈,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情拧廊,我是刑警寧澤监徘,帶...
    沈念sama閱讀 36,238評論 5 350
  • 正文 年R本政府宣布,位于F島的核電站吧碾,受9級特大地震影響凰盔,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜倦春,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,928評論 3 334
  • 文/蒙蒙 一户敬、第九天 我趴在偏房一處隱蔽的房頂上張望落剪。 院中可真熱鬧,春花似錦尿庐、人聲如沸著榴。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,417評論 0 24
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至暮胧,卻和暖如春锐借,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背往衷。 一陣腳步聲響...
    開封第一講書人閱讀 33,528評論 1 272
  • 我被黑心中介騙來泰國打工钞翔, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人席舍。 一個月前我還...
    沈念sama閱讀 48,983評論 3 376
  • 正文 我出身青樓布轿,卻偏偏與公主長得像,于是被迫代替她去往敵國和親来颤。 傳聞我的和親對象是個殘疾皇子汰扭,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,573評論 2 359

推薦閱讀更多精彩內(nèi)容

  • 1、集群部署概述 1.1福铅、RocketMQ部署結(jié)構(gòu)圖: 各部分說明:(1)Producer:生產(chǎn)者(2)Consu...
  • RocketMQ介紹 Apache RocketMQ是一個分布式消息傳遞和流媒體平臺萝毛,具有低延遲、高性能和可靠性滑黔、...
    fantasymango閱讀 47,219評論 9 27
  • RocketMq4.x安裝及集群配置 單節(jié)點(diǎn)安裝RocketMQ4.x 本地環(huán)境需配置JAVA_HOME笆包,MAVE...
    方穹軒閱讀 962評論 0 1
  • 一. 認(rèn)識消息隊(duì)列 1. 隊(duì)列 隊(duì)列(queue)是只允許在一端進(jìn)行插入操作,而在另一端進(jìn)行刪除操作的線性表(數(shù)據(jù)...
    Serializable_dx閱讀 1,806評論 0 1
  • 我是黑夜里大雨紛飛的人啊 1 “又到一年六月略荡,有人笑有人哭庵佣,有人歡樂有人憂愁,有人驚喜有人失落汛兜,有的覺得收獲滿滿有...
    陌忘宇閱讀 8,544評論 28 53