基于MQTT Topic通信
SDK中接口提供的基础能力包括：发布、订阅、取消订阅、订阅下行，通过这部分接口可以实现云端数据的上下行。上行接口请求 重要 本文介绍的接口都需要在MQTT长连接通道建立成功的情况下才可以调用。调用上行请求接口，SDK封装了上行发布相关...
公共接口
用户在发布媒体流后，可以在期间取消发布，取消发布后，如果用户想要再次发布流，则需要调用 publish 接口进行重新发布。参数：参数 类型 说明 config UnpublishConfig 需要取消发布的流信息，详情请参见 重要参数。返回值：无。...
回调函数
会话控制，每次通话对应一个会话*用于创建房间，加入房间、发布、订阅等操作，只有加入或者创建房间成功，才会分配合法的 sessionId*对于房间创建者，典型流程是：CreateRoom->Publish->FeedAudio/FeedVideo->LeaveRoom，后续有人加入再做 ...
创建PolarDB-X 1.0数据订阅任务
注意事项 类型 说明 源库限制 待订阅的表需具备主键或唯一约束（仅具有唯一约束的表不支持订阅结构更新，建议使用主键约束），且字段具有唯一性，否则可能会导致订阅到的重复数据 如订阅对象为表级别，则单次订阅任务仅支持至多500张表。...
创建RDS MySQL数据订阅任务
通过数据订阅功能，您可以实时订阅源库的增量数据，轻松帮助业务实现轻量级缓存更新、业务异步解耦、含ETL逻辑的数据实时同步等场景。本文将介绍如何创建 RDS MySQL 数据订阅任务。前提条件 已创建源 RDS MySQL 实例，创建方式，请参见 ...
SubscribeTopic
Topic的操作权限必须为 订阅或 发布和订阅。IotInstanceId String 否 iot-06*实例ID。您可在物联网平台控制台的 实例概览页面，查看当前实例的 ID。注意 若有ID值，必须传入该ID值，否则调用会失败。若无ID值，则无需传入。实例的更多信息...
创建PolarDB-X 2.0数据订阅任务
本文介绍如何创建 PolarDB分布式版 数据订阅任务。前提条件 已创建 PolarDB分布式版 实例和数据库，具体操作请参见 创建实例 和 创建数据库。说明 PolarDB分布式版 中的数据库须基于RDS MySQL创建，DTS暂不支持基于 PolarDB MySQL版 创建的...
使用DTS创建数据订阅
DTS支持创建自建PosgreSQL、RDS PostgreSQL 数据订阅任务。本文以 RDS PostgreSQL 为例介绍配置流程。前提条件 已创建源 RDS PostgreSQL 实例，创建方式，请参见 创建RDS PostgreSQL实例。已设置源 RDS PostgreSQL 实例的参数wal_level=...
创建DMS逻辑库的数据订阅任务
本文介绍如何创建数据管理DMS（Data Management）逻辑库的数据订阅任务。前提条件 已配置数据管理DMS逻辑库，具体操作请参见 逻辑库。说明 数据管理DMS逻辑库需基于多个PolarDB MySQL实例的分库建立。注意事项 类型 说明 源库限制 待订阅的...
创建PolarDB PostgreSQL版数据订阅任务
本文为您介绍如何创建 PolarDB PostgreSQL版 数据订阅任务。前提条件 已创建源 PolarDB PostgreSQL版 数据库集群，创建方式请参见 创建PolarDB PostgreSQL版数据库集群。若源库为经典网络的实例，则不支持通过公网IP方式进行数据订阅。注意...
Topic管理
云消息队列 RocketMQ 版 支持发布和订阅模型，通过Topic完成消息的发布和订阅。消息生产者将消息发送到Topic中，而消息消费者则通过订阅该Topic来消费消息。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查询Topic。...
创建RDS PostgreSQL数据订阅任务
DTS支持创建自建PosgreSQL、RDS PostgreSQL 数据订阅任务。本文以 RDS PostgreSQL 为例介绍配置流程。前提条件 已创建源 RDS PostgreSQL 实例，创建方式，请参见 创建RDS PostgreSQL实例。说明 支持的版本，请参见 订阅方案概览。已设置源 ...
创建PolarDB MySQL版数据订阅任务
通过数据订阅功能，您可以实时订阅增量数据，轻松帮助业务实现轻量级缓存更新、业务异步解耦、含ETL逻辑的数据实时同步等场景。本文介绍如何创建 PolarDB MySQL版 数据订阅任务。前提条件 已创建 PolarDB MySQL版 集群，详情请参见 购买...
回调接口
参数说明：回调参数 类型 说明 code int 正常状态：5001：取消发布/订阅触发关闭流 5002：对端离开房间，被动关闭流 5006：对端取消发布，被动关闭流 5008：退出房间触发关闭流 异常状态：5003：启动流失败（信令阶段）5004：流建立连接...
SubscribeBillToOSS-导出订阅详单
本订阅与费用中心首页的“账单数据存储”为同一功能，订阅互通。订阅至 Bucket 下的目录时，请注意符合目录命名规范：不允许使用表情符，请使用符合要求的 UTF-8 字符。用于分割路径，可快速创建子目录，但不要以/或 \ 开头，不要出现连续...
SDK使用过程中如何减少耗时
通过以下接口设置自动订阅和自动推流：setAutoPublish：设置是否自动发布，是否自动订阅。默认是自动发布和订阅，必须在加入频道之前设置。(int)setAutoPublish:(BOOL)autoPub withAutoSubscribe:(BOOL)autoSub;合理的使用publish和...
创建PolarDB PostgreSQL版（兼容Oracle）数据订阅任务
本文为您介绍如何创建 PolarDB PostgreSQL版（兼容Oracle）数据订阅任务。前提条件 已创建源 PolarDB PostgreSQL版（兼容Oracle）集群，创建方式，请参见 创建PolarDB PostgreSQL版（兼容Oracle）集群。源 PolarDB PostgreSQL版（兼容...
设备数据订阅
背景介绍：该文档适用于多租户和单租户两种模式，发布和订阅已授权给应用的设备端的消息。物联网平台提供HTTPS/2 (Java)设备SDK进行建联，用于建立设备端与物联网平台的通信。参考SDK链接：...
长连接通道SDK
长连接通道SDK，提供IoT业务协议封装的云端数据下行能力，为App提供订阅、发布消息的能力和支持请求响应模型。依赖SDK 概述 日志 基础依赖SDK，提供客户端统一日志打印，日志等级控制，分模块日志隔离等能力 API 通道 提供API通道能力，和...
概述
消息收发模型 消息队列支持发布/订阅模型，消息生产者应用创建 Topic 并将消息发送到 Topic。消费者应用创建对 Topic 的订阅以便从其接收消息。通信可以是一对多（扇出）、多对一（扇入）和多对多。生产者集群 用来表示发送消息应用，一个...
BatchPub
说明 指定Topic的操作权限须为 订阅，或 发布和订阅，且所有设备已订阅该Topic。您可通过以下途径查看自定义Topic：在产品详情页的 Topic类列表 页签下，查看产品下的自定义Topic。在设备详情页的 Topic列表 页签下，查看设备已订阅的...
创建Oracle数据订阅任务
通过数据订阅功能，您可以实时订阅源库的增量数据，轻松帮助业务实现轻量级缓存更新、业务异步解耦、含ETL逻辑的数据实时同步等场景。本文为您介绍如何创建Oracle数据订阅任务。前提条件 自建Oracle数据库的版本为9i、10g、11g版本，暂不...
MQTT协议规范
MQTT是基于TCP/IP协议栈构建的异步通信消息协议，是一种轻量级的发布、订阅信息传输协议。可以在不可靠的网络环境中进行扩展，适用于设备硬件存储空间或网络带宽有限的场景。使用MQTT协议，消息发送者与接收者不受时间和空间的限制。物联网...
什么是Topic
在发布/订阅消息的MQTT协议中，Topic用于定义消息传输的通道和路径，设备通过Topic将消息发布到物联网平台，物联网平台将消息发送给订阅Topic的设备。为方便海量设备基于Topic进行通信，简化授权操作，物联网平台定义了产品Topic类和设备...
账单数据订阅及查询分析
您可在用户中心订阅不同类型的账单数据，例如，计费项明细账单、计费项账单按天汇总等。订阅成功后，账单数据将会定时同步至MaxCompute，您可使用DataWorks的数据分析功能查询并分析账单数据，将分析结果生成可视化图表卡片及报告，同时，...
接口定义
本文介绍创建引擎、初始化引擎、引擎创建/销毁会话、获取引擎版本号和监听引擎事件的相关接口，以及会话相关的接口，包括创建一个房间、加入已有的房间、发布和订阅音视频流等。引擎相关 创建引擎 enum EventType { INIT=0,/引擎类：初始化...
基本概念
Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版 一款由阿里云提供的Apache Kafka全托管服务，具备免部署、免运维、低成本、高弹性、高可靠、高...
基于MQTT Topic通信
提供的基础能力包括：发布、订阅、取消订阅。发布 API原型：device#publish(topic,message,[options],[callback])API原型说明，具体请参见“认证与连接”文档中的 API描述。功能：向指定的topic发送一个消息。参数说明 参数 说明 topic ...
通信消息相关问题
通信Topic订阅 设备订阅Topic列表为空，如何创建和查看订阅的Topic？设备可以订阅其他设备的通信Topic吗？硬件设备和MQTT客户端使用同一设备证书接入物联网平台，订阅同一Topic失败 如何设置和修改通信Topic的操作权限？物联网平台设备只要...
大数据分析
费用说明 订阅及查询分析账单数据会产生如下费用：存储费用（MaxCompute收取）：账单数据会写入指定的MaxCompute表，产生存储费用。详情请参见 计费项与计费方式概述。计算费用（MaxCompute收取）：在数据分析执行SQL语句，会产生计算费用...
集群消费和广播消费
消息队列是基于发布/订阅模型的消息系统。消费者，即消息的订阅方订阅关注的 Topic，以获取并消费消息。由于消费者应用一般是分布式系统，以集群方式部署，因此消息队列约定以下概念：集群：使用相同 Group ID 的消费者属于同一个集群。同...
polar_create_table_with_full_replica_identity
PolarDB PostgreSQL版 的逻辑复制采用“发布-订阅”模式，可以将发布端的操作以类似SQL的形式在订阅端执行，达到数据同步的目的。为了在订阅端标识待更新或删除的数据，发布端需要配置表的复制标识。复制标识支持以下几种类型：主键 唯一...
AliRtcEngine接口
1.16.2 频道相关接口 API 描述 以上版本支持 setAutoPublishSubscribe 设置是否自动发布，是否自动订阅。1.1 joinChannel 加入频道。1.1 leaveChannel 离开频道。1.1 isInCall 检查当前是否在频道中。1.1 setChannelProfile 设置频道模式。...
polar_create_table_with_full_replica_identity
PolarDB PostgreSQL版（兼容Oracle）的逻辑复制采用“发布-订阅”模式，可以将发布端的操作以类似SQL的形式在订阅端执行，达到数据同步的目的。为了在订阅端标识待更新或删除的数据，发布端需要配置表的复制标识。复制标识支持以下几种类型...
实例
每个用户也可以申请其它用户创建的实例，在申请的实例上发布、订阅服务。实例创建、申请和授权的流程如下图所示。实例创建 使用CSB的服务功能前，需要先创建实例。CSB实例包含共享实例和专享实例。共享实例：无需创建和申请，默认可以使用...
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，...
mqtt
更正文档 概述 MQTT（Message Queuing Telemetry Transport，消息队列遥测传输协议），是一种基于发布/订阅（publish/subscribe）模式的“轻量级”通讯协议，该协议构建于 TCP/IP 协议上，由 IBM 在1999年发布。MQTT 最大优点在于，可以以...
AliRtcEngine接口
1.15 频道相关接口 API 描述 以上版本支持 setAutoPublish 设置是否自动发布，是否自动订阅。推荐您使用 setAutoPublishSubscribe 接口代替实现此功能。1.1 joinChannel 加入频道。1.1 leaveChannel 离开频道。1.1 isInCall 检查当前是否在...
AliRtcEngine接口
1.1 频道相关接口 API 描述 以上版本支持 setAutoPublish 设置是否自动发布，是否自动订阅。1.1 joinChannel 加入频道。1.1 leaveChannel 离开频道。1.1 isInCall 检查当前是否在频道中。1.1 setChannelProfile 设置频道模式。1.15 发布...
- 产品推荐
- 这些文档可能帮助您