检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
参数管理 查询RocketMQ配置 修改RocketMQ配置 父主题: API V2(推荐)
怎么判断哪个是主节点? 一个Broker由一个主节点和两个备节点组成,当您购买的Broker数为1时,实际创建3个Broker节点。三个节点采用raft模式部署,使用Broker ID分别为1、2、3,当其中一台节点选为主节点后,Broker ID变成0。因此,“Broker ID”显示“0”的节点为主节点。
概述 第二章介绍如何获取RocketMQ实例连接信息。 第三章~第七章介绍Java、Go和Python客户端访问分布式消息服务RocketMQ版的示例代码,具体如表1所示。 表1 示例代码 客户端语言 示例代码 Java(TCP协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息
无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积,那么定时消息会排在堆积消息后面,将不能严格按照配置的时间进行投递。 由于客户端和服务端可能存在时间差,消息的实际投递时间与客户端设置的投递时间之间可能存在偏差,以服务端时间为准。 设置定时
后台任务列表 任务名 说明 创建实例 创建一个RocketMQ实例。 重启实例 重启RocketMQ实例。 修改是否开启SSL 修改SSL的配置。 开启公网访问 修改“公网访问”为开启。 关闭公网访问 修改“公网访问”为关闭。 变更规格 扩容存储空间 扩容代理数量 扩容代理规格 批量删除消费组
识别空闲资源,寻找节约成本的机会。也可以根据成本分析阶段的分析结果识别成本偏高的资源,然后采取针对性的优化措施。 监控资源利用率,评估当前配置是否过高。例如:CPU、内存、云硬盘等资源的利用率。 监控闲置的资源,避免浪费。例如:未挂载的云硬盘、未绑定的EIP等。 计费模式优化 不
计费项 计费项说明 适用的计费模式 计费公式 实例费用 4.8.0版本计费因子:代理规格和代理数量 5.x基础版和专业版计费因子:TPS和部署类型 包年/包月、按需计费 实例规格单价 * 购买时长 实例规格单价请参见分布式消息服务RocketMQ版价格详情中的“实例价格”。 存储空间费用
管理消费组 创建RocketMQ消费组 查看RocketMQ消费组详情 查看RocketMQ消费者连接地址 修改RocketMQ消费组配置 重置RocketMQ消费进度 删除RocketMQ消费组
RocketMQ实例兼容开源RocketMQ哪个版本? 实例可靠性是怎么保障的? 为什么RocketMQ 4.8.0版本不能选择2个可用区? RocketMQ实例的SSL配置是否支持修改? 磁盘类型对RocketMQ实例性能有什么影响?
节介绍订阅关系一致的概念、原理以及实施方法。 消息堆积处理建议 本章节介绍出现消息堆积的主要原因和实施方法。 配置消息堆积数监控 本章节介绍RocketMQ通过云监控配置告警规则的具体操作,以便您可以实时监控实例的运行状态和关键的业务指标,并能够及时收到异常的告警通知,实现生产环境的风险预警。
“更多 > 转包周期”,跳转到“按需转包年/包月”页面。 选择RocketMQ实例的购买时长,判断是否勾选“自动续费”,确认预计到期时间和配置费用后单击“去支付”。 图1 按需转包年/包月 进入支付页面,选择支付方式,确认付款,支付订单后即可完成按需转包年/包月。 父主题: 变更计费模式
的时候将Token加到请求消息头,从而通过身份认证,获得操作API的权限。Token可通过调用获取用户Token接口获取。 云服务存在两种部署方式:项目级服务和全局级服务。其中: 项目级服务需要获取项目级别的Token,此时请求body中auth.scope的取值为project。
开通自动续费后,还可以手动续费该RocketMQ实例。手动续费后,自动续费仍然有效,在新的到期时间前的第7天开始扣款。 自动续费的到期前7日自动扣款属于系统默认配置,您也可以根据需要修改此扣款日,如到期前6日、到期前5日等等。 更多关于自动续费的规则介绍请参见自动续费规则说明。 前提条件 请确认包年/包月RocketMQ实例还未到期。
ID。 如果通过按Message Key查询,需要提前获取消息所在的Topic名称和消息的Message Key。 Message Key为7中配置的消息Key,也可先通过Topic查询消息,记录Message Key。 查询消息内容 登录管理控制台。 在管理控制台左上角单击,选择区域。
"ACL_SECRET_KEY", # 角色密钥 '' )#用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 producer.start() msg = create_message()
"credits" or "license" for more information. >>> 如果未安装Python,请使用以下命令安装: yum install python 安装librocketmq库和rocketmq-client-python,具体操作请参考rocketmq-client-python。
新增查询产品规格列表、查询RocketMQ产品规格核数、查询实例节点和重启指定实例接口。 2024-09-04 本次变更如下: 更新查询RocketMQ配置的响应示例。 2024-07-05 本次变更如下: 新增应用示例批量创建Topic。 2023-12-15 本次变更如下: 新增查询实例的扩容规格列表和实例规格变更接口。
元数据迁移 包括新建元数据迁移任务、查询实例下所有迁移任务或查询指定迁移任务信息、删除元数据迁移任务。 参数管理 包括修改RocketMQ配置。 标签管理 包括添加或删除实例标签、查询实例标签和查询项目标签。 其他接口 包括查询可用区信息。 规格变更管理 包括查询实例的扩容规格列表和实例规格变更。
消息堆积处理建议 方案概述 在RocketMQ的实际业务中,消息堆积是比较常见的问题。在消息处理过程中,如果客户端的消费速度跟不上服务端的发送速度,未处理的消息会越来越多,这部分消息就被称为堆积消息。消息没有被及时消费而产生消息堆积,从而会造成消息消费延迟。对于消息消费实时性要求
type String 产品类型,single或者cluster。 product_id String 产品ID。 ecs_flavor_id String ECS的flavor id。 billing_code String CBC的规格码。 arch_types Array of