正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RocketMQ业务使用流程 分布式消息服务RocketMQ版(以下简称RocketMQ)是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。用户购买RocketMQ实例后,生产者客户端连接RocketMQ实例进行消息生产,生产的消息被存储在RocketMQ实例的Topic中,消费者客户端通过订阅Topic消费消息。
分区上是否还有可用资源。 default_az Boolean 是否为默认可用区。 remain_time Long 剩余时间。 ipv6_enable Boolean 是否支持IPv6。 请求示例 查询可用区信息。 GET https://{endpoint}/v2/available-zones
final SendReceipt sendReceipt = producer.send(message); log.info("Send message successfully, messageId={}", sendReceipt.getMessageId());
送给消费者进行消费。 发送定时消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 2022年3月30日及以后购买的实例支持定时消息功能,在此之前购买的实例不支持此功能。 客户端连接RocketMQ实例5.x版本收发定时消息前,需要确保Topic的消息类型为“定时”。 适用场景
送给消费者进行消费。 发送定时消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 2022年3月30日及以后购买的实例支持定时消息功能,在此之前购买的实例不支持此功能。 客户端连接RocketMQ实例5.x版本收发定时消息前,需要确保Topic的消息类型为“定时”。 适用场景
送给消费者进行消费。 发送定时消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 2022年3月30日及以后购买的实例支持定时消息功能,在此之前购买的实例不支持此功能。 客户端连接RocketMQ实例5.x版本收发定时消息前,需要确保Topic的消息类型为“定时”。 适用场景
指标说明和告警处理建议 磁盘容量使用率 0~100 告警阈值:原始值>85 连续触发次数:3 告警级别:紧急 是 指标说明:该指标为从RocketMQ节点虚拟机层面采集的磁盘容量使用率。单位:%。 处理建议:出现该告警时,说明当前实例规格已不足以承载业务,需要扩容存储空间。具体操作,请参考变更实例规格。
final SendReceipt sendReceipt = producer.send(message); log.info("Send message successfully, messageId={}", sendReceipt.getMessageId());
ps { "name" : "consumer-group-test", "group_desc" : "group_description", "brokers" : [ "broker-0" ], "broadcast" : false, "retry_max_time"
计费样例 计费场景 某用户于2023/03/18 15:30:00在“华北-北京四”区域购买了一个按需计费4.8.0版本的RocketMQ实例,规格配置如下: 规格:rocketmq.4u8g.cluster*1 总存储空间:高I/O,300GB 用了一段时间后,用户发现Rock
Integer 代理数量 当oper_type参数为horizontal时,该参数必填。 publicip_id 否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 当oper_type参数为horizontal且开启了公网访问时,此参数必填。 响应参数
"c131886aec...", "name": "IAMUser", "description": "IAM User Description", "areacode": "", "phone": "",
cn-north-1.myhuaweicloud.com/rocketmq-tutorial.zip 解压“rocketmq-tutorial”。 unzip rocketmq-tutorial.zip (可选)如果RocketMQ实例开启了ACL访问控制,执行mqadmin命令时,需要鉴权。
return; } try { final SendReceipt sendReceipt = producer.send(message, transaction); log.info("Send
本分配。 通过企业项目进行成本分配 在进行成本分配之前,建议开通企业项目并做好企业项目的规划,可以根据企业的组织架构或者业务项目来划分。在购买云资源时选择指定企业项目,新购云资源将按此企业项目进行成本分配。详细介绍请参见通过企业项目维度查看成本分配。 图2 为RocketMQ实例选择企业项目
final SendReceipt sendReceipt = producer.send(message); log.info("Send message successfully, messageId={}", sendReceipt.getMessageId());
property_list objects 消息属性列表。 born_host String 产生消息的主机IP。 store_host String 存储消息的主机IP。 queue_id Integer 队列ID。 queue_offset Integer 在队列中的偏移量。
如果某个Topic不再使用,可参考本章节删除Topic,释放资源。 仅在实例的“状态”为“运行中”时,才可以删除实例中的Topic。 前提条件 已购买RocketMQ实例。 已创建Topic。 删除Topic 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。
cn-north-1.myhuaweicloud.com/rocketmq-tutorial.zip 解压“rocketmq-tutorial”。 unzip rocketmq-tutorial.zip (可选)如果RocketMQ实例开启了ACL访问控制,执行mqadmin命令时,需要鉴权。
续费相关的功能 包年/包月RocketMQ实例续费相关的功能如表1所示。 表1 续费相关的功能 功能 说明 手动续费 包年/包月RocketMQ实例从购买到被自动删除之前,您可以随时在RocketMQ控制台为RocketMQ实例续费,以延长RocketMQ实例的使用时间。 自动续费 开通自动