检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
"total" : 1, "groups" : [ { "name" : "group-1", "enabled" : true, "broadcast" : false, "brokers" : [ "broker-0" ], "createdAt"
单击“创建Topic”,弹出“创建Topic”页面。 参考表1或表2,填写Topic名称和配置信息。 图1 创建Topic(RocketMQ实例4.8.0版本) 图2 创建Topic(RocketMQ实例5.x版本) 表1 Topic参数说明(RocketMQ实例4.8.0版本) 参数
生产者发送消息时,消息已经设置了唯一的Key,在消费者消费消息时,可以根据消息的Key进行幂等处理。消费者通过getKeys()能够读取到消息的唯一标识(如订单号等),业务逻辑围绕该唯一标识进行幂等处理即可。
8d3f-047b0de4c5cf", "subnet_id" : "0a0f1fcb-f019-458d-b9e5-301867394d50", "security_group_id" : "23c5977f-ff33-4b95-a73e-08d8a0bc4e6c",
0版本不同产品规格在发送1KB大小的消息,且CPU使用率达到80%以上时,实例的网络入流量、网络出流量、消息生产速率、消息消费速率、CPU核均负载和内存使用率。 测试环境 进行测试前,您需要先构建如下的测试环境: 购买如表1所示实例,购买步骤请参考购买实例。 表1 实例参数 名称 规格
该指标用于统计节点虚拟机的内存使用率 单位:% 0~100 RocketMQ实例节点 1分钟 broker_alive 节点存活状态 节点存活状态 说明: 2022年5月16号及以后购买的实例,支持此监控项。 1:存活 0:离线 RocketMQ实例节点 1分钟 broker_connections
"topic-test1", "topicSysFlag" : 0, "writeQueueNums" : 3 } }, "subscriptionGroupTable" : { "group-test1" : { "
修改如表1所示配置信息。 表1 Topic参数说明 参数 说明 权限 RocketMQ实例的版本为4.8.0时,才会显示此参数。 Topic的权限,包括发布+订阅、发布和订阅。 关联代理 RocketMQ实例的版本为4.8.0时,才会显示此参数。 修改读队列个数或写队列个数。
SDK代码示例 SDK代码示例如下。 Java Python Go 更多 修改用户参数,授予user_name用户发布、订阅topic1和group1的权限。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id}/metadata 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id
创建安全组的操作步骤,请参考创建安全组。 连接RocketMQ实例前,请添加表1所示安全组规则。 表1 安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 8100 RocketMQ客户端所在的IP地址或地址段。 使用TCP协议,通过内网访问实例的端口。 入方向 TCP 8080
格TPS上限的增量部分进行计费。 取值为计费周期即1小时内,增量部分TPS的最大值。 按量付费(先使用后付费) 与实例本身为按需或包年/包月无关。 每小时弹性TPS费用 = 1小时内增量部分TPS最大值 * 弹性TPS单价 图1 账单 计费示例 以包年/包月计费模式为例,假设您于2023/03/08
分布式消息服务RocketMQ版不会向个别客户提供事先通知。 最后,分布式消息服务RocketMQ版不会针对产品中的漏洞开发或发布可利用的入侵代码(或“验证性代码”)。 父主题: 漏洞公告
"available_zones" : [ "9f1c5806706d4c1fb0eb72f0a9b18c77" ], "available_zone_names" : [ "AZ3" ], "user_id" : "0b01fbb53600d4671fa8c00673c71260"
ages/export { "topic" : "%DLQ%group1", "msg_id_list" : [ "C0A8011700002774000000000013B19D", "C0A8011700002774000000000013B30F" ], "uniq_key_list"
"available_zones" : [ "9f1c5806706d4c1fb0eb72f0a9b18c77" ], "available_zone_names" : [ "AZ3" ], "user_id" : "0b01fbb53600d4671fa8c00673c71260"
本文主要介绍在Linux系统的命令行模式下,调用TCP协议连接未开启SSL的RocketMQ实例。 创建实例时或者在实例基本信息中,将“SSL”配置为“PLAINTEXT”或“PERMISSIVE”(通过明文传输),即为未开启SSL。 前提条件 已创建RocketMQ实例,并记录实例详情中的“连接地址”(内网访问
个隔离的、用户自主配置和管理的虚拟网络环境以及安全保护策略,提升实例的安全性。 RocketMQ实例所需资源的具体要求和创建指导如表1所示。 表1 RocketMQ实例依赖资源 准备资源 要求 创建指导 VPC和子网 RocketMQ实例可以使用当前账号下已创建的VPC和子网,也
是否接近性能上限,表示当前资源支撑的性能为告警策略中设置的告警阈值,如果继续上升,业务可能出现问题。 表1 RocketMQ实例配置告警的指标 指标名称 正常范围 告警策略 是否接近性能上限 指标说明和告警处理建议 磁盘容量使用率 0~100 告警阈值:原始值>85 连续触发次数:3 告警级别:紧急 是 指标
x系统的命令行模式下,调用TCP协议连接已开启SSL的RocketMQ实例。 创建实例时或者在实例基本信息中,将“SSL”配置为“SSL”或“PERMISSIVE”(通过密文传输),即为已开启SSL。 操作视频 本视频演示使用客户端连接RocketMQ实例的操作。 前提条件 已创