检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
测试4.8.0版本RocketMQ实例性能 本章节主要测试RocketMQ实例4.8.0版本不同产品规格在发送1KB大小的消息,且CPU使用率达到80%以上时,实例的网络入流量、网络出流量、消息生产速率、消息消费速率、CPU核均负载和内存使用率。 测试环境 进行测试前,您需要先构建如下的测试环境
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务回滚
发送定时消息 分布式消息服务RocketMQ版支持任意时间的定时消息,最大推迟时间可达到1年。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前,请参考收集连接信息收集RocketMQ
收发普通消息 本章节介绍普通消息的收发方法和示例代码。其中,普通消息发送方式分为同步发送和异步发送。RocketMQ提供PushConsumer和SimpleConsumer类型的消费者,PushConsumer消费者订阅普通消息时,代码不区分同步订阅和异步订阅。SimpleConsumer
服务韧性 DMS for RocketMQ提供了3级可靠性架构,通过跨AZ容灾、AZ内实例容灾、实例数据多副本技术方案,保障服务的持久性和可靠性。 表1 DMS for RocketMQ可靠性架构 可靠性方案 简要说明 跨AZ容灾 DMS for RocketMQ提供跨AZ类型实例
自动续费 自动续费可以减少手动续费的管理成本,避免因忘记手动续费而导致RocketMQ实例被自动删除。自动续费的规则如下所述: 以RocketMQ实例的到期日计算第一次自动续费日期和计费周期。 RocketMQ实例自动续费周期根据您开通自动续费的途径不同,遵循不同的规则。 在RocketMQ
配置消息堆积数监控 方案概述 在消息处理过程中,如果客户端的消费速度跟不上服务端的发送速度,未处理的消息会越来越多,这部分消息就被称为堆积消息。消息没有被及时消费就会产生消息堆积,从而会造成消息消费延迟。 如果您想要在消费组的消息堆积数超过阈值时,通过短信/邮件及时收到通知信息,可以参考本章节设置告警通知
迁移RabbitMQ的元数据到RocketMQ实例 分布式消息服务RocketMQ版支持通过控制台迁移RabbitMQ的元数据到云上RocketMQ实例。 前提条件 已购买RocketMQ实例。 已开启RabbitMQ管理插件。 已购买RabbitMQ 3.7.17/3.8.35版本实例
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务回滚
开启和查询RocketMQ消息轨迹 在一条消息从生产者发出到消费者消费处理过程中,由各个相关节点的时间、地点等数据汇聚而成的完整链路信息。通过消息轨迹,您能清晰定位消息从生产者发出,经由RocketMQ服务端,投递给消费者的完整链路,方便定位排查问题。 本章节介绍使用Java、Go
查看RocketMQ消息 本章节指导您通过查询消息功能查看具体的消息内容,以及确定消息是否生产/消费成功。 分布式消息服务RocketMQ版提供三种消息查询的方法:按Topic查询、按Message ID查询和按Message Key查询。 按Topic查询:查询某时间段内指定Topic
收发普通消息 本章节介绍普通消息的收发方法和示例代码。普通消息发送方式分为同步发送和异步发送。 同步发送:消息发送方发出一条消息到服务端,服务端接收并处理消息,然后返回响应给发送方,发送方收到响应后才会发送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息
功能总览 功能总览 全部 购买RocketMQ实例 连接RocketMQ实例 Topic管理 变更实例规格 公网访问 消息查询 消费组管理 用户管理 死信队列 实例诊断 收发消息 定时消息 监控 审计 API 购买RocketMQ实例 您在使用分布式消息服务RocketMQ版前,需要先购买
批量创建Topic RocketMQ未提供批量创建Topic接口,用户想批量创建Topic时只能手动多次调用接口一个个创建,效率低下。现通过代码实现接口循环调用,可实现批量创建Topic的效果。 前提条件 已获取IAM和RocketMQ服务所在区域的Endpoint地址。 已获取RocketMQ
状态码 状态码如表1所示 表1 状态码 状态码 编码 错误码说明 100 Continue 继续请求。 这个临时响应用来通知客户端,它的部分请求已经被服务器接收,且仍未被拒绝。 101 Switching Protocols 切换协议。只能切换到更高级的协议。 例如,切换到HTTP
创建用户并授权使用DMS for RocketMQ 如果您需要对您所拥有的DMS for RocketMQ进行精细的权限管理,您可以使用统一身份认证服务(Identity and Access Management,简称IAM),通过IAM,您可以: 根据企业的业务组织,在您的华为账号中
RocketMQ支持的监控指标 功能说明 本章节定义了分布式消息服务RocketMQ版上报云监控服务的监控指标的命名空间,监控指标列表和维度定义,您可以通过分布式消息服务RocketMQ版控制台来检索分布式消息服务RocketMQ版产生的监控指标和告警信息。 命名空间 SYS.DMS