RocketMQ 5.x系列的Java SDK消息收发示例代码_云消息队列 RocketMQ 版(RocketMQ)-阿里云帮助中心

本文介绍Apache RocketMQ Java SDK的消息收发示例代码。

示例代码

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

Serverless版实例公网访问版本说明

Serverless版实例使用公网访问接入云消息队列 RocketMQ 版时，需要保证使用的SDK版本满足以下要求，并在消息收发代码中补充如下内容：

说明

其中，InstanceId需要替换为您实际使用的实例ID。

SDK版本：rocketmq-client ≥ 5.2.0
消息发送代码补充：producer.setNamespaceV2("InstanceId");
消息消费代码补充：consumer.setNamespaceV2("InstanceId");

SDK版本：rocketmq-client-java ≥ 5.0.6

消息发送和消息消费代码补充：

ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setNamespace("InstanceId")
.setCredentialProvider(sessionCredentialsProvider)
.build();