检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置RocketMQ实例回收站策略 开启回收站策略的实例在被删除后,会被临时存入回收站中,此时实例中的数据尚未被彻底删除,在保留天数内支持从回收站中恢复此实例。超过保留天数的实例会被彻底删除,无法恢复。 回收站策略默认是关闭状态。 回收站功能仅在“华北-北京一”、“华北-北京四”
前,需要先连接RocketMQ实例。 购买RocketMQ实例时,加密方式支持配置为SSL。 支持区域: 全部 连接未开启SSL的RocketMQ实例 连接已开启SSL的RocketMQ实例 Topic管理 Topic,即消息主题,消息发送与接收的基本单元。购买RocketMQ实
RocketMQ实例方式设置为密码访问(即开启ACL访问控制),防止未经认证的客户端误操作实例。 您可以选择如下任意一种方法开启ACL访问控制。 在“购买实例”页面开启ACL访问控制,具体可参考购买RocketMQ实例。 购买实例后,在实例的“基本信息”页面中开启ACL访问控制,具体可参考查看和修改RocketMQ实例基本信息。
n Boolean 是否开启消息收集功能。 storage_space Integer 存储空间,单位:GB。 used_storage_space Integer 已用消息存储空间,单位:GB。 enable_publicip Boolean 是否开启公网。 publicip_id
选择已经创建好的或共享的子网。 子网在RocketMQ实例创建完成后,不支持修改。 子网开启IPv6后,RocketMQ实例支持IPv6功能。 IPv6 子网开启IPv6后,页面才显示此参数。开启IPv6后,客户端可以使用IPv6地址连接RocketMQ实例。 RocketMQ实例创建完成后,不支持修改IPv6开关。
n Boolean 是否开启消息收集功能。 storage_space Integer 存储空间,单位:GB。 used_storage_space Integer 已用消息存储空间,单位:GB。 enable_publicip Boolean 是否开启公网。 publicip_id
头须为英文字母。 是否同名覆盖 如果开启同名覆盖,会对已有的同名元数据的配置进行修改。 例如:原实例Topic01的读队列个数为3,云上实例Topic01的读队列个数为2,开启同名覆盖后,云上实例Topic01的读队列个数变为3。 如果不开启同名覆盖,同名元数据的迁移将失败。 例
后台任务列表 任务名 说明 创建实例 创建一个RocketMQ实例。 重启实例 重启RocketMQ实例。 修改是否开启SSL 修改SSL的配置。 开启公网访问 修改“公网访问”为开启。 关闭公网访问 修改“公网访问”为关闭。 变更规格 扩容存储空间 扩容代理数量 扩容代理规格 批量删除消费组
填入用户名/密码,用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。创建实例时,如果开启了ACL才需要添加以下代码。 String accessKey = System.getenv("ROCKETMQ_AK");
Boolean 是否开启访问控制列表。 ipv6_enable 否 Boolean 是否支持IPv6。 true:支持 false:不支持 enable_publicip 否 Boolean 是否开启公网访问功能。默认不开启公网。 true:开启 false:不开启 publicip_id
MQ实例是否开启SSL,然后再允许执行操作。下表显示了适用于DMS for RocketMQ服务特定的条件键。 表1 DMS for RocketMQ请求条件 DMS for RocketMQ条件键 运算符 描述 dms:publicIP Bool Null 是否开启公网 dms:ssl
填入用户名/密钥,用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。创建实例时,如果开启了ACL才需要添加以下代码。 String accessKey = System.getenv("ROCKETMQ_AK");
setNamesrvAddr("192.168.0.1:8100"); //producer.setUseTLS(true); //创建实例时,如果开启了SSL,请添加此行代码。 try { producer.start();
指标说明和告警处理建议 磁盘容量使用率 0~100 告警阈值:原始值>85 连续触发次数:3 告警级别:紧急 是 指标说明:该指标为从RocketMQ节点虚拟机层面采集的磁盘容量使用率。单位:%。 处理建议:出现该告警时,说明当前实例规格已不足以承载业务,需要扩容存储空间。具体操作,请参考变更实例规格。
x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。 使用gRPC协议连接RocketMQ实例时,消费者是否顺序消费消息,取决于消费组中是否开启顺序消费,并非在消费代码中设置,顺序消费消息的代码与普通消费的代码相同。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5
remain_time Long 剩余时间。 ipv6_enable Boolean 是否支持IPv6。 请求示例 查询可用区信息。 GET https://{endpoint}/v2/available-zones?engine=reliability 响应示例 状态码: 200 查询可用区信息成功。
ACL用户 RocketMQ实例开启ACL权限控制功能后,生产和消费消息时,须增加ACL用户信息,才能成功生产和消费消息。您还可以通过创建多个用户并为其赋予不同的Topic和消费组权限,以达到用户之间的权限隔离。 前提条件 已购买RocketMQ实例。 已开启ACL访问控制。 创建用户
perm String 权限。 请求示例 修改用户参数,授予user_name用户发布、订阅topic1和group1的权限。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/users/{user_name}
退订”,退订成功后,RocketMQ实例会自动被删除。 删除的实例能否恢复取决于是否开启回收站策略,如果未开启回收站策略,实例删除后,实例中原有的数据将被删除,且没有备份。回收站策略默认关闭,如果需要开启,具体步骤请参见开启回收站策略。 前提条件 RocketMQ实例状态为运行中、故障、已冻结的按需付费实例才能执行删除操作。
头须为英文字母。 是否同名覆盖 如果开启同名覆盖,会对已有的同名元数据的配置进行修改。 例如:原实例Topic01的读队列个数为3,云上实例Topic01的读队列个数为2,开启同名覆盖后,云上实例Topic01的读队列个数变为3。 如果不开启同名覆盖,同名元数据的迁移将失败。 例