检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
查看RocketMQ实例后台任务 对实例的一些操作，如表1所示，会启动一个后台任务，您可以在后台任务页，查看该操作的状态等信息，同时可通过删除操作，清理任务信息。 表1 后台任务列表 任务名 说明 创建实例 创建一个RocketMQ实例。 重启实例 重启RocketMQ实例。 修改是否开启SSL
导出RocketMQ实例列表 RocketMQ支持通过控制台导出实例列表信息，供用户查看和使用。 前提条件 已购买RocketMQ实例。 导出RocketMQ实例列表 登录管理控制台。 在管理控制台左上角单击，选择区域。 不同区域的云服务产品之间内网互不相通。请就近选择靠近您业务的区域，可减少网络时延，提高访问速度。
消费消息的记录。当您需要使用相同的Topic和消费组时，可通过元数据迁移操作将已有的Topic和消费组信息迁移到指定的RocketMQ实例中，无需再手动创建。 RocketMQ业务迁移主要涉及以下场景： 迁移其他RocketMQ的元数据到华为云上RocketMQ实例。其他RocketMQ元数据包括如下内容：
//ACL_User_Name为用户名，ACL_Secret_Key为用户的密钥。创建用户的步骤，请参见创建用户。用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险，建议在配置文件或者环境变量中密文存放，使用时解密。 func main() { os.Setenv("mq.consoleAppender
//ACL_User_Name为用户名，ACL_Secret_Key为用户的密钥。创建用户的步骤，请参见创建用户。用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险，建议在配置文件或者环境变量中密文存放，使用时解密。 SessionCredentialsProvider sessionCredentialsProvider
收发普通消息 本章节介绍普通消息的收发方法和示例代码。其中，普通消息发送方式分为同步发送和异步发送。 同步发送：消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息。 异步发送：消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息。
//ACL_User_Name为用户名，ACL_Secret_Key为用户的密钥。创建用户的步骤，请参见创建用户。用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险，建议在配置文件或者环境变量中密文存放，使用时解密。 func main() { os.Setenv("mq.consoleAppender
x版本收发定时消息前，需要确保Topic的消息类型为“定时”。 适用场景 定时消息适用于以下场景： 消息对应的业务逻辑有时间窗口要求，如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息，5分钟以后投递给消费者，消费者收到此消息后需要判断对应订单是否完成支付，如果未完成支付，则关闭订单。如果已完成，则忽略。
x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 使用gRPC协议连接RocketMQ实例时，消费者是否顺序消费消息，取决于消费组中是否开启顺序消费，并非在消费代码中设置，顺序消费消息的代码与普通消费的代码相同。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
if __name__ == '__main__': send_orderly_with_sharding_key() 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 topic：表示Topic名称。 name_srv：表示实例连接地址和端口。 set_key
支持多少个Topic？ 不同实例规格支持的Topic个数不同，具体参见表1、表2、表3、表4和表5。 表1 实例规格说明（分布式消息服务RocketMQ版4.8.0） 资源规格 代理（个） 存储容量（GB/代理） 单个代理TPS 单个代理Topic数上限 单个代理消费组数上限 rocketmq
消息创建时间在哪设置？ 消息创建时间是由生产客户端在生产消息时设置的。 父主题： 消息问题
云监控无法展示Topic监控数据？ 当Topic名称中包含“%”或“|”时，在云监控中会将“%”或“|”转换为“_”显示，例如Topic名称为“test%01”，在云监控中Topic名称显示为“test_01”。 父主题： 监控告警问题
消费组管理 查询消费组列表 创建消费组或批量删除消费组 批量修改消费组 删除指定消费组 查询指定消费组 修改消费组 查询消费列表或详情 重置消费进度 查询消费者列表 父主题： API V2（推荐）
包年/包月转按需，需包年/包月计费模式到期后，按需的计费模式才会生效。 前提条件 RocketMQ实例计费模式为“包年/包月”。 RocketMQ实例状态为“运行中”。 在云服务控制台转按需 登录管理控制台。 单击左侧导航栏的图标，选择“应用中间件 > 分布式消息服务RocketMQ版”。 通过以下任意
按需计费RocketMQ实例绑定的云硬盘随RocketMQ实例同步变更计费模式。 前提条件 RocketMQ实例计费模式为“按需计费”。 RocketMQ实例状态为“运行中”。 操作步骤 登录管理控制台。 单击左侧导航栏的图标，选择“应用中间件 > 分布式消息服务RocketMQ版”。 通过以下任意一种方法，实现按需实例转包周期。
x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 使用gRPC协议连接RocketMQ实例时，消费者是否顺序消费消息，取决于消费组中是否开启顺序消费，并非在消费代码中设置，顺序消费消息的代码与普通消费的代码相同。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5
事务消息生产者需要实现两个回调函数，其中executeLocalTransaction回调函数在发送完半事务消息后被调用，即上图中的第3阶段，checkLocalTransaction回调函数在收到回查时调用，即上图中的第6阶段。两个回调函数均可返回3种事务状态： LocalTransactionState.CO
e.printStackTrace(); } }} 上述代码中，相同orderId的消息需要保证顺序，不同orderId的消息不需要保证顺序，所以在分区选择算法中以“orderId/队列个数的余数”作为消息发送的队列。 订阅顺序消息 参考如下示例代码，或者通过Consumer
//ACL_User_Name为用户名，ACL_Secret_Key为用户的密钥。创建用户的步骤，请参见创建用户。用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险，建议在配置文件或者环境变量中密文存放，使用时解密。 SessionCredentialsProvider sessionCredentialsProvider
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
