-
成本管理 - 分布式消息服务RocketMQ版
IP等。 计费模式优化 不同类型的业务对资源使用周期有不同的要求,为每一类业务确定合适的计费模式,灵活组合以达到最优效果。 针对长期稳定的成熟业务,使用包年/包月计费模式。 针对不能中断的短期、突增或不可预测的业务,使用按需计费模式。 实现自动化运维 华为云也提供了丰富的运维类产
-
停止计费 - 分布式消息服务RocketMQ版
停止计费 包年/包月资源 对于包年/包月计费模式的资源,例如包年/包月的RocketMQ实例,用户在购买时会一次性付费,服务将在到期后自动停止使用。 如果在计费周期内不再使用包年/包月资源,您可以执行退订操作,系统将根据资源是否属于五天无理由退订、是否使用代金券和折扣券等条件返还
-
购买RocketMQ实例 - 分布式消息服务RocketMQ版
使用gRPC协议,通过公网访问实例的端口 操作步骤 进入购买RocketMQ实例页面。 选择“计费模式”、“区域”、“项目”和“可用区”。 设置实例信息。 实例名称:实例的名称,用于区分不同的实例。 企业项目:根据实际业务情况选择企业项目。 规格选择模式:选择“默认”或者“规格测算”。 选择“默认”,且“版本”为“4
-
RocketMQ业务迁移 - 分布式消息服务RocketMQ版
的迁移将失败。 元数据 上传获取其他厂商或自建RocketMQ实例的元数据。 单击“确定”。 迁移完成后,在迁移任务列表页面查看“任务状态”。 当“任务状态”为“迁移完成”,表示所有元数据都已成功迁移。 当“任务状态”为“迁移失败”,表示元数据中部分或全部元数据迁移失败。单击迁移
-
实例版本概述 - 分布式消息服务RocketMQ版
与4.8.0版本相比,5.x版本具有如下优势: 架构更先进 5.x版本提供无状态的Proxy接入,解决无法通过代理访问的问题。5.x提供了Pop消费模式,降低消费堆积发生的概率。 开发门槛更低 支持开源gRPC协议SDK,提供更多种语言的SDK,API更加简洁友好。 成本更弹性 支持
-
迁移其他RocketMQ的元数据到RocketMQ实例 - 分布式消息服务RocketMQ版
1的迁移将失败。 元数据 上传其他厂商或自建RocketMQ实例的元数据。 单击“确定”。 迁移完成后,在迁移任务列表页面查看“任务状态”。 当“任务状态”为“迁移完成”,表示所有元数据都已成功迁移。 当“任务状态”为“迁移失败”,表示元数据中部分或全部元数据迁移失败。单击迁移任
-
收发普通消息 - 分布式消息服务RocketMQ版
enableSsl(false) // 创建实例时,如果开启了SSL,请增加此行代码。 // .setCredentialProvider(sessionCredentialsProvider) // 创建实例时,如果开启了ACL,请添加此行代码。
-
查看和修改RocketMQ实例基本信息 - 分布式消息服务RocketMQ版
RocketMQ实例支持通过筛选来查询对应的RocketMQ实例。当前支持的筛选条件为状态、名称、版本、实例类型、规格、已用/可用存储空间、计费模式、企业项目和标签。RocketMQ实例状态请参见表1。 表1 RocketMQ实例状态说明 状态 说明 创建中 创建RocketMQ实例后
-
变更实例 - 分布式消息服务RocketMQ版
变更实例 变更RocketMQ实例规格 变更RocketMQ实例计费模式为包周期
-
与Kafka、RabbitMQ的差异 - 分布式消息服务RocketMQ版
支持 不支持 不支持 死信队列 支持 不支持 支持 消息重试 支持 不支持 不支持 消费模式 支持客户端主动拉取和服务端推送两种方式 客户端主动拉取 支持客户端主动拉取以及服务端推送两种模式 广播消费 支持 支持 支持 消息回溯 支持 支持。Kafka支持按照offset和timestamp两种维度进行消息回溯。
-
版本发布说明 - 分布式消息服务RocketMQ版
实例版本 发布时间 新增/优化特性 5.x 2023年7月 兼容开源RocketMQ 5.x和4.x协议 实例支持gRPC协议 实例支持pop消费模式 4.8.0 2022年3月 实例支持定时消息 4.8.0 2021年8月 实例支持ACL访问控制权限 父主题: 版本公告
-
快速连接RocketMQ并生产消费消息 - 分布式消息服务RocketMQ版
PATH=$JAVA_HOME/bin:$PATH “/opt/java/jdk1.8.0_151”为JDK的安装路径,请根据实际情况修改。 退出编辑模式并执行如下命令保存环境变量文件。 :wq 执行如下命令使环境变量生效。 source .bash_profile 环境变量文件名称请根据实际查找到的进行修改。
-
查询指定实例 - 分布式消息服务RocketMQ版
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak := os.Getenv("CLOUD_SDK_AK") sk := os.Getenv("CLOUD_SDK_SK")
-
创建实例 - 分布式消息服务RocketMQ版
以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 broker_num 是 Integer 代理个数 bss_param 否 BssParam object 表示包周期计费模式的相关参数。 如果为空,则默认计费模式为按需计费;否则是包周期方式。
-
修改RocketMQ消费组配置 - 分布式消息服务RocketMQ版
编辑消费组”页面。 修改如表1所示配置信息。 表1 消费组参数说明 参数 说明 最大重试次数 设置消费失败的最大重试次数。 是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。 是否顺序消费
-
创建RocketMQ消费组 - 分布式消息服务RocketMQ版
最大重试次数 设置普通消费的最大重试次数。 如果是顺序消费,可通过消费者的setMaxReconsumeTimes函数配置。 是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。 是否顺序消费
-
计费样例 - 分布式消息服务RocketMQ版
购买时长为1个月。那么在3~4月份,该RocketMQ实例总共产生多少费用呢? 计费构成分析 可以将RocketMQ实例的使用阶段按照计费模式分为两段:在2023/03/18 15:30:00 ~ 2023/03/20 10:30:00期间为按需计费,2023/03/20 10:30:00
-
收发普通消息 - 分布式消息服务RocketMQ版
setNamesrvAddr("192.168.0.1:8100"); //producer.setUseTLS(true); //创建实例时,如果开启了SSL,请添加此行代码。 try { producer.start(); Message
-
测试5.x版本RocketMQ实例性能 - 分布式消息服务RocketMQ版
名称 消息类型 topic-01 普通 创建如表3所示消费组,创建步骤请参考创建消费组。 表3 消费组参数 名称 最大重试次数 是否允许以广播模式消费 是否顺序消费 group-01 16 否 否 购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持
-
错误码 - 分布式消息服务RocketMQ版
has the read-only permission and cannot perform operations on DMS. 租户只有只读权限,无法操作DMS。 请检查租户权限 403 DMS.00403003 This role does not have the permissions