检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RocketMQ，都会要求访问请求方出示身份凭证，并进行身份合法性校验，同时提供登录保护和登录验证策略加固身份认证安全。 DMS for RocketMQ基于统一身份认证服务（Identity and Access Management，简称IAM），支持三种身份认证方式：用户名密码、访问密钥、临时访问密钥。同时还提供登录保护及登录验证策略。
在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在左侧导航栏，单击“消费组管理”，进入消费组列表页面。
获取账号名和账号ID 在调用接口的时候，部分URL中需要填入账号名和账号ID，所以需要先在管理控制台上获取到账号名和账号ID。账号名和账号ID获取步骤如下： 登录管理控制台。 鼠标悬停在右上角的用户名，选择下拉列表中的“我的凭证”。 查看账号名和账号ID。 图1 查看账号名和账号ID
元数据迁移 新建元数据迁移任务 查询实例下所有迁移任务或查询指定迁移任务信息 删除元数据迁移任务 父主题： API V2（推荐）
规格变更管理 查询实例的扩容规格列表 实例规格变更 父主题： API V2（推荐）
是否支持自动创建Topic？ RocketMQ实例不支持自动创建Topic。 父主题： Topic问题
请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在“连接信息 > SSL”中，选择实例接入方式，弹出“确认”对话框。 单击“确定”，跳转到“后台任务管理”页面。
消费端限流 在分布式消息服务RocketMQ版中，消费者消费消息时，可能会出现消费过快导致下游业务来不及处理的情况，进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码，以保障系统的稳定。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4
创建用户 功能介绍 创建用户。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/users 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。
在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在左侧导航栏，单击“Topic管理”，进入“Topic管理”页面。
在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在左侧导航栏，单击“Topic管理”，进入“Topic管理”页面。
使用ACL权限访问 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。 生产者增加用户认证信息 普通消息、顺序消息和定时消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。 import ( "context" "fmt" "os"
图解Kafka、RabbitMQ和RocketMQ的差异
更新消费组 功能介绍 更新消费组。 调用方法 请参见如何调用API。 URI PUT /v2/{engine}/{project_id}/instances/{instance_id}/groups 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 引擎。
在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在左侧导航栏，单击“监控”，进入实例监控页面。
替换成真实RocketMQ的NameServer地址与端口 rocketmq.name-server=127.0.0.1:9876 生产消息 生产消息的示例代码如下（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 @SpringBootApplication public
x版本支持流控。 出现如下两种情况会触发流控： 短时间内生产、消费消息请求数量过多。 秒级突发流量过大时，可能出现该秒请求被流控。 监控数据采集的是一分钟内平均TPS，不是秒级监控。 当请求被流控时，会导致生产消息请求失败，且服务端返回215错误码。为避免出现流控情况，请确保生产、消费TPS在给定实例规格内。
查询项目标签 功能介绍 查询项目标签。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/rocketmq/tags 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 请求参数
修改用户参数 功能介绍 修改用户参数。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/users/{user_name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是
修改指定消费组 功能介绍 修改指定消费组。 调用方法 请参见如何调用API。 URI PUT /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 engine
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
