检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
对于管理员创建IAM用户接口,返回如图1所示的消息头。 图1 管理员创建IAM用户响应消息头 响应消息体(可选) 该部分可选。响应消息体通常以结构化格式(如JSON或XML)返回,与响应消息头中Content-type对应,传递除响应消息头之外的内容。 对于管理员创建IAM用户接口,返回如下消息体。为篇幅起见,这里只展示部分内容。
收发顺序消息 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息: 全局顺序消息:对于指定的一个Topic,将队列数量设置为1,这个队列内所有消息按照严格的先入先出FIFO(First In First
实例状态,详细状态说明请参考实例状态说明。 include_failure 否 String 是否返回创建失败的实例数。 当参数值为“true”时,返回创建失败的实例数。参数值为“false”或者其他值,不返回创建失败的实例数。 exact_match_name 否 String 是否按照实例名称进行精确匹配查询。
事务消息生产者需要实现两个回调函数,其中executeLocalTransaction回调函数在发送完半事务消息后被调用,即上图中的第3阶段,checkLocalTransaction回调函数在收到回查时调用,即上图中的第6阶段。两个回调函数均可返回3种事务状态: LocalTransactionState
name_srv:表示实例连接地址和端口。 事务消息生产者需要实现两个回调函数,其中local_execute回调函数在发送完半事务消息后被调用,即上图中的第3阶段,check_callback回调函数在收到回查时调用,即上图中的第6阶段。两个回调函数均可返回3种事务状态: TransactionStatus
事务消息生产者需要实现两个回调函数,其中ExecuteLocalTransaction回调函数在发送完半事务消息后被调用,即上图中的第3阶段,CheckLocalTransaction回调函数在收到回查时调用,即上图中的第6阶段。两个回调函数均可返回3种事务状态: primitive
创建消费组后不能修改关联代理。 最大重试次数 设置普通消费的最大重试次数。 取值范围:1~16 如果是顺序消费,可通过消费者的setMaxReconsumeTimes函数配置。 是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。
2以上才支持消息轨迹,如果版本不满足要求,请先升级。 开启RocketMQ消息轨迹(Java) 在客户端开启消息轨迹的方法如下: 生产者开启消息轨迹(除事务消息以外的消息类型) 构造函数的“enableMsgTrace”参数传入“true”,例如: DefaultMQProducer producer = new D
发送和异步发送。 同步发送:消息发送方发出一条消息到服务端,服务端接收并处理消息,然后返回响应给发送方,发送方收到响应后才会发送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。 收发普通消息前,请参考收集连接信息收集RocketMQ所需的连接信息。
发送和异步发送。 同步发送:消息发送方发出一条消息到服务端,服务端接收并处理消息,然后返回响应给发送方,发送方收到响应后才会发送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。 收发普通消息前,请参考收集连接信息收集RocketMQ所需的连接信息。
发送和异步发送。 同步发送:消息发送方发出一条消息到服务端,服务端接收并处理消息,然后返回响应给发送方,发送方收到响应后才会发送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。 以下示例仅介绍同步发送的示例代码。 收发普通消息前,请参考收
发送和异步发送。 同步发送:消息发送方发出一条消息到服务端,服务端接收并处理消息,然后返回响应给发送方,发送方收到响应后才会发送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。 收发消息前,请参考收集连接信息收集RocketMQ所需的连接信息。
该接口用于查询RocketMQ配置,若成功则返回配置的相关信息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/rocketmq/instances/{instance_id}/configs 表1 路径参数 参数 是否必选 参数类型 描述 project_id
ata 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 id 否 String 任务ID。 type
性能基线基于超高I/O及以上磁盘类型,高I/O磁盘类型可能无法达到当前标准。 分布式消息服务RocketMQ版4.8.0默认规格 分布式消息服务RocketMQ版4.8.0产品规格由以下六个维度定义: 资源规格:定义使用的弹性云服务器的规格类型。 代理个数:定义实例的规模。 存
版本支持公告 版本号说明 分布式消息服务RocketMQ版的版本号格式为:消息引擎类型 x.y.z,其中消息引擎类型为RocketMQ,版本号具体含义如图1所示。 图1 版本号示例 版本支持情况 分布式消息服务RocketMQ版支持的版本:4.8.0、5.x 版本生命周期 分布式
本章节介绍分布式消息服务RocketMQ版不同版本支持的实例类型和部署架构,5.x版本相比4.8.0版本的优势,以及不同实例类型、部署架构之前的差异,为您选择适合您业务的实例提供参考。 不同版本支持的实例类型和部署架构 表1 不同版本支持的实例类型和部署架构 实例版本 实例类型 部署架构 4.8.0 专业版 集群
同步发送:消息发送方发出一条消息到服务端,服务端接收并处理消息,然后返回响应给发送方,发送方收到响应后才会发送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。 表1 普通消息收发方式 消息类型 发送消息 订阅消息(PushConsumer) 订阅消息(SimpleConsumer)
理性的前提下,再考虑消费并发度问题。 消费耗时 影响消息处理时长的主要因素是业务处理的代码逻辑,而代码逻辑中会影响处理时长的主要有两种代码类型:CPU内部计算型代码和外部I/O操作型代码。如果代码中没有复杂的递归和循环处理,CPU内部计算耗时相对于外部I/O操作耗时来说几乎可以忽
送到Broker。 Consumer:从NameServer获取元数据,然后从Broker拉取消息。 支持的消息类型 分布式消息服务RocketMQ版支持4种消息类型。 普通消息:没有特殊功能的消息,区别于延迟消息、顺序消息和事务消息。 延迟消息/定时消息:生产者生产消息到分布式