检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
约束与限制 本章主要为您介绍分布式消息服务RocketMQ版使用过程中的一些限制。 如果因为您的实例配置超过相应的约束和限制而导致的任何不稳定情况,不在SLA承诺和赔偿范围内。 实例 表1 实例约束与限制 限制项 约束与限制 版本 实例创建后,不支持变更版本。建议服务端版本和客户端版本保持一致。
1s以内。但在定时消息投递压力过大时,会触发定时消息投递流控机制,精度会变差。 在0.1s的精度内,不保证消息投递的顺序性。即如果两条定时消息的定时时间差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间
1s以内。但在定时消息投递压力过大时,会触发定时消息投递流控机制,精度会变差。 在0.1s的精度内,不保证消息投递的顺序性。即如果两条定时消息的定时时间差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间
使用ACL权限访问 实例开启ACL访问控制后,消息生产者和消费者都需要增加用户认证信息。 约束与限制 RocketMQ TCP协议的Python SDK只支持Linux系统。 生产者增加用户认证信息 普通消息、顺序消息和定时消息,参考如下代码。以下加粗内容需要替换为实例自有信息,请根据实际情况替换。
异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。 收发消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发普通消息前,需要确保Topic的消息类型为“普通”。
在“连接信息”区域,单击“弹性TPS”后的,弹出确认开启提示框。 开启弹性TPS能力后,消息收发允许在一定范围内超过基础规格限制的TPS,且超过基础规格外的部分,需要收取额外的弹性规格费用。 关闭弹性TPS能力后,消息收发将限制在基础规格TPS之内。 单击“确定”,开启弹性TPS功能。 父主题: 管理实例
1s以内。但在定时消息投递压力过大时,会触发定时消息投递流控机制,精度会变差。 在0.1s的精度内,不保证消息投递的顺序性。即如果两条定时消息的定时时间差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间
1s以内。但在定时消息投递压力过大时,会触发定时消息投递流控机制,精度会变差。 在0.1s的精度内,不保证消息投递的顺序性。即如果两条定时消息的定时时间差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间
同步发送 异步发送 不分区同步订阅和异步订阅 同步订阅 异步订阅 收发消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发普通消息前,需要确保Topic的消息类型为“普通”。
RocketMQ配置名称。 value 否 String RocketMQ配置目标值。 响应参数 无 请求示例 修改RocketMQ配置的参数,将文件保留时间修改为72小时。 PUT https://{endpoint}/v2/{project_id}/rocketmq/instanc
精确识别,达到权限管理的目的。开启ACL权限控制功能后,生产消息和消费消息时,需要鉴权。 约束与限制 仅2021年8月21号后购买的实例,支持设置ACL访问控制。 开启ACL访问控制会导致没有配置认证信息的客户端连接中断。 前提条件 已购买RocketMQ实例。 开启RocketMQ
全局顺序消息和分区顺序消息的区别仅为队列数量不同,代码没有区别。 收发顺序消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。
emo中获取。 下文所有RocketMQ的配置信息,如实例连接地址、Topic名称、用户信息等,请参考收集连接信息获取。 在pom.xml文件中引入RocketMQ-Spring依赖 <dependency> <groupId>org.apache.rocketmq</groupId>
全局顺序消息和分区顺序消息的区别仅为队列数量不同,代码没有区别。 收发顺序消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。
MQ消息存储在CommitLog文件中,CommitLog文件大小为1GB,当一个CommitLog文件写满后,会生成一个新的CommitLog文件。RocketMQ删除消息是删除CommitLog文件,而不是删除一条消息。CommitLog文件为顺序写入,当最后写入的一条消息过
息只有在提交之后才投递给消费者,消费者对回滚的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。
回收站策略默认是关闭状态。 约束与限制 回收站中的按需实例不会收取实例的费用,但是会收取存储空间的费用。 包年/包月的实例退订后会存入回收站中,此时不会收取实例的费用,但是会按需收取存储空间的费用。 包年/包月的实例从回收站中恢复后,计费模式会变为按需计费。 处于宽限期和保留期的
-c {RocketMQ集群名称} -f {导出的元数据文件的存放路径} 例如:“nameserver地址及端口号”为“192.168.0.65:8100”,“RocketMQ集群名称”为“DmsCluster”,“导出的元数据文件的存放路径”为“/tmp/rocketmq/export”。
√ × 实例规格(单机实例) × × 存储空间(集群实例) √ × 实例规格(集群实例) √ √ 约束与限制 扩容存储空间有次数限制,只能扩容20次。 扩容代理个数时,系统会根据当前磁盘大小进行相应比例的存储空间扩容。例如扩容前实例的代理数为1,每个代理的磁盘大小为300GB,扩
x版本批量创建不同类型的Topic 新建“topics.txt”文件,用于存放待创建的Topic信息。 文件内容格式为“Topic名称 消息类型”,消息类型包含普通(NORMAL)、顺序(FIFO)、定时(DELAY)、事务(TRANSACTION)四种。文件内容填写示例如下: topic-test01