rocketmq面試題及答案

一、單項選擇題（每題2分，共20分）1.RocketMQ默認的NameServer端口是？A.9876B.10911答案：A2.RocketMQ生產者發送消息的方式不包括？A.同步B.異步C.無序答案：C3.以下哪個是RocketMQ的存儲文件？A.commitlogB.log4j答案：A4.RocketMQ消費者拉取消息間隔默認是？A.1秒B.30秒答案：B5.RocketMQ中的Topic由誰創建？A.NameServerB.Broker答案：B6.RocketMQ支持的消息類型不包括？A.普通消息B.事務消息C.HTTP消息答案：C7.RocketMQ消費者獲取消息的模式是？A.pushB.push和pull答案：B8.哪個組件負責存儲RocketMQ的元數據？A.NameServerB.Producer答案：A9.RocketMQ版本號第一位數字代表？A.主版本B.次版本答案：A10.RocketMQ的持久化機制基于？A.文件系統B.內存答案：A二、多項選擇題（每題2分，共20分）1.RocketMQ的核心組件有？A.NameServerB.BrokerC.ProducerD.Consumer答案：ABCD2.RocketMQ支持的消息發送策略包括？A.輪詢B.隨機C.哈希答案：AC3.以下哪些是RocketMQ的持久化方式？A.異步刷盤B.同步刷盤答案：AB4.RocketMQ的消息過濾方式有？A.標簽過濾B.SQL92過濾答案：AB5.NameServer存儲的信息包括？A.Broker元數據B.Topic元數據答案：AB6.RocketMQ消費者分組的作用有？A.負載均衡B.消息重試答案：AB7.RocketMQ事務消息的階段包括？A.半消息B.提交消息C.回滾消息答案：ABC8.Producer發送消息時可設置的參數有？A.超時時間B.消息內容答案：AB9.RocketMQ中實現消息順序消費的條件有？A.相同TopicB.相同隊列答案：AB10.Broker存儲的文件類型有？A.commitlogB.consumequeue答案：AB三、判斷題（每題2分，共20分）1.RocketMQ中NameServer和Broker之間采用長連接通訊。（）答案：對2.RocketMQ生產者必須要設置NameServer地址。（）答案：對3.消費者分組名稱可以隨意設置。（）答案：錯4.RocketMQ所有消息都必須保證嚴格順序。（）答案：錯5.Broker重啟后，之前的消息會丟失。（）答案：錯6.Topic中的消息隊列數量創建后不能更改。（）答案：錯7.RocketMQ支持消息重試次數是無限的。（）答案：錯8.Producer發送事務消息時可以不進行回查。（）答案：錯9.消息隨機存儲在Broker的不同隊列。（）答案：對10.RocketMQ不支持集群部署。（）答案：錯四、簡答題（每題5分，共20分）1.簡述RocketMQ消息發送的主要流程。答案：Producer啟動后，先獲取NameServer地址找到對應Broker。構造消息，選擇發送方式（同步、異步等），根據負載均衡算法選隊列，將消息發至Broker的對應隊列，Broker持久化消息。2.說明RocketMQ消費者的工作原理答案：消費者啟動連接NameServer獲取Broker信息，按分組拉取消息。采用push或pull模式，從Broker的consumequeue獲取消息，根據負載均衡在組內分配隊列，處理消息且記錄消費進度。3.解釋RocketMQ持久化機制的重要性答案：持久化保證消息可靠性，Broker崩潰重啟消息不丟失。如commitlog文件記錄消息全量數據，異步或同步刷盤確保消息寫入盤，保證消息持久存儲，為系統穩定運行提供保障。4.簡述RocketMQ消息過濾機制答案：支持標簽過濾和SQL92過濾。標簽過濾基于消息設置標簽篩選。SQL92過濾可定義復雜條件，如比較數字、字符串等，Broker根據過濾規則篩選符合條件消息推送至消費者。五、討論題（每題5分，共20分）1.在高并發場景下如何優化RocketMQ的性能？答案：合理設置NameServer、Broker數量，采用集群部署。優化生產者發送與消費者拉取策略，生產者批量發送消息、消費者合理設置線程數并行消費。調整存儲層刷盤等參數、優化消息隊列數量及負載均衡策略。2.談談RocketMQ在分布式系統中的應用場景及優勢答案：應用場景有異步處理、解耦系統模塊、流量削峰等。優勢在于性能高、可靠性強、支持分布式部署，提供豐富消息類型（如事務消息），多隊列設計及負載均衡機制，保障分布式系統高效、穩定運行。3.針對RocketMQ的高可用方案進行討論答案：NameServer多實例部署防止單點故障。Broker主從架構，主節點故障從節點切換提供服務。消息持久化確保節點故障消息不丟失，消費端支持自動重試重新拉取消息，保障系統可用性和消息處理連貫性。4.如何保證