示例代码
更新时间:
本文介绍Apache RocketMQ Java SDK的消息收发示例代码。
示例代码
消息类型 | 发送消息示例代码 | 订阅消息示例代码 | |
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();
文档内容是否对您有帮助?