没有合适的资源？快使用搜索试试~ 我知道了~

文库首页后端JavaRocketMQ面试中常见的问题及答案详解.docx

RocketMQ面试中常见的问题及答案详解.docx

1.该资源内容由用户上传，如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款（资源遇到问题，请及时私信上传者）

版权申诉

代码

0 下载量 166 浏览量 2022-07-10 10:15:27 上传评论收藏 32KB DOCX 举报

温馨提示

试读

14页

java开发，面向互联网集群化功能丰富，对在线业务的响应时延做了很多的优化，大多数情况下可以做到毫秒级的响应，每秒钟大概能处理几十万条消息。

资源推荐

资源详情

资源评论

1、多个 mq 如何选型？

描述

RabbitMQ

erlang 开发，对消息堆积的支持并不好，当大量消息积压的时候，会导致

RabbitMQ 的性能急剧下降。每秒钟可以处理几万到十几万条消息。

RocketMQ

java 开发，面向互联网集群化功能丰富，对在线业务的响应时延做了很多的优化，

大多数情况下可以做到毫秒级的响应，每秒钟大概能处理几十万条消息。

Kafka

Scala 开发，面向日志功能丰富，性能最高。当你的业务场景中，每秒钟消息数

量没有那么多的时候，Kafka 的时延反而会比较高。所以，Kafka 不太适合在线

业务场景。

ActiveMQ

java 开发，简单，稳定，性能不如前面三个。小型系统用也 ok，但是不推荐。

推荐用互联网主流的。

2、为什么要使用 MQ？

因为项目比较大，做了分布式系统，所有远程服务调用请求都是同步执行经常

出问题，所以引入了 mq

作用

描述

解耦

系统耦合度降低，没有强依赖关系

异步

不需要同步执行的远程调用可以有效提高响应时间

削峰

请求达到峰值后，后端 service 还可以保持固定消费速率消费，不会被压垮

3、RocketMQ 由哪些角色组成，每个角色作用和特点是

什么？

角色

作用

Nameserver

无状态，动态列表；这也是和 zookeeper 的重要区别之一。zookeeper 是有状

态的。

Producer

消息生产者，负责发消息到 Broker。

Broker

就是 MQ 本身，负责收发消息、持久化消息等。

Consumer

消息消费者，负责从 Broker 上拉取消息进行消费，消费完进行 ack。

4、RocketMQ 中的 Topic 和 JMS 的 queue 有什么区

别？

queue 就是来源于数据结构的 FIFO 队列。而 Topic 是个抽象的概念，每个 Topic

底层对应 N 个 queue，而数据也真实存在 queue 上的。

5、RocketMQ Broker 中的消息被消费后会立即删除

吗？

不会，每条消息都会持久化到 CommitLog 中，每个 Consumer 连接到 Broker

后会维持消费进度信息，当有消息消费后只是当前 Consumer 的消费进度

（CommitLog 的 offset）更新了。

追问：那么消息会堆积吗？什么时候清理过期消息？

4.6 版本默认 48 小时后会删除不再使用的 CommitLog 文件

� 检查这个文件最后访问时间

� 判断是否大于过期时间

� 指定时间删除，默认凌晨 4 点

源码如下：

/**

* {@link org.apache.rocketmq.store.DefaultMessageStore.CleanCommitLogService#is

TimeToDelete()}

private boolean isTimeToDelete() {

// when = "04";

String when = DefaultMessageStore.this.getMessageStoreConfig().getDeleteWhen(

);

// 是 04 点，就返回 true

if (UtilAll.isItTimeToDo(when)) {

return true;

}

// 不是 04 点，返回 false

return false;

}

/**

* {@link org.apache.rocketmq.store.DefaultMessageStore.CleanCommitLogService#de

leteExpiredFiles()}

private void deleteExpiredFiles() {

// isTimeToDelete()这个方法是判断是不是凌晨四点，是的话就执行删除逻辑。

if (isTimeToDelete()) {

// 默认是 72，但是 broker 配置文件默认改成了 48，所以新版本都是 48。

long fileReservedTime = 48 * 60 * 60 * 1000;

deleteCount = DefaultMessageStore.this.commitLog.deleteExpiredFile(72 * 60

* 60 * 1000, xx, xx, xx);

}

/**

* {@link org.apache.rocketmq.store.CommitLog#deleteExpiredFile()}

public int deleteExpiredFile(xxx) {

// 这个方法的主逻辑就是遍历查找最后更改时间+过期时间，小于当前系统时间的话就删了（也

就是小于 48 小时）。

return this.mappedFileQueue.deleteExpiredFileByTime(72 * 60 * 60 * 1000, xx, xx,

xx);

}

7、RocketMQ 消费模式有几种？

消费模型由 Consumer 决定，消费维度为 Topic。

剩余13页未读，继续阅读

评论收藏

内容反馈

1.该资源内容由用户上传，如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款（资源遇到问题，请及时私信上传者）

版权申诉

资源评论

资源反馈

评论星级较低，若资源使用遇到问题可联系上传者，3个工作日内问题未解决可申请退款~

小兔子平安

粉丝: 209
资源: 1940

上传资源快速赚钱

我的内容管理展开

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

前往需求广场，查看用户热搜

RocketMQ面试中常见的问题及答案详解.docx

土木工程研究生面试问题及答案(3).docx

高级信息系统项目管理师下午2018上半年真题及答案解析.docx

面试问题及答案英语.docx

面试问题及答案 英文.docx

(全新整理)1月浙江单片机原理及应用自考试题及答案解析.docx

大学部门面试常见问题及答案收集.docx

2023JVM面试题及答案共32道.docx

(完整版)运维面试题(含答案).docx

电动力学典型试题分析-证明题和答案解析.docx

机械工程测试技术基础试题(卷)与答案解析.docx

《国家开放大学学习指南》网上做作业的方法和参考答案详解.docx

2020最新5G试题屏南某通讯服务公司面试试题(含答案).docx

2020最新5G基础大田某动通信有限公司二面试题(含答案).docx

SQL数据库经典面试题(修改笔试题)(有答案).docx.docx

面试英文问题及答案.docx

最新web前端面试题(及答案).docx

上海长宁区妇幼保健院2019年招聘人员试题及答案解析.docx

面试问题及答案英文版.docx

Java第十五届蓝桥杯大赛软件JavaB组真题

SwitchHosts

安卓期末大作业（AndroidStudio开发），垃圾分类助手app，分为前台后台，代码有注释，均能正常运行

Notepad++安装包

2024北森能力测评题库.7z

微信小程序源码-合集1.rar

Java面试八股文2023最新版

Linux Centos7 升级最新版OpenSSH-9.6p1 有脚本（支持离线）

JDK1.8 windows 64位

ruoyi-vue-pro 芋道源码项目的表结构

最新资源

面试问题及答案英文.docx