检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Credentials{ AccessKey: os.Getenv("ACL_ACCESS_KEY"), //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险，建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey: os.Getenv("ACL_SECRET_KEY")
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
storage_resource_id String 存储资源ID。 storage_spec_code String 存储规格代码。 service_type String 服务类型。 storage_type String 存储类型。 extend_times Long 扩展时间。 ipv6_enable Boolean
重启指定实例 功能介绍 重启指定实例。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/{engine}/instances/{instance_id}/restart 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是
在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 在待重启节点的RocketMQ实例所在行，单击“重启节点”，弹出“重启节点”对话框。 勾选需要重启的节点，单击“是”。
删除实例 功能介绍 删除实例。 调用方法 请参见如何调用API。 URI DELETE /v1.0/{project_id}/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 instance_id 是 String 实例ID。 project_id
查询产品规格列表 功能介绍 查询相应引擎的产品规格列表。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/products 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎的类型。支持的类型为rocketmq。 表2
修改实例 功能介绍 修改实例。 调用方法 请参见如何调用API。 URI PUT /v1.0/{project_id}/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 instance_id 是 String 实例ID。 project_id
storage_resource_id String 存储资源ID。 storage_spec_code String 存储规格代码。 service_type String 服务类型。 storage_type String 存储类型。 extend_times Long 扩展时间。 ipv6_enable Boolean
查询RocketMQ产品规格核数 功能介绍 查询RocketMQ产品规格核数。 调用方法 请参见如何调用API。 URI GET /v2/rocketmq/products/cores 请求参数 无 响应参数 状态码： 200 表1 响应Body参数 参数 参数类型 描述 core_nume
图解Kafka、RabbitMQ和RocketMQ的差异
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
更新消费组 功能介绍 更新消费组。 调用方法 请参见如何调用API。 URI PUT /v2/{engine}/{project_id}/instances/{instance_id}/groups 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 引擎。
在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 RocketMQ实例支持通过筛选来查询对应的RocketMQ实例。当前支持的筛选条件为状
在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在左侧导航栏，单击“监控”，进入实例监控页面。
RocketMQ-Spring的使用 本文介绍如何使用RocketMQ-Spring连接华为云RocketMQ实例进行消息的生产和消费。相关代码您可以从rocketmq-springboot-demo中获取。 下文所有RocketMQ的配置信息，如实例连接地址、Topic名称、用户信息等，请参考收集连接信息获取。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
