检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RocketMQ支持通过控制台导出实例列表信息,供用户查看和使用。 前提条件 已购买RocketMQ实例。 导出RocketMQ实例列表 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分
已用消息存储空间,单位:GB。 enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 publicip_address
是否返回创建失败的实例数。 当参数值为“true”时,返回创建失败的实例数。参数值为“false”或者其他值,不返回创建失败的实例数。 exact_match_name 否 String 是否按照实例名称进行精确匹配查询。 默认为“false”,表示模糊匹配实例名称查询。若参数值为“
fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询消费组成功。 错误码 请参见错误码。 父主题: 消费组管理
顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息: 全局顺序消息:对于指定的一个Topic,将队列数量设置为1,这个队列内所有消息按照严格的先入先出FIFO(First In First Out)的顺序进行发布和订阅。 分
查询产品规格列表 功能介绍 查询相应引擎的产品规格列表。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/products 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎的类型。支持的类型为rocketmq。 表2
fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询主题消费组列表成功。 错误码 请参见错误码。 父主题: Topic管理
fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 204 删除指定的实例成功。 错误码 请参见错误码。 父主题: 生命周期管理
topic 否 String 待查询的Topic,不指定时查询Topic列表,指定时查询详情。 limit 否 Integer 当次查询返回的最大个数,默认值为10,取值范围为1~50。 offset 否 Integer 偏移量,表示从此偏移量开始查询, offset大于等于0。 请求参数
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
否 Integer 查询数量,取值范围为1~50。 offset 否 Integer 偏移量,表示从此偏移量开始查询, offset大于等于0。 is_detail 否 Boolean 是否查询消费者详细列表,参数为“true”则表示查询详细列表,否则表示查询简易列表。 请求参数
诊断完成后,在“诊断记录”区域,新增一条诊断记录。 单击“查看报告”,进入“实例诊断”页面,查看诊断结果。 您可以查看到消费组状态是否在线、消费者数量、订阅关系是否一致和消息堆积量,并根据结果分析处理生产和消费消息时所遇到的问题。 图1 诊断结果 消费组不在线时,可以诊断成功,但是会显示1项异常。
查询RocketMQ产品规格核数 功能介绍 查询RocketMQ产品规格核数。 调用方法 请参见如何调用API。 URI GET /v2/rocketmq/products/cores 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 core_nume
RocketMQ-Spring的使用 本文介绍如何使用RocketMQ-Spring连接华为云RocketMQ实例进行消息的生产和消费。相关代码您可以从rocketmq-springboot-demo中获取。 下文所有RocketMQ的配置信息,如实例连接地址、Topic名称、用户信息等,请参考收集连接信息获取。
顺序消息:消费者按照消息发送的顺序来消费消息。 事务消息:提供类似X/Open XA的分布事务功能,通过事务消息能达到分布式事务的最终一致。 支持的高级特性 分布式消息服务RocketMQ版支持4种高级特性。 消息过滤:消费者根据分布式消息服务RocketMQ版设置的标签对已订阅Topic中的消息进行过滤,达到只消费需要的消息的目的。
支持多语言的客户端。 采用Scala和Java编写,支持多种语言的客户端。 支持多种语言的客户端。 流量控制 RocketMQ 5.x支持基于实例规格的流量控制。 支持client、user和Topic级别,通过主动设置可将流控作用于生产者或消费者。 RabbitMQ的流控基于C
费用账单 您可以在“费用中心 > 账单管理”查看资源的费用账单,以了解该资源在某个时间段的使用量和计费信息。 账单上报周期 包年/包月计费模式的资源完成支付后,会实时上报两条账单(实例费用账单和存储空间费用账单)到计费系统进行结算。 按需计费模式的资源按照固定周期上报使用量到计费系统进
在实例列表页面的“可用存储空间”中查看扩容后的总存储空间大小(即扩容后的单个代理的存储空间*代理个数)。 扩容存储空间不会影响业务。 可用存储空间=实际存储空间-用于存储日志的存储空间-格式化磁盘的损耗。 例如,实际扩容存储空间到700GB,用于存储日志的存储空间为100GB,格式化磁
Topic名称的命名规则是什么? 创建Topic时,请确保唯一性。Topic名称命名规则必须满足如下要求: 长度为3~64个字符。 只能由英文字母、数字、百分号、竖线、中划线、下划线组成。 不能以“rmq_sys_”开头。 不能和以下字符串相同: TBW102 SCHEDULE_TOPIC_XXXX
修改RocketMQ实例的SSL配置 操作场景 您可以通过明文接入RocketMQ实例,也可以通过密文接入RocketMQ实例,本章节指导您在控制台修改接入方式。 RocketMQ实例支持的接入方式如下: SSL:服务端与客户端之间通过密文传输,安全性较高,性能较低。 PLAIN