跳到主要内容
版本: 5.0

Java 客户端 SDK

信息​

本节介绍了如何使用 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
FIFO 消息ProducerFifoMessageExample.javaPushConsumerExample.java同步订阅消息： SimpleConsumerExample.java
异步订阅消息： AsyncSimpleConsumerExample.java
延时消息ProducerDelayMessageExample.javaPushConsumerExample.java同步订阅消息： SimpleConsumerExample.java
异步订阅消息： AsyncSimpleConsumerExample.java
事务消息ProducerTransactionMessageExample.javaPushConsumerExample.java同步订阅消息： SimpleConsumerExample.java
异步订阅消息： AsyncSimpleConsumerExample.java