检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 修改成功。 错误码 请参见错误码。 父主题： 用户管理
fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询所有实例列表成功。 错误码 请参见错误码。 父主题： 生命周期管理
fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 批量修改消费组成功。 错误码 请参见错误码。 父主题： 消费组管理
fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询消费者订阅详情成功。 错误码 请参见错误码。 父主题： 消费组管理
gid：表示生产者组名称，请根据业务实际情况输入生产者组名称。 name_srv：表示实例连接地址和端口。 ROCKETMQ_AK：表示用户名。创建用户的步骤，请参见创建用户。 ROCKETMQ_SK：表示用户的密钥。 事务消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。
实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。 生产者增加用户认证信息 普通消息、顺序消息和定时消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。 import ( "context" "fmt" "os" "github.com/apache/rocketmq-client-go/v2"
快速入门 场景描述 您可以根据业务需要创建相应计算能力和存储空间的RocketMQ实例。 API调用方法请参考如何调用API。 前提条件 已获取IAM和RocketMQ的Endpoint，具体请参见地区和终端节点。 创建RocketMQ实例 如下示例是创建RocketMQ实例的请求消息：
修改RocketMQ消费组配置 消费组创建成功后，可以根据业务需要修改消费组的配置信息。 前提条件 已创建消费组。 修改RocketMQ消费组配置 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件
rocketmq.name-server=127.0.0.1:9876 生产消息 生产消息的示例代码如下（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 @SpringBootApplication public class ProduceDemoApplication implements
使业务结构更清晰，提高效率。可以根据如下几方面判断Topic和Tag的具体使用场景： 根据消息类型判断：RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息、事务消息，不同类型的消息需要用不同的Topic来区分，无法通过Tag区分。 根据消息优先级判断：在业务中紧急程度
云。详情请参见责任共担。 本文提供了如何安全使用DMS for RocketMQ的最佳实践，旨在为提高整体安全能力提供可操作的规范性指导。根据该指导文档您可以持续评估DMS for RocketMQ资源的安全状态，更好的组合使用DMS for RocketMQ提供的多种安全能力，提高对DMS
息保留时间。RocketMQ消息存储在CommitLog文件中，CommitLog文件大小为1GB，当一个CommitLog文件写满后，会生成一个新的CommitLog文件。RocketMQ删除消息是删除CommitLog文件，而不是删除一条消息。CommitLog文件为顺序写入
例被自动删除。自动续费的规则如下所述： 以RocketMQ实例的到期日计算第一次自动续费日期和计费周期。 RocketMQ实例自动续费周期根据您开通自动续费的途径不同，遵循不同的规则。 在RocketMQ实例到期前均可开通自动续费，到期前7日凌晨3:00首次尝试自动续费，如果扣款
华为云根据客户等级定义了不同客户的宽限期和保留期时长。 在RocketMQ实例到期前均可开通自动续费，到期前7日凌晨3:00首次尝试自动续费，如果扣款失败，每天凌晨3:00尝试一次，直至RocketMQ实例到期或者续费成功。到期前7日自动续费扣款是系统默认配置，您也可以根据需要修改此扣款日。
ketMQ实例，用户在购买时会一次性付费，服务将在到期后自动停止使用。 如果在计费周期内不再使用包年/包月资源，您可以执行退订操作，系统将根据资源是否属于五天无理由退订、是否使用代金券和折扣券等条件返还一定金额到您的账户。详细的退订规则请参见云服务退订规则概览。需要注意，如果实例
正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制，消息老化时间修改后，正常消息的保留时间和死信消息的保留时间都会被修改。 实例创建后，您可以根据业务需要修改消息老化时间。修改老化时间，不会重启实例。消息老化时间默认为48小时。 前提条件 已购买RocketMQ实例。 修改RocketMQ消息保留时间
条账单（实例费用账单和存储空间费用账单）到计费系统进行结算。 按需计费模式的资源按照固定周期上报使用量到计费系统进行结算。按需计费模式产品根据使用量类型的不同，分为按小时、按天、按月三种周期进行结算，具体扣费规则可以参考按需产品周期结算说明。RocketMQ实例的按需计费模式按小时进行结算。
客户端连接RocketMQ实例5.x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 发送顺序消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 from rocketmq.client import Producer, Message topic = 'TopicTest'
topic：表示Topic名称。 gid：表示生产者组名称，请根据业务实际情况输入生产者组名称。 name_srv：表示实例连接地址和端口。 订阅普通消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 import time from rocketmq
分布式消息服务RocketMQ版支持4种高级特性。 消息过滤：消费者根据分布式消息服务RocketMQ版设置的标签对已订阅Topic中的消息进行过滤，达到只消费需要的消息的目的。 消息重试：消费者消费某条消息失败后，分布式消息服务RocketMQ版根据重试机制将消息重新发送给消费者进行消费。如果重试
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
