跳到主要内容
版本：5.0

Java 客户端

版本说明​

本章节介绍使用 Apache RocketMQ 5.0 gRPC 协议 Java SDK 收发消息。

信息
  • 本示例代码基于gRPC 协议 SDK 构建，因此需要服务端至少升级到5.0版本，并启用 gRPC Proxy 才可兼容。关于Proxy的部署参考快速指南。
  • 如果您使用的是 Remoting 协议 SDK，建议参考之前4.x 版本的示例代码即可运行.如何识别您使用的 SDK 类型，参考概览。

示例代码​

下面给出 Apache RocketMQ gRPC 协议 Java SDK的消息收发示例代码链接，完整代码工程和运行环境，参照rocketmq-clients 配置运行。

消息类型发送消息示例PushConsumer消费消息示例SimpleConsumer消费消息示例
普通消息同步发送：ProducerNormalMessageExample.java
异步发送：AsyncProducerExample.java		PushConsumerExample.java同步订阅：SimpleConsumerExample.java
异步订阅：AsyncSimpleConsumerExample.java
顺序消息ProducerFifoMessageExample.javaPushConsumerExample.java同步订阅：SimpleConsumerExample.java
异步订阅：AsyncSimpleConsumerExample.java
定时/延时消息ProducerDelayMessageExample.javaPushConsumerExample.java同步订阅：SimpleConsumerExample.java
异步订阅：AsyncSimpleConsumerExample.java
事务消息ProducerTransactionMessageExample.javaPushConsumerExample.java同步订阅：SimpleConsumerExample.java
异步订阅：AsyncSimpleConsumerExample.java