Service Provider Interface Introduction eventmesh-spi module EventMeshSPI EventMeshExtensionFactory ExtensionClassLoader SPI use case Service Provider Interface Introduct...

6 消息查询 6.1 按照MessageId查询消息 6.2 按照Message Key查询消息 6 消息查询 RocketMQ支持按照下面两种维度（“按照Message Id查询消息”、“按照Message Key查询消息”）进行消息查询。 6.1 按照MessageId查询消息 RocketMQ中的MessageId的长度总共有16字节...

Service Provider Interface Introduction eventmesh-spi module EventMeshSPI EventMeshExtensionFactory ExtensionClassLoader SPI use case Service Provider Interface Introduct...

3 消息过滤 3 消息过滤 RocketMQ分布式消息队列的消息过滤方式有别于其它MQ中间件，是在Consumer端订阅消息时再做消息过滤的。RocketMQ这么做是在于其Producer端写入消息和Consumer端订阅消息采用分离存储的机制来实现的，Consumer端订阅消息是需要通过ConsumeQueue这个消息消费的逻辑队列拿到一个索引，然...

定时/延时消息 应用场景 功能原理 使用限制 使用示例 使用建议 定时/延时消息 定时/延时消息为 Apache RocketMQ 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。 备注 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻将消息投递给消费者消费。因此，...

消费进度管理 背景信息 消费进度原理 重置消费位点 版本兼容性 使用建议 消费进度管理 Apache RocketMQ 通过消费位点管理消费进度，本文为您介绍 Apache RocketMQ 的消费进度管理机制。 背景信息 Apache RocketMQ 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...

顺序消息 应用场景 功能原理 使用限制 使用示例 使用建议 顺序消息 顺序消息为 Apache RocketMQ 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。 应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，上游的事件变更需要按照顺序传递到下游...

Java 客户端 版本说明 示例代码 Java 客户端 版本说明 本章节介绍使用 Apache RocketMQ 5.0 gRPC 协议 Java SDK 收发消息。 信息 本示例代码基于gRPC 协议 SDK 构建，因此需要服务端至少升级到5.0版本，并启用 gRPC Proxy 才可兼容。关于Proxy的部署参考快速指南 。 如果您使用...

EventMesh Runtime 1 Run on your local machine 1.1 Run from source code 1.1.1 Dependencies 1.1.2 Download source code 1.1.3 Run form local 1.2 Run form local binary 1.1.1 Depend...

EventMesh Runtime 快速开始 1. 部署二进制发行版 1.1 环境 1.2 下载 1.3 配置 1.3.1 EventMesh Runtime 配置 1.3.2 事件存储配置 1.4 启动 2. 构建二进制分发包 2.1 环境 2.2 下载 2.3 构建 在 JDK8 环境运行 在 JDK11 环境运行 2.4 打包插...