设备模拟器
详细说明，请参见 使用消息通信Topic。使用限制 属性上报和事件上报支持策略推送功能。多次设置策略推送时，仅保留并执行最后一次的策略推送。连续推送的最小时间间隔为1秒。连续推送时间段最多为3小时。数据格式为 透传或自定义 的设备 不...
订阅关系一致
正确订阅关系三：订阅多个Topic且订阅多个Tag 如下图所示，同一Group ID下的三个Consumer实例C1、C2和C3分别都订阅了TopicA和TopicB，且订阅的TopicA都未指定Tag，即订阅TopicA中的所有消息，订阅的TopicB的Tag都是 Tag1 和 Tag2，表示订阅...
设备数据订阅指引
使用MNS服务端订阅消息 物联网平台将订阅的消息推送到消息服务（MNS）的队列中，您的服务器MNS客户端通过监听MNS队列接收设备消息。MNS服务端订阅消息流转流程如下图所示。详细信息请参考 ...
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
配置AMQP服务端订阅
当需要 实时获取 设备上报的数据时，如果使用云端API只能获取物模型数据，而且可能无法实时获取，使用基于AMQP 1.0版协议的 AMQP服务端 订阅功能，可以在业务服务器实时、可靠地获取设备上报消息。本文为您介绍配置 AMQP服务端订阅 的操作...
领域模型概述
产品定位 云消息队列 RocketMQ 版 是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文 通信方式介绍 和 消息传输模型介绍。云消息队列 RocketMQ 版 产品具备异步...
新增消费组
数据订阅功能支持创建消费组。通过创建多个消费组，您可以对...后续步骤 新增消费组后，根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据（推荐）使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
快速使用MQTT.fx模拟SDK收发消息
AliyunMQSubOnlyAccess 云消息队列 MQTT 版 的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK订阅消息的权限。AliyunMQReadOnlyAccess 云消息队列 MQTT 版 的只读权限，被授予该权限的RAM用户仅有通过访问控制台或调用...
新增消费组
数据订阅功能支持创建消费组。通过创建多个消费组，您可以对...后续步骤 新增消费组后，根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据（推荐）使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
修改订阅对象
DTS支持在数据消费的过程中动态增加或减少订阅对象，本文将介绍修改订阅对象的操作流程。注意事项 执行了增加订阅对象操作后，订阅通道会从当前时间拉取该对象的增量数据。执行了移除订阅对象操作后，如果数据订阅的客户端还能订阅到该对象...
数据转发到AMQP服务端订阅消费组消费
直接使用AMQP服务端订阅实时获取设备数据，只能从产品维度获取所有设备的数据，使用消息转发的云产品流转功能，可以将全部设备或指定设备发送到物联网平台的消息，先经过解析脚本处理和过滤，再转发到AMQP服务端订阅消费组，通过AMQP客户端...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的SDK使用.NET语言进行消息订阅。说明 请确保同一个Group ID下所有Consumer实例的订阅关系保持一致。更多信息，请参见 订阅关系一致。云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同...
中间件产品总览
Spring Boot 自研的开发框架 集成 SOFA 中间件，且中间件可插拔 服务网格 将传统微服务和 Service Mesh 进行融合 对接经典应用服务和容器应用服务 提供丰富的服务治理功能 消息队列 基于 Apache RocketMQ 构建的分布式消息中间件 ...
Subscription
订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略进行重试，重试失败后，会丢弃消息。SubscriptionURL 标识Subscription的URL格式：http://$AccountId.mns.<Region>....
Subscription
订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略进行重试，重试失败后会丢弃消息。SubscriptionURL 标识Subscription的URL格式：http://$AccountId.mns.<Region>.aliyuncs...
基础版/铂金版实例计费
则该场景下，消息订阅关系数为10×2=20个。计费单价 实例类型 订阅关系数上限（个）价格（元/月）基础版实例 1千 50 1万 500 5万 2500 10万 5000 20万 10000 50万 25000 100万 50000 铂金版实例 10万 7000 50万 33000 100万 67000 200万 ...
在线教育视频直播
部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里巴巴集团已超过13年，经过交易核心链路反复打磨与历年双十一高并发场景的...
消息过滤
使用Tag标签过滤消息，订阅所有消息。FilterExpression filterExpression=new FilterExpression("*",FilterExpressionType.TAG);pushConsumer.subscribe(topic,filterExpression);SQL属性过滤 SQL属性过滤是 云消息队列 RocketMQ 版 提供的...
TopicMessage
用户发布消息到主题时，可以指定消息体、消息标签和消息额外属性。...当发布消息时指定了消息标签，MNS将只推送消息给接收这类标签消息的订阅。PublishTime 消息的发布时间，从1970-1-1 00:00:00 000到消息发布时的毫秒值。
【通知】2021年12月1日起新创建的DTS订阅任务的网络...
2021年12月1日起，新创建的DTS订阅任务限制了网络类型，源实例不支持为经典网络的云数据库，或部署在...订阅数据的消费方式，请参见：使用SDK示例代码消费订阅数据（推荐）使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
为什么在控制台看不到消费者的客户端信息？
问题现象 在 云消息队列 Kafka 版 控制台 ...您采用 assign 方式手动指定消费者读取某个Topic分区的消息，订阅关系已经明确，开源Kafka没有统计此信息。只有您采用 subscribe 方式自动分配分区与消费者的订阅关系，客户端的具体信息才会显示。
顺序消息
与顺序消息相关的常见问题如下：顺序消息是否支持集群消费和广播消费？同一条消息是否可以既是顺序消息，同时又支持定时消息和事务消息？顺序消息支持哪些地域（Region）？顺序消息的使用范围是什么？顺序消息支持哪种消息发送方式？顺序...
快速体验CSB
您可以使用云服务总线CSB将一个已有的后端服务发布为API，以便其它服务订阅和调用。同时，您的服务也可以订阅和调用在CSB中发布的服务。体验流程 说明 快速体验服务旨在帮忙您快速体验服务的全流程，所以您无需根据发布者或订阅者的角色...
参数说明
参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey AccessKey ID，阿里云身份验证标识。...更多信息 收发普通消息 收发顺序消息 收发定时消息 收发事务消息 订阅消息
参数说明
消息订阅参数 参数名 参数说明 ConsumerId 您在 云消息队列 RocketMQ 版 控制台 上创建的Group ID，更多信息，请参见 基本概念。MessageModel 设置Consumer实例的消费模式，取值说明如下：CLUSTERING（默认值）：表示集群消费。...
逻辑订阅
本文简单介绍逻辑订阅的使用流程，示例的流程如下：源实例的数据库src创建发布，发布表public.t1，然后在目的实例的数据库dst创建订阅sub1_from_pub1，订阅源库表public.t1。更多详情请参见 逻辑订阅原理与最佳实践。注意事项 您可以在单个...
通信消息相关问题
云产品流转：使用消息转发的云产品流转功能，通过数据流转规则将指定设备数据流转到消息服务（MNS）的主题或消息队列（RocketMQ）的队列中。服务器通过MNS或RocketMQ SDK接收消息。详细内容，请参见 云产品流转概述。已配置MNS服务端订阅，...
主题订阅的使用限制
消息服务MNS 的主题订阅功能使用存在一定的限制，本文介绍 MNS 主题订阅功能的使用限制。地域限制 阿联酋（迪拜）不支持主题。主题个数 主题个数上限为1000，且一个主题下的订阅个数上限为100。推送限制 发送消息时，目前只能指定是某个...
创建PolarDB MySQL版数据订阅通道
通过数据订阅功能，您可以实时订阅增量数据，轻松帮助业务实现轻量级缓存更新、业务异步解耦、含ETL逻辑的数据实时同步等场景。本文介绍如何创建 PolarDB MySQL版 数据订阅通道。前提条件 PolarDB MySQL版 集群已开启Binlog功能，详情请...
消息服务MNS的订阅成功后收不到消息
问题描述 消息服务MNS的订阅成功后收不到消息，并且在日志中查不到相关记录。问题原因 可能是由于订阅时配置了 FilterTag 参数。该参数描述了订阅中消息过滤的标签，标签一致的消息才会被推送。解决方案 请参考如下步骤进行排查。检查消息...
开源MQTT迁移至云消息队列 MQTT 版
云端SDK可用于云端分布式应用部署，天然支持共享订阅，并提供消息收发、消息订阅、客户端上下线事件通知等能力，目前支持Java、Go语言的SDK。更多信息，请参见 云端开发概述。云端SDK支持在 云消息队列 MQTT 版 服务端层面进行订阅发布，而...
配置数据订阅任务
数据订阅功能可以帮助您获取数据库的实时增量数据，您可以根据自身业务需求自由...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费PolarDB-X 1.0订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
订阅服务
服务发布后，订阅者使用消费凭证对发布的服务发起订购，发布者审批后订购生效，才能正常调用服务。前提条件 当订阅者不是服务发布者时，订阅者需要先申请服务所在实例的权限。具体操作，请参见 申请实例。订阅服务流程 在快速体验订阅服务...
创建DMS逻辑库的数据订阅任务
本文介绍如何创建数据管理DMS（Data Management）逻辑库的数据订阅任务。...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费PolarDB-X 1.0订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建RDS MySQL数据订阅通道
通过数据订阅功能，您可以实时订阅源库的增量数据，轻松帮助业务实现轻量级缓存更新、业务异步解耦、含ETL逻辑的数据实时同步等场景。本文将介绍如何创建RDS MySQL数据订阅通道。注意事项 由于使用gh-ost或pt-online-schema-change等类似...
P2P消息收发模式（MQTT）
除了标准MQTT协议所支持的发布/订阅（Pub/Sub）消息收发模式外，云消息队列 MQTT 版 还支持点对点（Point to Point，简称P2P）模式。本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P，...
P2P消息收发模式（MQTT）
除了标准MQTT协议所支持的发布/订阅（Pub/Sub）消息收发模式外，云消息队列 MQTT 版 还支持点对点（Point to Point，简称P2P）模式。本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P，...
创建PolarDB-X 1.0数据订阅任务
本文介绍如何创建 PolarDB-X 1.0 数据订阅任务。前提条件 已创建 PolarDB-X 1.0...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费PolarDB-X 1.0订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建PolarDB PostgreSQL版数据订阅任务
本文为您介绍如何创建 PolarDB PostgreSQL版 数据订阅任务。前提条件 已创建源 PolarDB ...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
使用DTS创建数据订阅
DTS支持创建自建PosgreSQL、RDS PostgreSQL 数据订阅任务。本文以 RDS PostgreSQL 为例介绍...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
- 产品推荐
- 这些文档可能帮助您