Docker部署单机RocketMQ（解决NameServer获取Borker地址为容器内部ip问题）

部署NameServer docker pull rocketmqinc/rocketmq:4.4.0 docker run --name rmqnamesrv -d -p 9876:9876 --restart=always rocketmqinc/rocketmq:4.4.0 sh mqname

作者：青云发布时间：2024-05-12

分类： Docker

标签： #docker , #rocketmq

RocketMQ 的 Producer 是如何发送消息的？

RocketMQ的Producer有三种消息发送模式：同步发送（Sync Send）：这是默认的发送模式。在同步发送模式下，发送者发送一条消息后会等待 Broker 的响应，直到 Broker 确认收到消息并返回结果。如果发送失败，将会抛出异常。这种模式下，Producer 可以确保消息成功发送到

作者：zhanxuewei 发布时间：2024-04-23

分类： Java

标签： #消息中间件 , #rocketmq

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

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

作者：zhanxuewei 发布时间：2024-04-23

分类： Java

标签： #消息中间件 , #rocketmq

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

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

作者：zhanxuewei 发布时间：2024-04-23

分类： Java

标签： #消息中间件 , #rocketmq

RocketMQ 如何保证消息顺序？

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

作者：zhanxuewei 发布时间：2024-04-23

分类： Java

标签： #消息中间件 , #rocketmq

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

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

作者：zhanxuewei 发布时间：2024-04-23

分类： Java

标签： #消息中间件 , #rocketmq

RocketMQ 如何保证消息不丢失？

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

作者：zhanxuewei 发布时间：2024-04-23

分类： Java

标签： #消息中间件 , #rocketmq

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

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

作者：zhanxuewei 发布时间：2024-04-23

分类： Java

标签： #消息中间件 , #rocketmq

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

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

作者：zhanxuewei 发布时间：2024-04-23

分类： Java

标签： #消息中间件 , #rocketmq

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

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

作者：zhanxuewei 发布时间：2024-04-23

分类： Java

标签： #消息中间件 , #rocketmq