检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
梳理消息的消费耗时需要注意以下几点： 消息消费逻辑的计算复杂度是否过高，代码是否存在复杂的递归和循环处理。 消息消费逻辑中的I/O操作是否是必须，是否可以使用本地缓存等方案规避。 消息消费逻辑中的复杂耗时操作是否可以做异步化处理。 设置消费并发度 对于消费并发度的计算，可以按如下方法进行处理：
型为“顺序”。 使用gRPC协议连接RocketMQ实例时，消费者是否顺序消费消息，取决于消费组中是否开启顺序消费，并非在消费代码中设置，顺序消费消息的代码与普通消费的代码相同。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
mod”命令新建一个“go.mod”，并增加以下代码，添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export
mod”命令新建一个“go.mod”，并增加以下代码，添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export
x版本的RocketMQ实例支持的变更配置如表2所示。 表1 变更配置列表（RocketMQ实例4.8.0版本） 变更配置类型 是否支持扩容 是否支持缩容 代理个数 √ × 存储空间 √ × 代理规格 √ × RocketMQ实例5.x版本创建成功后，您可以根据业务需要，进行扩
enableSsl(false) // 创建实例时，如果将“SSL”配置为“PLAINTEXT”，则请增加此行代码。如果将“SSL”配置为“PERMISSIVE”，则请根据实际情况选择是否增加此行代码。 // .setCredentialProvider(
使用控制台连接RocketMQ 本章节介绍RocketMQ实例如何在控制台生产消息。此功能通过将指定消息发送给RocketMQ实例，验证业务逻辑是否正常。 前提条件 已存在“运行中”的RocketMQ实例。 已创建Topic。 使用控制台连接RocketMQ生产消息 登录管理控制台。 在管理控制台左上角单击，选择区域。
etMQ实例，如果不再使用，单击“操作”栏下的“更多 > 退订”，退订成功后，RocketMQ实例会自动被删除。 删除的实例能否恢复取决于是否开启回收站策略，如果未开启回收站策略，实例删除后，实例中原有的数据将被删除，且没有备份。回收站策略默认关闭，如果需要开启，具体步骤请参见开启回收站策略。
本文档提供了分布式消息服务RocketMQ版API的描述、语法、参数说明及样例等内容。 分布式消息服务RocketMQ版持续增加新的功能，将不可避免对现有接口有所调整，比如增加响应参数。 为了减少接口变更带来的影响，除了分布式消息服务RocketMQ版自身尽量做到接口向下兼容的同时，用户在
（可选）如果RocketMQ实例开启了ACL访问控制，执行mqadmin命令时，需要鉴权。 切换到解压后的软件包目录下，在“conf/tools.yml”文件中，增加如下内容。 accessKey:******* secretKey:******* accessKey和secretKey表示在控制台“用
mod”命令新建一个“go.mod”，并增加以下代码，添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export
为“事务”。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go，请下载并安装。 在“go.mod”中增加以下代码，添加依赖。 module rocketmq-example-go
RocketMQ实例兼容开源RocketMQ哪个版本？ 实例可靠性是怎么保障的？ 为什么不能选择2个可用区？ RocketMQ实例的SSL开关是否支持修改？ 磁盘类型对RocketMQ实例性能有什么影响？
nce_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 name 否 String
企业项目ID。若为企业项目账号，该参数必填。 enable_acl 否 Boolean 是否开启访问控制列表。 ipv6_enable 否 Boolean 是否支持IPv6。 true：支持 false：不支持 enable_publicip 否 Boolean 是否开启公网访问功能。默认不开启公网。 true：开启
Token无效。 请检查token是否有效 401 DMS.10240102 Expired token. Token已过期。 请检查使用的token是否已过期 401 DMS.10240103 Missing token. Token缺失。 请检查是否没有token 401 DMS
nces/{instance_id}/groups/{group_id}/reset-message-offset 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 引擎类型：reliability。 project_id 是 String 项目ID，获取方式请参见获取项目ID。
使用ACL权限访问 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。 生产者增加用户认证信息 普通消息、顺序消息和定时消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。 from rocketmq.client import Producer
/v2/{project_id}/instances 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 表2 Query参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎：rocketmq。
<version>4.9.8</version> </dependency> 下载依赖JAR包。 生产者增加用户认证信息 生产者初始化时需要增加“rpcHook”参数。 普通消息、顺序消息和定时消息，增加如下代码。 RPCHook rpcHook = new AclClientRPCHook(new
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
