简介
数据模型是业务数据的抽象模型，它由实体互相关联形成的关系网来表征模型之间的关系。数据模型 通过数据实体建模，用户不用关心...实体 魔笔平台提供多种实体和模块供用户在搭建数据模型时使用，具体说明请参见 实体类型 和 系统数据模块。
收发普通消息（三种方式）
阿里云 云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件 您已...
在Knative上实现Kafka消息推送
适用场景 在线短任务处理 AI音视频消息处理 监控告警 数据格式转换 操作流程 在Knative上实现 云消息队列 Kafka 版 消息推送的操作流程如下图所示。部署Kafka组件 登录 容器服务控制台。在左侧导航栏，单击 集群。在 集群列表 页面，单击要...
迁移上云操作
消息保存时长：最短24小时。最长720小时。定时消息最大延迟时间：默认值：24小时。取值范围：不支持自定义修改。更多参数约束，请参见 配额与限制。SDK版本约束：迁移方案秉承最小变更原则，一般场景下支持客户端SDK版本直接升级，若是大...
发布者最佳实践
这种策略在短时间内看，会将消息发送到同一个分区，如果拉长整个运行时间，消息还是可以均匀地发布到各个分区上的。这样可以避免消息出现分区倾斜，同时还可以降低延迟，提升服务整体性能。如果您使用的 云消息队列 Kafka 版 Producer客户...
消息服务MNS中删除消息时报“message not exist”的...
本文介绍了当MNS删除消息时返回“message not exist”的问题描述、问题原因和解决方案。问题描述 消息服务MNS中删除消息时报如下错误。...如果 VisibilityTimeout 设置得太大，当消息处理失败时，将不能在短时间内再次处理该条消息。
应用场景
相较于以日志为中心的系统，例如Scribe和Flume，云消息队列 Kafka 版 在具备高性能的同时，可以实现更强的数据持久化以及更短的端到端响应时间。云消息队列 Kafka 版 的这种特性决定它适合作为日志收集中心。云消息队列 Kafka 版 忽略掉...
CreateTopic
Name Value API CreateTopic RAM授权操作 mns:CreateTopic 资源 acs:mns:$region:$accountid:/topics/$topicName 使用限制 主题名称是一个不超过255个字符的字符串，必须以字母或数字为首字符，剩余部分可以包含字母、数字和短划线（-）。...
DataGrid自定义逻辑流搜索搭建步骤
DataGrid的搜索的搭建步骤如下所示：创建列表实体。给画布里拖一个列表组件。打开自定义逻辑流搜索。选择数据源为逻辑流。逻辑流的参数为列表的一个实体（这个实体存储的搜索参数）。修改参数后必须重新对逻辑流进行选择。添加搜索的属性。...
消费者分组（ConsumerGroup）
本文介绍 云消息队列 RocketMQ 版 中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
MNS是否支持长轮询？
本文介绍 消息服务MNS 是否支持长轮询的问题。消息服务MNS 支持长轮询。与传统的短轮询相比，长轮询只会在消息进入队列或长轮询超时时才返回响应。一旦消息可用，长轮询可立即以简单经济的方式从您的队列检索消息。详情请参见 长轮询。
消息管理
项目下的“消息管理”，是平台为项目提供的消息通知能力的管理入口，其功能包括“消息规则”的管理和“消息模板”的管理。当然，为了让消息能够触达用户，需要具体的消息服务。目前支持的消息服务包括“短信”和邮件。消息服务 短信“短信...
管理Kafka自定义连接器
更多信息，请参见 快速搭建（ROS）。已购买并部署 云消息队列 Kafka 版 实例。更多信息，请参见 购买并部署实例。环境说明 Kafka Connect版本为3.2.3。Scala版本为2.13。Java版本为java 8。创建流程 创建步骤 云消息队列 Kafka 版 支持创建...
使用限制
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。消息...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
RocketMQ全链路追踪解决方案
链路追踪服务端您可以选择自行搭建，也可以选择阿里云提供的链路追踪服务，云消息队列 RocketMQ 版 支持将Trace数据集成至阿里云 日志服务链路追踪 和 ARMS链路追踪 服务中。SLS Trace全链路解决方案 集成操作：请参见 SLS OpenTelemetry ...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
Topic管理
MQTT协议基于Pub/Sub模型，因此任何消息都属于一个Topic。根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，在使用 云消息队列 MQTT 版 前，需先创建该父级Topic资源。注意事项 Topic不能跨实例使用，例如不能使用实例B的接入点...
Group操作
Group ID必须以“GID_”或者“GID-”开头，长度限制为7~64个字符，只能包含英文、数字、短划线（-）以及下划线（_）。创建Group 登录 云消息队列 MQTT 版 控制台，并在左侧导航栏单击 实例列表。在顶部菜单栏选择目标地域，然后在实例列表...
什么是云消息队列 Confluent 版？
本文介绍 云消息队列 Confluent 版 的定义。什么是Confluent Platform Confluent Platform是一个全面的数据流企业级平台，使您能够以连续、实时的流形式轻松访问、存储和管理数据。Confluent由Apache Kafka的原始创建者构建，通过企业级...
产品优势
本文主要介绍 云消息队列 RabbitMQ 版 相比于自建开源RabbitMQ所具备的优势，以便您更进一步了解 云消息队列 RabbitMQ 版。灵活易用 开箱即用 完全兼容 AMQP 0-9-1 标准协议，完全兼容RabbitMQ开源社区，快速迁移上云。全托管服务 一键开通...
订阅消息API
订阅者可通过调用订阅消息API来消费 云消息队列 RocketMQ 版 服务端中的消息。请求构造 请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要 请求行总长度不能超过...
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
创建并管理业务实体
若您选择创建 普通对象、业务事件、业务流程 实体类型，您还需填写以下配置参数：实体类型 参数 普通对象 继承自实体、关联实体 业务事件 关联实体 业务流程 前序业务流程、关联实体、流程事件 参数说明：继承自实体：即选择当前业务对象的...
公网和VPC接入
如果需要同时在VPC网络和公网接入 云消息队列 Kafka 版，您需要购买并部署公网/VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有...
VPC接入
如果仅需要在VPC网络接入 云消息队列 Kafka 版，您可以购买并部署VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 步骤一：获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有网络...
如何使用Excel导入模块
Excel导入模块是通过指定实体类型，导入Excel文件，能快速获取实体信息，常用于信息导入、信息复用等。模块说明 自定义逻辑操作的 Excel导入 逻辑流操作和入参说明：实体类型：必填，文件信息映射实体。资源路径：必填，为可下载的资源文件...
Subscribe
mns:Subscribe 资源 acs:mns:$region:$accountid:/topics/$topicName/subscriptions/$subscriptionName 使用说明 Subscription名称是一个不超过255个字符的字符串，必须以字母或者数字为首字符，剩余部分可以包含字母、数字和短划线（-）。...
Subscribe
Subscription名称是一个不超过255个字符的字符串，必须以字母或者数字为首字符，剩余部分可以包含字母、数字和短划线（-）。创建Subscription时，需要指定对应的Endpoint，否则不合法。Request 请求消息由以下几部分组成：请求行 PUT/...
Group导入/导出
云消息队列 RocketMQ 版 支持将指定实例的Group列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Group的跨实例迁移。你可以在更换实例或者克隆实例时，使用Group导入/导出功能快速批量创建出相同的Group。背景信息 您可以...
CreateQueue
如果消费端拒绝一个不重新发送的消息，那么消息队列RabbitMQ版将会把消息路由到指定的死信Exchange，该Exchange再将消息路由到绑定的Queue进行存储。DeadLetterRoutingKey String 否 test.dl 死信Routing Key。只能包含字⺟、数字、短划线...
开源对比
本文从稳定性、内核能力、治理能力以及使用习惯等方面，对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
服务关联角色
本文介绍 云消息队列 RabbitMQ 版 服务关联角色的背景信息，权限策略、注意事项和常见问题。背景信息 服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...
Topic管理
例如，您需要创建一个Topic用于收发普通消息，则该Topic的消息类型必须为普通消息类型，不能选择顺序消息、事务消息等，否则会导致消息收发失败。计费说明 云消息队列 RocketMQ 版 会对已创建的每一个Topic收取Topic资源占用费，即使Topic...
CreateQueue
Name Value API CreateQueue RAM授权操作 mns:CreateQueue 资源 acs:mns:$region:$accountid:/queues/$queueName 使用说明 队列名称为不超过120个字符的字符串，必须以字母或数字为首字符，剩余部分可以包含字母、数字和短划线（-）。...
服务关联角色
本文介绍 云消息队列 Kafka 版 服务关联角色的背景信息、策略内容、注意事项和常见问题。背景信息 服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...
自由使用Group
Group名称只能包含字母、数字、短划线（-）以及下划线（_），且至少包含一个字母或数字。自由使用的Group的数量需遵循 云消息队列 Kafka 版 实例的规格限制，否则Group不能被自由使用。具体信息，请参见 使用限制。在 云消息队列 Kafka 版 ...
OnsGroupCreate-创建客户端Group ID
取值说明如下：长度限制为 2~64 个字符，只能包含字母、数字、短划线（-）和下划线（_）。若创建的 Group 所在实例有命名空间，则 Group ID 需要保证实例内唯一，不能和本实例下已有的 Group ID 或 Topic 名称重复；跨实例之间可以重名，...
使用限制
云消息队列 RabbitMQ 版 对集群、接口调用以及字符进行了限制，您在使用 云消息队列 RabbitMQ 版 时注意不要超过相应的限制值，以免程序出现异常。集群限制 限制项 Serverless版 专业版 企业版 铂金版 单实例的Vhost数量 200 单实例的Vhost...
- 产品推荐
- 这些文档可能帮助您