RocketMQ的Producer有三种消息发送模式： 同步发送（Sync Send）：这是默认的发送模式。在同步发送模式下，发送者发送一条消息后会等待 Broker 的响应，直到 Broker 确认收到消息并返回结果。如果发送失败，将会抛出异常。这种模式下，Producer 可以确保消息成功发送到
发布于 2024-04-23
RocketMQ的Consumer消费消息的方式有两种：Push方式和Pull方式。 在 Push 推模式下，RocketMQ 的 Broker 会主动将消息推送给对应的 Consumer。而 Consumer 会注册一个 MessageListener 回调函数，并在接收到消息后立即触发回调函数。
发布于 2024-04-23
广播消息和集群消息是 RocketMQ 的两种不同的消息消费模式。其中 广播模式意味着一条消息会被发送到所有订阅了这个主题 Topic 的消费者，而所有消费者都会收到相同的消息副本。 集群模式意味着一条消息只会分发给订阅了这个主题 Topic 的同一个消费者组中的一个消费者处理。每个消费者组只会处理
发布于 2024-04-23
RocketMQ 提供了顺序消息机制，用来保证一组消息的局部有序性，具体实现步骤如下： Producer 在发送消息时，通过设置一个 MessageQueueSelector 方法，将一组有顺序的消息，依次发送到对应 Topic 下的同一个 MessageQueue 上。而 MessageQueue
发布于 2024-04-23
RocketMQ消息过滤分为两种：基于表达式的过滤和基于类模式的过滤。 基于表达式的过滤有两种模式：TAG模式和SQL92模式。其中，RocketMQ 允许为每一条消息设置一个 Tag 标签。 TAG 模式下，Consumer 可以选择订阅特定的 TAG，对消息进行过滤。TAG模式根据消息的属性进行
发布于 2024-04-23
RocketMQ 可以通过一系列措施保证全链路消息不丢失。 producer 发送消息时，使用消息确认机制，确保消息被成功发送。例如，不要使用 oneway 发送方式。使用异步机制发送消息时，发送消息后要等待一段时间再停止 Producer。使用事务消息机制保证消息正常发送到 Broker。 Bro
发布于 2024-04-23
RocketMQ的事务消息是通过两阶段提交（Two-phase Commit）协议实现的。具体实现步骤如下： 发送方将半事务消息发送至RocketMQ服务端，由于消息为半事务消息，在未收到生产者对该消息的二次确认前，此消息被标记成“暂不能投递”状态，不会被消费。 发送方开始执行本地事务逻辑。可能是一
发布于 2024-04-23
RocketMQ 提供了消息存储清理和归档的机制，以便管理消息存储空间，删除过期消息，并将历史消息归档到其他存储介质中。这些功能有助于维护消息队列的性能和可用性。以下是关于 RocketMQ 消息存储清理和归档的主要方面： 消息文件删除策略： RocketMQ 支持多种消息文件删除策略，可以在配置文
发布于 2024-04-23
RocketMQ是采用分布式存储的方式来存储消息的。每个Broker的存储结构主要包括：CommitLog、ConsumeQueue和IndexFile。 CommitLog是消息存储的物理文件，存储了所有消息的主题、标签、时间戳等基本信息和消息体。每个Broker上的CommitLog被当前机器上
发布于 2024-04-23
RocketMQ的延迟消息实现是通过在消息发送时设置一个延迟级别，然后消息会被存储到DelayMessageService中，等待达到指定的延迟时间后再被重新推送到Broker的commitLog服务中。 具体流程如下： Producer 将消息投递到Broker的commitLog服务。
发布于 2024-04-23
