检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
前提条件 RocketMQ实例状态为运行中、故障、已冻结的按需付费实例才能执行删除操作。 删除RocketMQ实例 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Rocket
查看RocketMQ消息 本章节指导您通过查询消息功能查看具体的消息内容,以及确定消息是否生产/消费成功。 分布式消息服务RocketMQ版提供三种消息查询的方法:按Topic查询、按Message ID查询和按Message Key查询。 按Topic查询:查询某时间段内指定T
建议按照以下告警策略,配置监控指标的告警规则。 是否接近性能上限,表示当前资源支撑的性能为告警策略中设置的告警阈值,如果继续上升,业务可能出现问题。 表1 RocketMQ实例配置告警的指标 指标名称 正常范围 告警策略 是否接近性能上限 指标说明和告警处理建议 磁盘容量使用率
tMQ实例正常运行,此阶段为有效期;当您的账号因按需RocketMQ实例自动扣费导致欠费后,账号将变成欠费状态,RocketMQ实例将陆续进入宽限期和保留期。 图3 按需计费RocketMQ实例生命周期 欠费预警 系统会在每个计费周期后的一段时间对按需计费资源进行扣费。当您的账户
用于对应服务的操作。运算符与条件键一起使用,构成完整的条件判断语句。 DMS for RocketMQ通过IAM预置了一组条件键,例如,您可以先使用dms:ssl条件键检查RocketMQ实例是否开启SSL,然后再允许执行操作。下表显示了适用于DMS for RocketMQ服务特定的条件键。
储空间占用。 准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go
大消费的并发度越大。一个消费组表示一个消费者群组,在分布式应用场景下,同一个消费组中的多个消费者共同完成Topic所有Queue的消费。Queue的分配以消费组为单位,会均匀分配给消费组下的消费者,而不会在意该消费者是否订阅了当前Topic。一个消费者只会分配到Topic中的某几
最大重试次数 设置消费失败的最大重试次数。 取值范围:1~16 是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。 是否顺序消费 RocketMQ实例的版本为5.x时,需要设置此参数。
消息对应的业务逻辑有时间窗口要求,如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息,5分钟以后投递给消费者,消费者收到此消息后需要判断对应订单是否完成支付,如果未完成支付,则关闭订单。如果已完成,则忽略。 通过消息触发定时任务的场景,如在某些固定时间点向用户发送提醒消息。 注意事项 定
标详情”,可以进入云监控页面。 您也可直接在实例列表页面,单击待查看监控数据的实例所在行的“查看监控数据”,进入云监控页面。 在云监控页面,您可以自行选择哪些监控指标需要展示,以及对监控指标进行排序。 例如,在“节点”页签中,只需要展示“消息生产数”和“消息消费数”,请按照如下步骤操作。
型为“顺序”。 使用gRPC协议连接RocketMQ实例时,消费者是否顺序消费消息,取决于消费组中是否开启顺序消费,并非在消费代码中设置,顺序消费消息的代码与普通消费的代码相同。 准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。
code.test.com:443 Content-Type 消息体的类型(格式)。推荐用户使用默认值application/json,有其他取值时会在具体接口中说明。 是 application/json Content-Length 请求body长度,单位为Byte。 否 3495
Service,简称CTS),是华为云安全解决方案中专业的日志审计服务,提供对各种云资源操作记录的收集、存储和查询功能,可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。 用户开通云审计服务并创建和配置追踪器后,CTS可记录DMS for RocketMQ的管理事件用于审计。 CTS的详细介绍和开通配置方法,请参见CTS快速入门。
"ConsumerGroupName", true); 开启RocketMQ消息轨迹(Go) 在客户端开启消息轨迹的方法如下: 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 [root@ecs-test sarama]# go version
enableSsl(false) // 创建实例时,如果将“SSL”配置为“PLAINTEXT”,则请增加此行代码。如果将“SSL”配置为“PERMISSIVE”,则请根据实际情况选择是否增加此行代码。 // .setCredentialProvider(se
的连接信息。 准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go
如果是顺序消费,可通过消费者的setMaxReconsumeTimes函数配置。 是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。 是否顺序消费 RocketMQ实例的版本为5.x时,需要设置此参数。
重启RocketMQ实例。 修改是否开启SSL 修改SSL的配置。 开启公网访问 修改“公网访问”为开启。 关闭公网访问 修改“公网访问”为关闭。 变更规格 扩容存储空间 扩容代理数量 扩容代理规格 批量删除消费组 选择多个消费组,进行批量删除。 批量删除Topic 选择多个Topic,进行批量删除。
仅在实例的“状态”为“运行中”时,才可以删除实例中的Topic。 前提条件 已购买RocketMQ实例。 已创建Topic。 删除Topic 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式
消费验证是将消息重新发送到指定的在线客户端,验证消费者能否收到消息。消费验证会导致消息重复消费。 前提条件 仅在实例的“状态”为“运行中”时,才可以进行消费验证。 确保待进行消费验证的客户端处于在线状态,且消费者已订阅待重新发送的消息所属的Topic。 验证RocketMQ消息消费 登录管理控制台。