检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
名称 消息类型 topic-01 普通 创建如表3所示消费组，创建步骤请参考创建消费组。 表3 消费组参数 名称 最大重试次数 是否允许以广播模式消费 是否顺序消费 group-01 16 否 否 购买1台ECS服务器（区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保
测试实例性能 测试4.8.0版本RocketMQ实例性能 测试5.x基础版本RocketMQ实例性能
topic-01 发布+订阅 broker-0 8 创建如表3所示消费组，创建步骤请参考创建消费组。 表3 消费组参数 名称 关联代理 最大重试次数 是否允许以广播模式消费 group-01 broker-0 16 否 购买1台ECS服务器（区域、可用区、虚拟私有云、子网、安全组与Rocke
是否支持自动创建Topic？ RocketMQ实例不支持自动创建Topic。 父主题： Topic问题
RocketMQ实例的SSL开关是否支持修改？ SSL开关支持修改，具体步骤请参考修改SSL。 父主题： 实例问题
RocketMQ是否支持自建Broker连接云上nameserver？ 不支持。自建Broker连接到云上RocketMQ的nameserver，会影响管理面功能，导致查询不到Topic等问题。 父主题： 连接问题
mod”命令新建一个“go.mod”，并增加以下代码，添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export
存储空间 磁盘类型创建完成后不可修改。 只支持扩大存储空间，不支持减小存储空间。 扩容存储空间有次数限制，最多扩容20次。 代理个数 只支持增加代理个数，不支持减小代理个数。 代理规格 支持扩容代理规格。 若实例Broker数为1，扩容期间会导致Broker主备切换，造成业务中断30秒以内。
程度上受到磁盘规格的影响。在其它条件相同的情况下，磁盘吞吐量越高，生产消息的性能越好。当磁盘性能达到瓶颈时，磁盘访问时延会增加，进而导致生产消息请求时延增加，严重情况下可能造成生产消息失败。 对消费RocketMQ实例消息的影响 RocketMQ消息落盘使用的是顺序写，在新的消息
消息对应的业务逻辑有时间窗口要求，如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息，5分钟以后投递给消费者，消费者收到此消息后需要判断对应订单是否完成支付，如果未完成支付，则关闭订单。如果已完成，则忽略。 通过消息触发定时任务的场景，如在某些固定时间点向用户发送提醒消息。 注意事项
建议按照以下告警策略，配置监控指标的告警规则。 是否接近性能上限，表示当前资源支撑的性能为告警策略中设置的告警阈值，如果继续上升，业务可能出现问题。 表1 RocketMQ实例配置告警的指标 指标名称 正常范围 告警策略 是否接近性能上限 指标说明和告警处理建议 磁盘容量使用率
最大重试次数 设置消费失败的最大重试次数。 取值范围：1～16 是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费，每条消息都会被消费组内的所有消费者消费一次。否则，每条消息只会被消费组内的某一消费者消费。 是否顺序消费 RocketMQ实例的版本为5.x时，需要设置此参数。
查看RocketMQ消息 本章节指导您通过查询消息功能查看具体的消息内容，以及确定消息是否生产/消费成功。 分布式消息服务RocketMQ版提供三种消息查询的方法：按Topic查询、按Message ID查询和按Message Key查询。 按Topic查询：查询某时间段内指定T
sumerGroupName", true); 开启RocketMQ消息轨迹（Go） 在客户端开启消息轨迹的方法如下： 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 [root@ecs-test sarama]# go version
在购买时会一次性付费，服务将在到期后自动停止使用。 如果在计费周期内不再使用包年/包月资源，您可以执行退订操作，系统将根据资源是否属于五天无理由退订、是否使用代金券和折扣券等条件返还一定金额到您的账户。详细的退订规则请参见云服务退订规则概览。需要注意，如果实例开启了回收站策略，包
enableSsl(false) // 创建实例时，如果将“SSL”配置为“PLAINTEXT”，则请增加此行代码。如果将“SSL”配置为“PERMISSIVE”，则请根据实际情况选择是否增加此行代码。 // .setCredentialProvider(
enableSsl(false) // 创建实例时，如果将“SSL”配置为“PLAINTEXT”，则请增加此行代码。如果将“SSL”配置为“PERMISSIVE”，则请根据实际情况选择是否增加此行代码。 // .setCredentialProvider(
enableSsl(false) // 创建实例时，如果将“SSL”配置为“PLAINTEXT”，则请增加此行代码。如果将“SSL”配置为“PERMISSIVE”，则请根据实际情况选择是否增加此行代码。 // .setCredentialProvider(
配置RocketMQ ACL用户 RocketMQ实例开启ACL权限控制功能后，生产和消费消息时，须增加ACL用户信息，才能成功生产和消费消息。您还可以通过创建多个用户并为其赋予不同的Topic和消费组权限，以达到用户之间的权限隔离。 前提条件 已购买RocketMQ实例。 已开启ACL访问控制。
表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 group 是 String 消费组名称。 表2 Query参数 参数 是否必选 参数类型 描述 topic
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
