RocketMQ叢集搭建1
阿新 • • 發佈：2021-06-19
1.各角色介紹
Producer：訊息的傳送者。舉例：發信者
Consumer：訊息的接收者。舉例：收信者
Broker：暫存和傳輸訊息。舉例：郵局
NameServer：管理Broker。舉例：各個郵局的管理機構（有點類似微服務的註冊中心）
Topic：區分訊息的種類。一個傳送者可以傳送訊息給一個或多個Topic；一個訊息的接收者可以訂閱一個或者多個Topic訊息
Message Queue：相當於Topic的分割槽，用去並行傳送和接收訊息
2.伺服器環境
| 序號 | IP | 角色 | 架構模式 |
| 1 | 192.168.100.128 | nameserver brokerserver | Master1.Slave2 |
| 2 | 192.168.100.129 | nameserver brokerserver | Master2.Slave1 |
3.Host新增資訊
vim /etc/hosts
配置如下：
# nameserver 192.168.100.128 rocketmq-nameserver1 192.168.100.129 rocketmq-nameserver2 # broker 192.168.100.128 rocketmq-master1 192.168.100.128 rocketmq-slave2 192.168.100.129 rocketmq-master2 192.168.100.129 rocketmq-slave1
重啟網絡卡
systemctl restart network
4.防火牆配置
防火牆配置有兩種方式
1.直接簡單粗暴關閉防火牆（測試用）
# 關閉防火牆 systemctl stop firewalld.service # 檢視防火牆狀態 firewall-cmd --state # 禁止防火牆開機啟動 systemctl disable firewalld.service
2.為了安全起見只開放特定的埠號,RocketMQ預設使用3個埠：9876、10911、11011。如果防火牆沒有關閉的話必須開放下面的埠（生產用）
nameserver 預設使用9876
master 預設使用10911
slave 預設使用11011
# 開放name server預設埠 firewalld-cmd --remove-port=9876/tcp --permanent # 開放master預設埠 firewalld-cmd --remove-port=10911/tcp --permanent # 開放slave預設埠 firewalld-cmd --remove-port=11011/tcp --permanent # 重啟防火牆 firewall-cmd --reload
5.設定環境變數，並執行
# set rocketmq export ROCKET_HOME=/usr/local/rocketmq/rocketmq-all-4.8.0-bin-release export PATH=$PATH:$ROCKET_HOME/bin
6.建立訊息儲存路徑
mkdir /usr/local/rocketmq/store mkdir /usr/local/rocketmq/store/commitlog mkdir /usr/local/rocketmq/store/consumequeue mkdir /usr/local/rocketmq/store/index