标签：消息中间件 - 青云博客|记录、分享

标签
消息中间件

RocketMQ 的 Consumer 是如何消费消息的？

Java

RocketMQ的Consumer消费消息的方式有两种：Push方式和Pull方式。在 Push 推模式下，RocketMQ 的 Broker 会主动将消息推送给对应的 Consumer。而 Consumer 会注册一个 MessageListener 回调函数，并在接收到消息后立即触发回调函数。

RocketMQ 的广播消息和集群消息有什么区别？

Java

广播消息和集群消息是 RocketMQ 的两种不同的消息消费模式。其中广播模式意味着一条消息会被发送到所有订阅了这个主题 Topic 的消费者，而所有消费者都会收到相同的消息副本。集群模式意味着一条消息只会分发给订阅了这个主题 Topic 的同一个消费者组中的一个消费者处理。每个消费者组只会处理

RocketMQ 如何保证消息顺序？

Java

RocketMQ 提供了顺序消息机制，用来保证一组消息的局部有序性，具体实现步骤如下： Producer 在发送消息时，通过设置一个 MessageQueueSelector 方法，将一组有顺序的消息，依次发送到对应 Topic 下的同一个 MessageQueue 上。而 MessageQueue

RocketMQ 提供了哪些消息过滤的机制？

Java

RocketMQ消息过滤分为两种：基于表达式的过滤和基于类模式的过滤。基于表达式的过滤有两种模式：TAG模式和SQL92模式。其中，RocketMQ 允许为每一条消息设置一个 Tag 标签。 TAG 模式下，Consumer 可以选择订阅特定的 TAG，对消息进行过滤。TAG模式根据消息的属性进行

RocketMQ 如何保证消息不丢失？

Java

RocketMQ 可以通过一系列措施保证全链路消息不丢失。 producer 发送消息时，使用消息确认机制，确保消息被成功发送。例如，不要使用 oneway 发送方式。使用异步机制发送消息时，发送消息后要等待一段时间再停止 Producer。使用事务消息机制保证消息正常发送到 Broker。 Bro

RocketMQ 的事务消息是如何实现的？有什么用途？

Java

RocketMQ的事务消息是通过两阶段提交（Two-phase Commit）协议实现的。具体实现步骤如下：发送方将半事务消息发送至RocketMQ服务端，由于消息为半事务消息，在未收到生产者对该消息的二次确认前，此消息被标记成“暂不能投递”状态，不会被消费。发送方开始执行本地事务逻辑。可能是一

RocketMQ的消息存储如何进行清理和归档？

Java

RocketMQ 提供了消息存储清理和归档的机制，以便管理消息存储空间，删除过期消息，并将历史消息归档到其他存储介质中。这些功能有助于维护消息队列的性能和可用性。以下是关于 RocketMQ 消息存储清理和归档的主要方面：消息文件删除策略： RocketMQ 支持多种消息文件删除策略，可以在配置文

RocketMQ 的消息是如何进行存储的？

Java

RocketMQ是采用分布式存储的方式来存储消息的。每个Broker的存储结构主要包括：CommitLog、ConsumeQueue和IndexFile。 CommitLog是消息存储的物理文件，存储了所有消息的主题、标签、时间戳等基本信息和消息体。每个Broker上的CommitLog被当前机器上

RocketMQ消息积压会发生什么问题？如何避免？

Java

在RocketMQ中，如果未消费的消息过多，会给集群带来非常多的问题：消息堆积：消息在Broker端不断堆积，可能会导致Broker的存储压力过大，影响整个系统的性能和稳定性。死信队列

RocketMQ 延迟消息是如何实现的？

Java

RocketMQ的延迟消息实现是通过在消息发送时设置一个延迟级别，然后消息会被存储到DelayMessageService中，等待达到指定的延迟时间后再被重新推送到Broker的commitLog服务中。具体流程如下： Producer 将消息投递到Broker的commitLog服务。