博文纲领：
消息队列面试题汇总,必须得看
RabbitMQ 的交换器类型包括：direct、topic、fanout、headers 等。1 如何确保每个消息能被消费？RabbitMQ 使用 ACK 确认机制来确保消息被正确消费。1 消息接收到后是否必须消费？消息接收到后不一定需要立即消费。在未确认消费前，消息可被重试。
如何解决消息队列的延时以及过期失效问题？ 通过设置消息的过期时间（TTL），RabbitMQ会自动在消息过期后删除，从而解决过期失效问题。对于延时，可以使用延迟队列（如RabbitMQ的死信队列配合死信策略）来实现，确保消息在特定时间后才被处理。
Partition：Kafka中数据的逻辑分区。Replica：Partition的副本，用于提高数据可靠性。Log：Partition中存储的消息序列。LogSegment：Log的物理分段，便于管理和优化。消息写入与消费流程 写入消息流程：计算消息偏移量，存储消息，优化磁盘读写效率。
RabbitMQ 通过确认机制确保每个消息被正确消费，开发者可选择手动确认。RabbitMQ 接收到消息后不一定需要立即消费，可以等待确认，避免不期望的消费行为。在 topic 模式下，发布路由键为“com.mq.rabbit.error”的消息，选项 C 不能接收到消息。
【348期】面试官:Kafka和RocketMQ有什么区别?
在存储对比方面，Kafka与RocketMQ的主要区别体现在消息体的存储方式和索引文件的管理上。Kafka将每个消息体独立存储于多个文件中，而RocketMQ则将消息体与存储地址分开处理，通过优化文件系统缓存策略（pagecache）来提升性能。
几种常见的消息队列介绍
消息队列通常包括以下分类：队列、主题、发布/订阅模式、点对点模式等。它们在消息的存储、传递和消费方面有不同的特性和应用场景。以下是一些常见的消息队列中间件及其特点： RabbitMQ 作为一个广泛使用的开源消息队列，RabbitMQ基于Erlang编写，遵循AMQP协议，支持多种传输协议。
从而实现高性能、高可用与可扩展架构。常见的消息队列包括ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ与RocketMQ。接下来，我们将探讨消息队列在实际应用中的四大使用场景：异步处理、应用解耦、流量削峰以及日志处理。
消息队列主要有以下几种： RabbitMQ：RabbitMQ是一个开源的消息代理软件，用于实现消息的路由、队列和可靠传输。它提供了多种消息传递模式和扩展功能，如消息的持久化、消息确认和消息优先级等。它支持多种语言，广泛用于企业级应用。
ZeroMQ 介绍：ZeroMQ被誉为“史上最快的”消息队列，提供了一套类似于Socket的接口，能够实现多对多的网络通信，简化了传统Socket编程的复杂性。 入门教程：官方文档和教程提供了从基础到进阶的全面指南，帮助开发者快速上手ZeroMQ。
消息队列可以按照不同的标准分类，这里我们关注几个常见的MQ类型：1 **ActiveMQ ActiveMQ 是一个开源的、高性能的、可移植的消息中间件，支持多种协议，包括JMS、AMQP等。它适用于需要高可用性和可扩展性的应用场景。2 **Kafka Kafka 是一款由Apache开源的分布式消息系统，专为大数据处理而设计。
消息队列概览 消息队列是一种异步服务间通信方式，支持无服务器和微服务架构，是实现分布式系统高级特性的关键组件。常见的主流消息队列包括ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ、Pulsar等。
消息队列kafka详解:Kafka重要知识点+面试题大全
Kafka中的消费者以组为单位进行消费，每个消费者组内的消费者负责消费不同的Partition，以实现负载均衡。消费者组：存在意义：提高消费效率，实现负载均衡，保证消息的顺序性。作用：通过增加消费者数量来并行消费，同时确保每个Partition只被一个消费者消费，以维护消息的顺序。
Kafka高可用性、可靠性和一致性的实现机制。解释Kafka通过Leader选举、ISR列表、最小同步副本数（min.insync.replicas）等机制实现高可用性；以及通过高水位（HW）和一致性检查保证数据的可靠性和一致性。Kafka性能优化技术。探讨Kafka利用顺序写入、零拷贝技术以及压缩协议等方法提高数据处理速度和效率。
Kafka是分布式发布-订阅消息系统，最初由LinkedIn开发，后成为Apache项目的一部分。它用于处理流式数据，是一个分布式、可划分、冗余备份的持久日志服务。为什么要使用kafka和消息队列？缓冲和削峰：缓冲上游突发流量，下游从容处理。解耦和扩展性：消息队列作为接口层，解耦业务流程，提供扩展能力。
Kafka中有四个主要组件：主题、生产者、消费者和经纪人。主题是一堆或一组消息的集合；生产者发布通信并向Kafka主题发布消息；消费者订阅一个主题并从主题中读取和处理消息；经纪人负责管理主题中的消息存储。
选项 C：direct 交换器支持获取历史消息。1 RabbitMQ 是否包含事务功能？如何使用？RabbitMQ 支持事务，主要通过配置通道来实现。1 RabbitMQ 的事务在什么情况下无效？当设置 autoAck=true 时，事务功能将失效。
本文内容主要整理自朱小厮的博客，旨在检验最近的学习成果。对于问题的解释如下： **Kafka用途**：- 异步处理 - 系统解耦 - 削峰填谷 - 提速 - 广播机制 - 应用于消息传输、网站活动追踪、监测指标、日志聚合、流处理、事件采集、提交日志等场景。