检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
云硬盘单价 * 购买时长 云硬盘单价请参见分布式消息服务RocketMQ版价格详情中的“存储价格”。 弹性TPS费用 5.x专业版时,如果开启弹性TPS功能,则会按照超过实例基础规格TPS上限的增量部分进行计费。 取值为计费周期即1小时内,增量部分TPS的最大值。 按量付费(先使用后付费)
rocketmq.name-server=127.0.0.1:9876 rocketmq.producer.group=my-group ## 是否开启SSL rocketmq.producer.tls-enable=true #=============== 消费者配置 =======================
客户端连接RocketMQ实例的方式如表1所示。 表1 连接方式说明 连接方式 实现方式 参考文档 公网连接 在RocketMQ控制台开启公网访问,配置弹性公网IP,客户端通过弹性公网IP访问RocketMQ实例。 配置RocketMQ实例的公网访问 内网连接 客户端和Roc
单线程发送、单线程消费并且不采用延迟队列、优先级队列等一些高级功能时,才能实现消息有序。 安全机制 支持SSL认证。 支持SSL、SASL身份认证和读写权限控制。 3.8.35版本:支持SSL认证。 AMQP-0-9-1版本:支持ACL访问控制。 事务性消息 支持 支持 支持
存储空间费用 总存储空间的费用。 4.8.0版本时,总存储空间的费用为单个代理的存储空间*代理数量。 弹性TPS费用 5.x专业版时,如果开启弹性TPS功能,则会按照超过实例基础规格TPS上限的增量部分进行计费。 取值为计费周期即1小时内,增量部分TPS的最大值。 说明: 专业版目前还处于公测阶段。
setNamesrvAddr("192.168.0.1:8100"); //producer.setUseTLS(true); //创建实例时,如果开启了SSL,请增加此行代码。 producer.setTransactionListener(transactionListener);
cluster 1 高I/O 300GB 关闭 关闭 创建如表2所示Topic,创建步骤请参考创建Topic。 表2 Topic参数 名称 权限 关联代理 队列个数 topic-01 发布+订阅 broker-0 8 创建如表3所示消费组,创建步骤请参考创建消费组。 表3 消费组参数
点,从而导致消息生产失败。其中,放通的网段为实例所在子网网段,放通的端口范围为10100~(10100+3n-1)(n表示代理数量)。 已开启公网访问,且设置了弹性IP地址的实例,在扩容代理个数时,需要为新扩容的代理设置弹性IP地址。 扩容代理个数不会影响原来的代理,业务也不受影响。
instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 overwrite 是 String true开启同名覆盖,会对已有的同名元数据的配置进行修改,false时当Topic或group已存在则会报错。 name 是 String 迁移任务名称,名称规则参考创建实例。
Number 总读队列个数。 total_write_queue_num Number 总写队列个数。 permission String 权限。 brokers Array of brokers objects 关联的代理。 message_type String 消息类型(RocketMQ实例5
app_id String 应用ID。 app_name String 应用名称。 permissions Array of strings 权限。 请求示例 查询指定消费组的详细信息。 GET https://{endpoint}/v2/{project_id}/instances
最大重试次数,取值范围为1~16。 createdAt Long 创建时间戳。 permissions Array of strings 权限集。 consume_orderly Boolean 是否按顺序消费。 请求示例 查询RocketMQ实例的消费组列表。 GET http
white_remote_address String IP白名单。 admin Boolean 是否为管理员。 perm String 权限。 请求示例 查询主题的授权用户列表。 GET https://{endpoint}/v2/{project_id}/instances/
否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 当oper_type参数为horizontal且开启了公网访问时,此参数必填。 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 job_id String 规格变更任务ID。
Number 总读队列个数。 total_write_queue_num Number 总写队列个数。 permission String 权限。 brokers Array of brokers objects 关联的代理。 message_type String 消息类型(RocketMQ实例5
被彻底删除,不会进入回收站。 华为云根据客户等级定义了不同客户的宽限期和保留期时长。 关于续费的详细介绍请参见续费概述。 回收站计费策略 开启回收站策略的包年/包月实例,退订后会存入回收站中,此时不收取实例费用,但是会按需收取存储空间费用。 从回收站中恢复的包年/包月实例,计费模式会变为按需计费。
of queues objects 队列(仅RocketMQ实例4.8.0版本需要填写此参数)。 permission 否 String 权限(仅RocketMQ实例4.8.0版本需要填写此参数)。 取值范围: pub(发布) sub(订阅) all(发布+订阅) message_type