检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
vpc_id:RocketMQ实例所在的VPC(虚拟私有云)的ID。您可以在虚拟私有云控制台查询,也可以通过查询VPC列表API查询。 subnet_id:VPC内子网的网络ID。您可以在虚拟私有云控制台查询,也可以通过查询子网列表API查询。
发送定时消息 使用ACL权限访问 Go(gRPC协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 Python(TCP协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问
消息大小超过限制会导致消息发送失败。 定时消息的延时时长 最大延时时长为1年,不支持修改。 支持1年内任意时间的定时消息。 用户 表5 用户约束与限制 限制项 约束与限制 创建用户的数量 一个RocketMQ实例最多可以创建1000个用户。
因此,可以将消息重复的场景分为以下两类: 生产者发送消息时发生消息重复: 生产者发送消息时,消息成功发送至服务端。如果此时发生网络闪断,导致生产者未收到服务端的响应,此时生产者会认为消息发送失败,因此尝试重新发送消息至服务端。
表5 实例网络参数说明 参数名称 说明 虚拟私有云 选择已经创建好的或共享的虚拟私有云。 虚拟私有云可以为您的RocketMQ实例构建隔离的、能自主配置和管理的虚拟网络环境。您可以单击右侧的“管理虚拟私有云”,跳转到网络控制台的“虚拟私有云”页面,查看或创建虚拟私有云。
延迟消息/定时消息:生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到特定时间后才会发送给消费者进行消费。 顺序消息:消费者按照消息发送的顺序来消费消息。
vpc_id String 虚拟私有云ID。 获取方法如下:登录虚拟私有云服务的控制台界面,在虚拟私有云的详情页面查找VPC ID。 subnet_id String 子网信息。 获取方法如下:登录虚拟私有云服务的控制台界面,单击VPC下的子网,进入子网详情页面,查找网络ID。
按顺序消费可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费。 描述 消费组的描述信息。 取值长度为0~200个字符。 修改完成后,单击“确定”。 父主题: 管理消费组
预警消息将通过邮件、短信和站内信的方式通知到华为云账号的创建者。 到期后影响 资源到期未续费,进入宽限期。 如果您的包年/包月RocketMQ实例到期未续费,RocketMQ实例会进入宽限期,RocketMQ实例状态变为“已过期”。
如果消息类型为定时消息/延时消息/事务消息,发送消息的调用次数需要在普通消息基础上乘以5,接收消息的调用次数不需要乘以5。例如:每秒发送一条普通消息,TPS为1次/秒。每秒发送一条事务消息,TPS=1*5=5次/秒。
Java(gRPC协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息
Java(TCP协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问 消费端限流 RocketMQ-Spring的使用
按顺序消费可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费。 描述 消费组的描述信息。 取值长度为0~200个字符。 配置完成后,单击“确定”,完成消费组的创建。
迁移生产消息至分布式消息服务RocketMQ版实例。 将生产客户端的元数据连接地址改为分布式消息服务RocketMQ版实例的元数据连接地址,重启生产业务,使得生产者将新的消息发送到分布式消息服务RocketMQ版实例中。 迁移消费消息至分布式消息服务RocketMQ版实例。
当生产者向Topic A发送消息时,消息会按Queue均匀发送给消费者A和消费者B。由于消费者B没有订阅Topic A的消息,会把Topic A消息过滤掉(即图2中Topic A的Queue2中的消息会被消费者B过滤),从而导致部分Topic A消息未被消费。
取值范围: 禁止:表示用户既不可以往Topic发送消息,也不能消费Topic中的消息。 发布:表示用户只可以往Topic发送消息,不能消费Topic中的消息。 订阅:表示用户不可以往Topic发送消息,但可以消费Topic中的消息。
CPU每个核的平均负载 >0 RocketMQ实例节点 1分钟 broker_disk_usage 磁盘容量使用率 该指标用于统计节点虚拟机的磁盘容量使用率 单位:% 0~100 RocketMQ实例节点 1分钟 broker_memory_usage 内存使用率 该指标用于统计节点虚拟机的内存使用率
发送顺序消息 参考如下示例代码,或者通过Producer.java获取更多示例代码。
表1 消息轨迹的参数说明 参数 参数说明 生产者状态 生产者状态如下: 发送成功:消息发送成功,服务端已经成功存储消息。 提交成功:允许消费者消费此事务消息。 回滚:事务消息将被丢弃,不允许消费者消费此事务消息。
查询消息轨迹 功能介绍 查询消息轨迹。 调用方法 请参见如何调用API。