检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
本章节介绍分布式消息服务RocketMQ版不同版本支持的实例类型和部署架构,5.x版本相比4.8.0版本的优势,以及不同实例类型、部署架构之前的差异,为您选择适合您业务的实例提供参考。 不同版本支持的实例类型和部署架构 表1 不同版本支持的实例类型和部署架构 实例版本 实例类型 部署架构 4.8.0 专业版
责任共担 华为云秉承“将公司对网络和业务安全性保障的责任置于公司的商业利益之上”。针对层出不穷的云安全挑战和无孔不入的云安全威胁与攻击,华为云在遵从法律法规业界标准的基础上,以安全生态圈为护城河,依托华为独有的软硬件优势,构建面向不同区域和行业的完善云服务安全保障体系。 安全性是华为云与您的共同责任,如图1所示。
正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制,消息老化时间修改后,正常消息的保留时间和死信消息的保留时间都会被修改。 实例创建后,您可以根据业务需要修改消息老化时间。修改老化时间,不会重启实例。消息老化时间默认为48小时。 前提条件 已购买RocketMQ实例。 修改RocketMQ消息保留时间
使用TCP协议,通过公网访问元数据节点的端口。 入方向 TCP 10100-10199 使用TCP协议,通过内网访问业务节点的端口。 入方向 TCP 10101-10199 使用TCP协议,通过公网访问业务节点的端口。 表3 安全组规则(RocketMQ实例5.x版本) 方向 协议 端口 源地址 说明
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
消息。 支持区域: 全部 创建Topic 查询Topic信息 修改Topic参数 变更实例规格 RocketMQ实例创建成功后,您可以根据业务需要,扩容存储空间和代理个数。不支持同时扩容存储空间和代理个数,如果需要可以分别进行扩容。 当前只支持扩容,不支持缩容。扩容存储空间有次数限制,只能扩容20次。
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
如表1所示,包括了DMS for RocketMQ的所有系统权限。 表1 DMS for RocketMQ系统权限 系统角色/策略名称 描述 类别 依赖关系 DMS FullAccess 分布式消息服务管理员权限,拥有该权限的用户可以操作所有分布式消息服务的功能。 系统策略 无 DMS UserAccess
消费组(Consumer Group) 多个消费者组成同一个消费组,同一消费组内的消费者具有相同的消费属性。 代理(Broker) 一组节点构成的一个业务集群。 NameServer 存储元数据信息的轻量级注册中心。生产者/消费者在生产/消费消息前,需要先从NameServer获取元数据。
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
PLAINTEXT > SSL 存量实例会重启,业务会中断,需要在客户端修改实例接入方式。 新实例不会重启,但是业务会中断,需要在客户端修改实例接入方式。 SSL > PLAINTEXT PLAINTEXT > PERMISSIVE 实例不会重启,业务不会中断。 SSL > PERMISSIVE
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
迁移元数据 RocketMQ元数据迁移概述 迁移其他RocketMQ的元数据到RocketMQ实例 迁移RabbitMQ的元数据到RocketMQ实例
0,获取librocketmq库。 将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。 ln -s /查找到的librocketmq
元数据迁移 新建元数据迁移任务 查询实例下所有迁移任务或查询指定迁移任务信息 删除元数据迁移任务 父主题: API V2(推荐)
账单上报周期 包年/包月计费模式的资源完成支付后,会实时上报两条账单(实例费用账单和存储空间费用账单)到计费系统进行结算。 按需计费模式的资源按照固定周期上报使用量到计费系统进行结算。按需计费模式产品根据使用量类型的不同,分为按小时、按天、按月三种周期进行结算,具体扣费规则可以参考
0,获取librocketmq库。 将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。 ln -s /查找到的librocketmq
当您在使用RocketMQ消息队列时,请尽量避免同时触发大量冷读的场景(比如:批量对消费组消费进度重置或者业务批量上新时从某个历史位点开始消费)。在生产环境中,推荐为实例配备超高I/O及以上的磁盘,避免因为I/O瓶颈导致业务异常。 父主题: 实例问题