只能包含英文、数字、短横线(-)以及下划线(_),且至少包含一个英文或数字。开启自动创建Topic后,标准版实例可以通过发送消息的方式自动创建Topic,并在控制台上显示。常见问题 是否可以自动化创建Topic?可以,但不建议。云消息队列 ...
云消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出,再导入至其他的 云消息队列 RocketMQ 版 实例,实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时,使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...
云消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出,再导入至其他的 云消息队列 RocketMQ 版 实例,实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时,使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...
创建云消息队列 RocketMQ 版的主题(Topic)。主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器,用于标识同一类业务逻辑的消息。在消息收发模型中,生产者将消息发送至主题,消费者通过订阅指定的主题来消费其中的消息。调试 您...
本文介绍如何在 云消息队列 Kafka 版 控制台创建并启动迁移任务。前提条件 下载JDK 8 安装Tsar 为了更准确的获取执行机器的配置,推荐您提前安装Tsar软件。您也可以在运行迁移工具时通过指定-installTsar 参数自动安装Tsar软件,但自动安装...
通过数据传输服务DTS(Data Transmission Service),您可以将自建MySQL同步至 云消息队列 Kafka 版,扩展消息处理能力。前提条件 您已完成以下操作:自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
云消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出,再导入至其他的 云消息队列 RocketMQ 版 实例,实现Group的跨实例迁移。你可以在更换实例或者克隆实例时,使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...
应用场景 企业A购买了 云消息队列 RocketMQ 版 服务来开展业务,并希望将部分业务授权给企业B。具体需求如下:A希望能专注于业务系统,仅作为资源Owner;而消息发布和订阅等任务委托或授权给企业B。企业A希望当企业B的员工加入或离职时,...
部署RabbitMQ RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件,用于在分布式系统中存储转发消息,有良好的易用性、扩展性和高可用性。应用类型 部署方式 说明 部署RabbitMQ 部署RabbitMQ 本教程介绍如何在CentOS 7操作系统的...
背景信息 企业A购买了 云消息队列 RocketMQ 版 服务来开展业务,并希望将部分业务授权给企业B。需求说明:A希望能专注于业务系统,仅作为资源Owner;而消息发布和订阅等任务委托或授权给企业B。企业A希望当企业B的员工加入或离职时,无需做...
本文以单直播间、一名老师、两名学生的场景为例,说明如何使用 云消息队列 MQTT 版 实现直播互动消息、禁言、成员上下线通知以及系统消息通知,其中,老师和学生的客户端以HTML网页为例,后端应用以Java为例。背景信息 在直播互动的场景下...
云消息队列 RabbitMQ 版 的死信Exchange适用于处理被消费者否定应答或重试失败的消息。本文介绍死信Exchange的核心概念、路由流程、配置方式、注意事项和更多信息。核心概念 死信Exchange 用于路由死信消息的Exchange。死信Exchange会根据...
数据源:描述组件绑定的数据源,如从上下文中获取实体对象、从数据库读取实体对象、从逻辑流获取实体对象。形式上是一个对象,通过API执行数据源的加载。事件:如保存当前的实体对象、删除当前的实体对象、跳转页面、触发某个逻辑流。形式...
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时,云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则,5.0系列实例不支持。...
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时,云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则,5.0系列实例不支持。...
Group表示一类Producer或Consumer,这类Producer或Consumer通常生产或消费同一类消息,且消息发布或订阅的逻辑一致。使用 云消息队列 RocketMQ 版 进行消息收发,您需要创建Group ID用于标识同一类生产者实例或者同一类消费者实例。本文...
Queue是指消息队列,云消息队列 RabbitMQ 版 的消息都会被投入到一个或多个Queue中。本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息的存储资源Queue、查看Dashboard大盘、被Exchange绑定、向指定Queue发送消息、查看Consumer Tag、...
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时,云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则,5.0系列实例不支持。...
本文为您介绍 云消息队列 RocketMQ 版 的消息发送重试机制和消息流控机制。背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题:部分节点异常是否影响消息发送?请求重试是否会阻塞业务调用?请求重试...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
在向Headers Exchange发送消息时,设置消息的Headers属性键值对,使用消息Headers属性键值对和绑定属性键值对比较的方式将消息路由至绑定的Queue。InstanceId String 是 amqp-cn-v0h1kb9nu*实例ID。Internal Boolean 是 false 是否为内部...
信任策略是描述RAM角色可信实体的策略,可信实体是指可以扮演RAM角色的实体用户身份。服务关联角色的可信实体为云服务,您可以通过信任策略中的 Service 字段查看。关于如何查看服务关联角色,请参见 查看RAM角色。删除服务关联角色 重要 ...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息,云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品,并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
推荐的做法是使用RAM身份(即RAM用户和RAM角色)来访问 云消息队列 RocketMQ 版。RAM用户 RAM用户需要由阿里云账号(即主账号)或拥有管理员权限的RAM用户、RAM角色来创建,且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的...
推荐的做法是使用RAM身份(即RAM用户和RAM角色)来访问 云消息队列 RocketMQ 版。RAM用户 RAM用户需要由阿里云账号(即主账号)或拥有管理员权限的RAM用户、RAM角色来创建,且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的...
信任策略是描述RAM角色可信实体的策略,可信实体是指可以扮演RAM角色的实体用户身份。服务关联角色的可信实体为云服务,您可以通过信任策略中的 Service 字段查看。关于如何查看服务关联角色,请参见 查看RAM角色。删除服务关联角色 重要 ...
取值说明如下:0:普通消息 1:分区顺序消息 2:全局顺序消息 4:事务消息 5:定时/延时消息 各类型消息的详细说明,请参见 消息类型列表。0 Remark string 否 需创建的 Topic 的描述信息。测试 InstanceId string 是 需创建的 Topic 所...
推荐的做法是使用RAM身份(即RAM用户和RAM角色)来访问 云消息队列 Kafka 版。RAM用户 RAM用户需要由阿里云账号(主账号)或拥有管理员权限的RAM用户、RAM角色来创建,且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的资源。...
顺序消息可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费,常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
如需保证消息生产的顺序性,则必须满足以下条件:同一消息组(MessageGroup)消息生产顺序性的范围为消息组,生产者发送消息时可以为每条消息设置消息组,只有同一消息组内的消息可以保证顺序性,不同消息组或未设置消息组的消息之间不保证...
概念介绍 定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并不期望立马投递这条消息,而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费,该消息即定时消息。延时消息:Producer将消息发送到 云消息队列 ...
消息轨迹是指一条消息从生产者发送到 云消息队列 RabbitMQ 版 服务端,再到消费者消费,整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。如果消息收发不符合预期,您可以通过查询消息轨迹,快速分析和定位问题,及时...
format:pdf 设置消息头属性键值对信息,消息头属性使用一个或多个键值对拼接而成。x-match属性必须配置,其余属性可自定义。x-match属性取值如下:all:默认值,所有消息头的键值对必须匹配。any:至少一对消息头的键值对必须匹配。属性...
对于消费失败且重试后依然失败的消息,云消息队列 RocketMQ 版 不会立丢弃,而是将消息转发至指定的队列中,即死信队列,这些消息即为死信消息。当消费失败的原因排查并解决后,您可以重发这些死信消息,让消费者重新消费;若您暂时无法...
消息持久化 云消息队列 RocketMQ 版 会默认对消息进行持久化,即将接收到的消息存储到 云消息队列 RocketMQ 版 服务端的存储文件中,保证消息的可回溯性和系统故障场景下的可恢复性。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中...
取值如下:成功 失败 消息基础信息 消息类型 普通消息 顺序消息 定时/延时消息 事务消息 消息ID 消息的全局唯一标识,由 云消息队列 RocketMQ 版 系统自动生成。Topic 消息所属的主题名称。消息Keys MessageKey,消息的业务标识,由消息...
消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试:...
在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时,您可通过消息查询功能查看指定消息的详细内容和相关属性,帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点,可采用按位点查询消息;若不确定消息...
当您使用 ChatApp 消息服务 API接口发送消息后,可以通过MNS消息队列消费模式或HTTP批量推送模式来接收消息发送状态的结果和用户回复的消息内容。背景信息 如果出现网络异常、响应超时等情况,可能会导致回执消息推送重复、回执消息获取...