上一篇 <<<RocketMQ單機(jī)版本安裝
下一篇 >>>RocketMQ單機(jī)做主備實操
1.RocketMQ集群類型
a、nameServer（注冊中心存放mq服務(wù)地址信息）集群----需要將nameserver全部啟動起來，然后broker需要配置多個nameserver窃诉，并連接到多個nameserver
b焰薄、broker（MQ服務(wù)端）集群-----nameserver可以只啟動一個，但broker啟動的時候，需要連到同一個nameserver
2.四種集群部署方式
a.單個Master節(jié)點， 缺點:負(fù)載壓力大，如果宕機(jī)的話即供，數(shù)據(jù)會丟失
b.多個Master節(jié)點，分?jǐn)偞娣盼覀兊南⒂谖ⅲ秉c：沒有Slave節(jié)點逗嫡，主的Master節(jié)點宕機(jī)之后消息數(shù)據(jù)可能會丟失的；
c.多個Master和Slave節(jié)點 采用同步形式株依，效率比較低,但數(shù)據(jù)不會丟失驱证，也不會產(chǎn)生延遲。
d.多個Master和Slave節(jié)點 采用異步形式恋腕，效率非常高抹锄，但數(shù)據(jù)可能產(chǎn)生短暫延遲（毫秒級別的），也可能會出現(xiàn)數(shù)據(jù)丟失
3.集群結(jié)構(gòu)圖
1.Topic是大目錄荠藤，隊列是topic的子集伙单。
2.每個主題在不同的broker上默認(rèn)都有4個生產(chǎn)者隊列和4個消費者隊列，可通過配置修改：
defaultTopicQueueNums=4
4.程序默認(rèn)不走集群
由程序創(chuàng)建的主題能看到8個不同的隊列哈肖，但是不會集群的吻育，也就是不會投遞到不同的集群隊列上。
5.集群生效設(shè)置
如果程序想走集群的主題淤井，可先創(chuàng)建主題布疼，配置集群信息，然后配置到代碼中币狠。
6.生產(chǎn)者投遞消息的算法
- 隨機(jī)
- 輪詢
消費者獲取消息 brokerName: broker-a topic:tp1231001 queueId:2,隊列id：2, 消息迦葉msgid:0A2581022BB718B4AAC29EE525C50000
消費者獲取消息 brokerName: broker-a topic:tp1231001 queueId:0,隊列id：0, 消息迦葉msgid:0A2581022BB718B4AAC29EE525C50000
消費者獲取消息 brokerName: broker-a topic:tp1231001 queueId:1,隊列id：1, 消息迦葉msgid:0A2581022BB718B4AAC29EE525C50000
消費者獲取消息 brokerName: broker-a topic:tp1231001 queueId:3,隊列id：3, 消息迦葉msgid:0A2581022BB718B4AAC29EE525C50000
- hash—可保證消息的順序性
推薦閱讀：
<<<消息中間件的核心思想
<<<消息中間件常見問題匯總
<<<基于Netty簡單手寫消息中間件思路
<<<消息隊列常用名詞與中間件對比
<<<Rabbitmq基礎(chǔ)知識
<<<Rabbitmq示例之點對點簡單隊列
<<<Rabbitmq示例之工作(公平)隊列
<<<Rabbitmq示例之發(fā)布訂閱模式
<<<Rabbitmq示例之路由模式Routing
<<<Rabbitmq示例之通配符模式Topics
<<<Rabbitmq示例之RPC模式
<<<Rabbitmq隊列模式總結(jié)
<<<Rabbitmq如何保證消息不丟失
<<<Springboot利用AmqpTemplate整合Rabbitmq
<<<Rabbitmq如何保證冪等性
<<<Rabbitmq的重試策略
<<<Rabbitmq通過死信隊列實現(xiàn)過期監(jiān)聽
<<<Rabbitmq解決分布式事務(wù)思路
<<<Rabbitmq解決分布式事務(wù)demo
<<<Rabbitmq環(huán)境安裝
<<<Kafka中的專業(yè)術(shù)語都有哪些
<<<Kafka的設(shè)計原理介紹
<<<Kafka集群如何實現(xiàn)相互感知
<<<Kafka如何實現(xiàn)分區(qū)及指定分區(qū)消費
<<<Kafka如何保證消息順序消費
<<<Kafka如何保證高吞吐量
<<<Kafka集群環(huán)境搭建
<<<RocketMQ架構(gòu)原理
<<<RocketMQ游两、RabbitMQ和Kafka的對比
<<<SpringBoot整合RocketMQ示例
<<<RocketMQ保證順序消費demo
<<<RocketMQ如何動態(tài)擴(kuò)容和縮容
<<<RocketMQ如何解決分布式事務(wù)
<<<RocketMQ單機(jī)版本安裝
<<<RocketMQ單機(jī)做主備實操
<<<RocketMQ所有配置說明
