检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Java（TCP协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问 消费端限流 RocketMQ-Spring的使用
Java（gRPC协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息
最新动态 本文介绍了分布式消息服务RocketMQ版各特性版本的功能发布和对应的文档动态，欢迎体验。 2024年3月 序号 功能名称 功能描述 阶段 1 计费系统的RocketMQ规格名称优化 在计费系统中优化RocketMQ实例的规格名称，便于用户使用和理解。优化后的规格名称为
示例代码 package org.apache.rocketmq.example.simple; import java.util.List; import java.util.concurrent.TimeUnit; import com.google.common.util
使用ACL权限访问 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖： 使用Maven方式引入依赖。 <dependency>
LoggerFactory; import java.time.Duration; import java.util.Collections; import java.util.List; import java.util.Map; import java.util.concurrent.CompletableFuture;
producer.shutdown(); }} 订阅普通消息 参考如下示例代码，或者通过PushConsumer.java获取更多示例代码。 import java.util.List; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
下载依赖JAR包。 发送顺序消息 参考如下示例代码，或者通过Producer.java获取更多示例代码。 import java.nio.charset.StandardCharsets; import java.util.List; import org.apache.rocketmq
</dependency> 下载依赖JAR包。 发送定时消息 发送定时消息的示例代码如下： import java.nio.charset.StandardCharsets; import java.time.Instant; import org.apache.rocketmq.client
<artifactId>rocketmq-client-java</artifactId> <version>5.0.5</version> </dependency> 发送顺序消息 参考如下示例代码，或者通过ProducerFifoMessageExample.java获取更多示例代码。 import
org.slf4j.LoggerFactory; import java.io.IOException; import java.nio.charset.StandardCharsets; import java.time.Duration; public class Pro
MQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前，需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖： 使用Maven方式引入依赖。
<artifactId>rocketmq-client-java</artifactId> <version>5.0.5</version> </dependency> 发送事务消息 参考如下示例代码，或者通过ProducerTransactionMessageExample.java获取更多示例代码。 import
out.printf("received message: %s", message); } } } 父主题： Java（TCP协议）
查问题。 本章节介绍使用Java、Go和Spring开启消息轨迹，以及查看消息轨迹的方法。 前提条件 生产者Java客户端版本在4.9.0以上才支持事务消息的轨迹，如果版本不满足要求，请先升级。 开启SSL的RocketMQ实例，生产者和消费者的Java客户端版本在4.9.2以上
第三章~第七章介绍Java、Go和Python客户端访问分布式消息服务RocketMQ版的示例代码，具体如表1所示。 表1 示例代码 客户端语言 示例代码 Java（TCP协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问 消费端限流 Java（gRPC协议）
认证证书 合规证书 华为云服务及平台通过了多项国内外权威机构（ISO/SOC/PCI等）的安全合规认证，用户可自行申请下载合规资质证书。 图1 合规证书下载 资源中心 华为云还提供以下资源来帮助用户满足合规性要求，具体请查看资源中心。 图2 资源中心 销售许可证&软件著作权证书 另
查看SDK更新历史、获取安装包以及查看指导文档。 表1 SDK列表 编程语言 Github地址 参考文档 Java huaweicloud-sdk-java-v3 Java SDK使用指导 Python huaweicloud-sdk-python-v3 Python SDK使用指导
已创建Topic。 客户端所在服务器已安装Java Development Kit 1.8.111或以上版本，并完成环境变量配置。 命令行模式连接实例 登录客户端所在服务器。 下载“rocketmq-tutorial”示例软件包。 wget https://dms-demos.obs.cn-north-1
已创建Topic。 客户端所在服务器已安装Java Development Kit 1.8.111或以上版本，并完成环境变量配置。 命令行模式连接实例 登录客户端所在服务器。 下载“rocketmq-tutorial”示例软件包。 wget https://dms-demos.obs.cn-north-1
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
