消息队列面试连环问:如何保证消息不丢失?处理重复消息?消息有序性?消息堆积处理?(下)

消息队列面试连环问:如何保证消息不丢失?处理重复消息?消息有序性?消息堆积处理?(下)

如何保证消息不丢失就我们市面上常见的消息队列而言,只要配置得当,我们的消息就不会丢。先来看看这个图,可以看到一共有三个阶段,分别是生产消息、存储消息和消费消息。我们从这三个阶段分别入手来看看如何确保消息不会丢失。生产消息生产者发送消息至Broker,需要处理Broker的响应,不论是同步还是异步发送...

消息队列面试连环问:如何保证消息不丢失?处理重复消息?消息有序性?消息堆积处理?(上)

消息队列面试连环问:如何保证消息不丢失?处理重复消息?消息有序性?消息堆积处理?(上)

大家好,我是 yes。最近我一直扎在消息队列实现细节之中无法自拔,已经写了 3 篇Kafka源码分析,还剩很多没肝完。之前还存着RocketMQ源码分析还没整理。今儿暂时先跳出来盘一盘大方向上的消息队列有哪些核心注意点。核心点有很多,为了更贴合实际场景,我从常见的面试问题入手:如何保证消息不丢失?如...

带您快速了解阿里云消息队列RocketMQ 5.0版

5 课时 |
456 人已学 |
免费

消息队列RabbitMQ入门课程

3 课时 |
4296 人已学 |
免费

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费
开发者课程背景图
消息队列面试解析系列(七)- 数据压缩(下)

消息队列面试解析系列(七)- 数据压缩(下)

4 压缩分段选型大部分压缩算法区别主要是,对数据进行编码的算法,压缩的流程和压缩包的结构大致一样。而在压缩过程中,你最需要了解的就是如何选择合适的压缩分段。压缩时,给定的被压缩数据它必须有确定长度,或是有头有尾的,不能是个无限数据流,若要对流数据压缩,必须把流数据划分成多帧࿰...

消息队列面试解析系列(七)- 数据压缩(上)

1 数据压缩意义Kafka使用数据压缩,最高可提升约几十倍吞吐量。数据压缩不仅可节省存储空间,还可用于提升网络传输性能。这种使用压缩提升系统性能的方法,不仅在MQ使用,日常开发也可。比如传输大量数据或要在磁盘、数据库中存储较大数据,这些情况下,都可考虑使用数据压缩提升性能,还能节省网络带宽和存储空间...

消息队列面试解析 - 传输协议(下)

2 双工收发2.1 单工通信任一时刻,数据只能单向传输,一个人说时,另一个人只能听。HTTP 1.0协议就是这样,客户端与服务端建立个连接后,客户端发个请求,直到服务端返回响应或请求超时,这段时间内,这个连接通道上不能再发其他请求。这种单工通信,效率低,很多...

消息队列面试解析 - 传输协议(上)

0 前言应用程序之间要想互相通信,一起配合来实现业务功能,还需传输协议支持。传输协议就是应用程序之间对话的语言。设计传输协议,并无太多规范和要求,只需通信双方的应用程序都能正确处理该协议&&无歧义。1 断句1.1 分隔符传输协议也是种语言,传输数据时,首要解决的就是断句。对传输层,收...

消息队列面试解析系列(六)- 异步编程妙用(下)

异步实现的性能由于流程时序和同步一样,在少量请求场景下,平均响应时延一样100ms。在高请求数量场景下,异步不再需线程等待执行结果,只需个位数量的线程,即可实现同步场景大量线程一样的吞吐量。由于没线程的数量的限制,总体吞吐量上限会大大超过同步实现,且在服务器CPU、网络带宽资源达到极限前࿰...

消息队列面试必问解析(下)

消息队列面试必问解析(下)

2 RocketMQ和Kafka的消息模型这两个消息队列产品的消息模型是一样的。通过具体案例再次讲解下。假设有一主题MyTopic,为主题创建5个队列,分布到俩Broker。消息生产端设有3个生产者实例:Produer0、Produer1、Producer2。这3生产者如何对应到2Broker,又如...

消息队列面试必问解析(上)

消息队列面试必问解析(上)

示例流程网关发送消息之后,如何接收后端服务的秒杀结果,又如何给APP返回响应呢?网关接收后端服务秒杀结果,实现方式不只一种,这里给个简单方案。public class RequestHandler { // ID生成器 @Inject private IdGenerator idGenerator;...

消息队列面试解析系列(三)-消息模型辨析(下)

消息队列面试解析系列(三)-消息模型辨析(下)

RabbitMQ消息模型少数依然坚持使用队列模型的产品之一。怎么解决多消费者问题的?RabbitMQ中,Exchange位于生产者和队列间,生产者并不关心将消息发给哪个队列,而将消息发送给Exchange,由Exchange策略决定将消息投递到哪些队列。同份消息若需被多消费者消费,需配置Exchan...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

社区圈子

阿里中间件
阿里中间件
为企业提供高效、稳定、易扩展的中间件产品
164948+人已加入
加入
相关电子书
更多
阿里云消息队列的 Serverless架构演进
云原生开源开发者沙龙深圳站PPT合辑(微服务x消息队列专场)
消息队列 Kafka 版差异化特性
立即下载 立即下载 立即下载