rocketmq面试题及答案

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.如何保证