检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
开通华为云和实名认证介绍完成华为云的注册和实名认证。 为账户充值。 如果您的账户有足够金额,请跳到下一个任务。如果您的账户还没有足够金额,请先为账户充值,具体请参考账户充值。 为用户添加RocketMQ实例的操作权限。 您需要有RocketMQ的管理员权限“DMS FullAcc
本文主要介绍在Linux系统的命令行模式下,调用TCP协议连接未开启SSL的RocketMQ实例。 创建实例时或者在实例基本信息中,将“SSL”配置为“PLAINTEXT”或“PERMISSIVE”(通过明文传输),即为未开启SSL。 前提条件 已创建RocketMQ实例,并记录实例详情中的“连接地
包括创建主题、删除主题、查询主题、修改主题、查询主题消费组列表、查询主题的消息数。 消息管理 包括查询消息、查询消息轨迹、导出死信消息、重发死信消息、消费验证。 用户管理 包括创建用户、查询用户、修改用户、删除用户、查询主题的授权用户列表、查询消费组的授权用户列表。 元数据迁移 包括新建元数据迁移任务
本章节介绍分布式消息服务RocketMQ版不同版本支持的实例类型和部署架构,5.x版本相比4.8.0版本的优势,以及不同实例类型、部署架构之前的差异,为您选择适合您业务的实例提供参考。 不同版本支持的实例类型和部署架构 表1 不同版本支持的实例类型和部署架构 实例版本 实例类型 部署架构
Linux系统的命令行模式下,调用TCP协议连接已开启SSL的RocketMQ实例。 创建实例时或者在实例基本信息中,将“SSL”配置为“SSL”或“PERMISSIVE”(通过密文传输),即为已开启SSL。 操作视频 本视频演示使用客户端连接RocketMQ实例的操作。 前提条件
engine_version:消息引擎的版本。 storage_space:消息存储空间,单位MB。具体取值范围,请参考创建实例。 vpc_id:RocketMQ实例所在的VPC(虚拟私有云)的ID。您可以在虚拟私有云控制台查询,也可以通过查询VPC列表API查询。 subnet_id:VPC内子网的网络ID
通过消息触发定时任务的场景,如在某些固定时间点向用户发送提醒消息。 注意事项 定时消息的最大延迟时间为1年,延迟超过1年的消息将会发送失败。 定时消息的定时时间如果被设置成当前时间戳之前的某个时刻,消息将立刻投递给消费者。 在理想情况下,定时消息设定的时间与实际发送时间的误差在0.1s
终端接入的情况下,大量的数据汇聚在一起,实际不同的业务组件需要关注的信息只是其中某些类型的数据,如何在大量数据中快速识别出业务感兴趣的数据将会显得尤为重要。分布式消息服务RocketMQ版提供的消息过滤的能力,可以完好的支持该场景,终端写入时为消息添加标签,指定该消息的类型,业务
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询单个主题成功。 错误码 请参见错误码。 父主题:
接着发送下一条消息。 收发普通消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发普通消息前,需要确保Topic的消息类型为“普通”。 准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。
终端节点(Endpoint)即调用API的请求地址,不同服务不同区域的终端节点不同,您可以从地区和终端节点中查询所有服务的终端节点。 约束与限制 您能创建的实例数上限,具体请参见服务配额。 更详细的限制请参见具体API的说明。 基本概念 账号 用户注册账号时,账号对其所拥有的资源及云服务具有完全的访问权限,可
控告警在内的多种运维手段,业务无需过多关注分布式消息服务RocketMQ版的部署与运维工作,可以专注于自身业务的开发。 低延迟:基于华为云网络部署,在内网访问可达微秒级时延。 弹性高可靠:基于Raft协议实现集群内部节点的管理,及时发现故障节点并进行流量迁移,保证业务的连续性可靠。
顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息: 全局顺序消息:对于指定的一个Topic,将队列数量设置为1,这个队列内所有消息按照严格的先入先出FIFO(First In First Out)的顺序进行发布和订阅。 分
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询成功。 错误码 请参见错误码。 父主题: Topic管理
- - EOM:End of Marketing,停止该版本的销售。 EOS:End of Service & support,停止该版本的服务,建议您在执行作业时选择最新版本的引擎。在该日期之后,不再提供该软件版本的任何技术服务支持。 父主题: 版本公告
Service,CTS)服务,您可以记录与分布式消息服务RocketMQ版相关的操作事件,便于日后的查询、审计和回溯。 前提条件 已开通CTS。 CTS支持的DMS for RocketMQ操作 表1 云审计服务支持的分布式消息服务RocketMQ版操作列表 操作名称 资源类型 事件名称
顺序消息:消费者按照消息发送的顺序来消费消息。 事务消息:提供类似X/Open XA的分布事务功能,通过事务消息能达到分布式事务的最终一致。 支持的高级特性 分布式消息服务RocketMQ版支持4种高级特性。 消息过滤:消费者根据分布式消息服务RocketMQ版设置的标签对已订阅Topic中的消息进行过滤,达到只消费需要的消息的目的。
策略:IAM最新提供的一种细粒度授权的能力,可以精确到具体服务的操作、资源以及请求条件等。基于策略的授权是一种更加灵活的授权方式,能够满足企业对权限最小化的安全管控要求。例如:针对DMS for RocketMQ服务,管理员能够控制IAM用户仅能对实例进行指定的管理操作。多数细粒度
本文介绍了分布式消息服务RocketMQ版各特性版本的功能发布和对应的文档动态,欢迎体验。 2024年3月 序号 功能名称 功能描述 阶段 1 计费系统的RocketMQ规格名称优化 在计费系统中优化RocketMQ实例的规格名称,便于用户使用和理解。优化后的规格名称为:分布式消息服务RocketMQ专享规格。