检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment String ak = "{CLOUD_SDK_AK}"; //访问密钥ID。查看AK的方法请参见获取AK/SK。
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
03 入门 创建RocketMQ实例之后，您可以使用RocketMQ开源客户端访问分布式消息服务RocketMQ版来收发消息。 收发消息 收发普通消息 收发顺序消息 收发事务消息 05 实践 您可以通过消息幂等实现消息去重。 实践场景 通过消息幂等实现消息去重 02 购买 您可以根据
全部 实例诊断 收发消息 使用RocketMQ开源客户端访问分布式消息服务RocketMQ版来收发消息的示例代码。 支持区域： 全部 收发普通消息 收发顺序消息 收发事务消息 定时消息 分布式消息服务RocketMQ版支持任意时间的定时消息，最大推迟时间可达到1年。同时也支持定时消息的取消。
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
RocketMQ副本存储形式是怎样的？可以修改吗？ RocketMQ消息是一主两从3个副本的存储形式，且不支持修改。 父主题： 消息问题
x基础版支持的产品规格如表2和表3所示。下表中TPS是指以普通消息类型、4KB消息大小为基准计算的每秒收发消息的总条数。如果消息类型为定时消息/延时消息/事务消息，发送消息的调用次数需要在普通消息基础上乘以5，接收消息的调用次数不需要乘以5。例如：每秒发送一条普通消息，TPS为1次/秒。每秒发送一条事务消息，TPS=1*5=5次/秒。
向“放通全部流量”规则，此时使用内网通过同一个VPC访问RocketMQ实例，无需添加表1的规则。 创建弹性云服务器（Elastic Cloud Server，以下简称ECS）并配置环境。 本操作以Linux系统的ECS为例，Windows系统ECS的JDK安装与环境变量配置可自行在互联网查找相关帮助。
最佳实践 说明 通过消息幂等实现消息去重 为了防止消息重复消费导致业务处理异常，RocketMQ的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本章节介绍消息幂等的概念、适用场景以及实施方法。 通过Topic和Tag实现消息分类 在RocketMQ中，Top
限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4
可以使业务结构更清晰，提高效率。可以根据如下几方面判断Topic和Tag的具体使用场景： 根据消息类型判断：RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息、事务消息，不同类型的消息需要用不同的Topic来区分，无法通过Tag区分。 根据消息优先级判断：在业务中紧
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
AK/SK认证就是使用AK/SK对请求进行签名，在请求时将签名信息添加到消息头，从而通过身份认证。 AK(Access Key ID)：访问密钥ID。与私有访问密钥关联的唯一标识符；访问密钥ID和私有访问密钥一起使用，对请求进行加密签名。 SK(Secret Access Key)：与访问密钥ID结合使用的密钥
ic名称为“test%01”，在云监控中Topic名称显示为“test_01”。 消息类型 选择消息的类型，支持的消息类型：普通、顺序、定时和事务。 普通消息：没有特殊功能的消息，区别于定时消息、顺序消息和事务消息。 定时消息：生产者生产消息到分布式消息服务RocketMQ版后，
8</version> </dependency> 下载依赖JAR包。 生产者增加用户认证信息 生产者初始化时需要增加“rpcHook”参数。 普通消息、顺序消息和定时消息，增加如下代码。 RPCHook rpcHook = new AclClientRPCHook(new Sessi
通过消费者的setMaxReconsumeTimes函数配置最大重试次数。若未设置参数值，默认为无限重试。 普通消费 重试时间间隔根据重试次数阶梯变化，如表2所示。 创建消费组时设置。 取值范围：1-16。 表2 普通消费重试时间间隔 重试次数 与上次的间隔时间 重试次数 与上次的间隔时间 1 10s 9
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
选择需要创建消费组的代理，支持选择多个代理，可同步创建消费组，无需为每个代理单独创建。 创建消费组后不能修改关联代理。 最大重试次数 设置普通消费的最大重试次数。 取值范围：1～16 如果是顺序消费，可通过消费者的setMaxReconsumeTimes函数配置。 是否允许以广播模式消费
标签共由两部分组成：“标签键”和“标签值”，其中，“标签键”和“标签值”的命名规则如表1所示。 表1 标签命名规则 参数名称 规则 标签键 不能为空。 对于同一个实例，Key值唯一。 长度为1~128个字符（中文也可以输入128个字符）。 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @ 首尾字符不能为空格。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
