逻辑订阅
更多详情请参见 逻辑订阅原理与最佳实践。注意事项 您可以在单个实例的两个表之间实现逻辑订阅，也可以在同一VPC内的两个实例间（必须使用内网地址）实现逻辑订阅。前提条件 实例为RDS PostgreSQL 10及以上版本的云盘实例。实例参数 wal_...
混合云解决方案
分发单独放在一台服务器，其目的是解决publisher故障转移时，分发服务器可以提供持续同步数据到订阅服务器。发布（publisher）和分发（distributor）是放在用户本地，拥有自主权限。订阅（subscriber）放在RDS上，建议不要用高可用RDS实例...
通信消息相关问题
本文介绍设备与物联网平台和物联网平台与服务器端的通信相关问题和解决方法。类目 问题 上下行消息 设备重复收到消息，如何去重？设备使用MQTT协议接入物联网平台后，接收不到通信数据，怎么办？物联网平台发送消息比较慢，存在超时情况，...
推送动态配置
目前支持以下两种方式推送动态配置：直接推送：立即将配置发布至所有订阅服务器。建议在验证配置无误后再进行此操作。灰度推送：仅将配置推送到几台服务器进行测试验证，并不保存数据到数据库。操作步骤 登录 SOFAStack 控制台。在左侧导航...
CREATE SUBSCRIPTION
这意味着，当订阅用于同步复制时，将订阅者的 synchronous_commit 设置为 off 可能会增加发布服务器上 COMMIT 的延迟。在这种情况下，将 synchronous_commit 设置为 local 或更高是有利的。connect(boolean)指定 CREATE SUBSCRIPTION 是否...
服务端订阅设备消息
本文为您介绍通过配置AMQP服务端订阅，实现企业服务器通过接入AMQP客户端，接收路灯设备数据的完整流程。背景信息 通过AMQP服务端订阅获取设备消息流程如下图所示。详细说明，请参见 配置AMQP服务端订阅 和 AMQP客户端接入说明。操作步骤 ...
服务端订阅设备消息
本文为您介绍通过配置AMQP服务端订阅，实现企业服务器通过接入AMQP客户端，接收路灯设备数据的完整流程。前提条件 已接入设备和上报数据。具体操作，请参见 设备接入和上报数据。准备开发环境 本文AMQP客户端示例使用Java开发语言，推荐...
订阅数据示例
MQTT Server#mqtt服务器地址 iotx.mqtt.broker=tcp:/XX:31883#mqtt服务器用户名 iotx.mqtt.userName=XXX#只可以订阅，没有发布权限#mqtt服务器密码 iotx.mqtt.password=XXX#mqtt默认心跳时间 iotx.mqtt.keepAliveInterval=60#mqtt默认清除...
配置AMQP服务端订阅
当需要 实时获取 设备上报的数据时，如果使用云端API只能获取物模型数据，而且可能无法实时获取，使用基于AMQP 1.0版协议的 AMQP服务端 订阅功能，可以在业务服务器实时、可靠地获取设备上报消息。本文为您介绍配置 AMQP服务端订阅 的操作...
重要参数
本文介绍的是音视频引擎与会话接口...参数 说明 enableVideo 手动订阅的场景下，是否订阅视频。enableAudio 手动订阅的场景下，是否订阅音频。streamId 房间里面的每个发布者都有唯一的一个流标识，这个标识指明去订阅哪个参与者的音视频流。
重要参数
属性 说明 SUBSCRIBE_START 订阅操作有效，服务器接受该订阅请求，本地准备拉流操作。SUBSCRIBE_SUCCESS 订阅操作成功，成功从服务器拉取媒体流到本地。SUBSCRIBE_FAIL 订阅操作失败，可能是参数错误，也可能是服务器错误。SUBSCRIBE_...
数据转发到消息服务（MNS）
工作原理 云产品流转可将同一产品所有设备或指定设备的指定Topic消息，实时转发到MNS队列已订阅的主题中，您的应用服务器调用消息服务的接口订阅消息。在上图中：数据源：支持的Topic类型消息，请参见 数据格式。SQL表达式：编写SQL表达式...
采集企业内网服务器日志
本文以Nginx为例，介绍配置正向代理服务器以及通过代理模式将企业内网服务器日志采集到日志服务的解决方案。前提条件 已创建Project和Logstore。具体操作，请参见 创建项目Project 和 创建Logstore。已在服务器上安装Linux Logtail 1.5.0及...
基本原理
下面详细介绍 SOFARegistry 的原理。SOFARegistry 组成 SOFARegistry 即服务注册中心。其包含的 4 个组件及其职责为：客户端（Client）：提供应用接入服务注册中心的基本 API 能力，可以是订阅方，也可以是发布方。会话服务器...
冲突
在订阅者的服务器日志中可以找到有关冲突的详细情况。通过更改订阅者上的数据（这样它就不会与到来的数据发生冲突）或者跳过与已有数据冲突的事务可以解决这种冲突。通过调用 pg_replication_origin_advance()函数可以跳过该事务，函数的...
产品架构
数据订阅的工作原理 数据订阅支持实时拉取RDS实例的增量日志，用户可以通过DTS提供的SDK数据订阅服务端来订阅增量日志，同时可以根据业务需求，实现数据定制化消费。DTS服务端的日志拉取模块主要实现从数据源抓取原始数据，通过解析、过滤...
什么是Topic
在发布/订阅消息的MQTT协议中，Topic用于定义消息传输的通道和路径，设备通过Topic将消息发布到物联网平台，物联网平台将消息发送给订阅Topic的设备。为方便海量设备基于Topic进行通信，简化授权操作，物联网平台定义了产品Topic类和设备...
同机房路由收敛
调用流程 说明 以上数据结构为讲解原理进行了简化，并非真实的结构。datacenter：服务器所在的物理机房。zone：物理机房为了方便管理划分出来的逻辑单元，datacenter+zone 共同标识服务器位置信息。调用流程如下：服务提供方 A 和 B 将自己...
什么是RRPC
RRPC原理 具体流程如下：（可选）设备端订阅RRPC相关Topic。物联网平台根据MQTT协议，仅定制了RRPC消息的请求和响应机制。设备端若要获取物联网平台下发的RRPC消息数据，并做应对处理，需要在设备端先订阅Topic，然后开发数据处理逻辑。...
使用SDK示例代码消费订阅数据
完成数据订阅通道的配置后，您可以使用DTS提供的SDK示例代码来订阅数据变更信息，本文介绍该示例代码的使用说明。操作步骤 重要 若数据源是PolarDB-X 1.0或DMS LogicDB，消费订阅数据的操作步骤请参见 使用SDK示例代码消费PolarDB-X 1.0...
使用SDK示例代码消费订阅数据
在完成数据订阅通道的配置（创建好订阅任务和消费组）后，您可以自行编写SDK示例代码或使用DTS提供的SDK示例代码来订阅数据变更信息，本文介绍示例代码的使用方法。操作步骤 重要 如果数据源是PolarDB-X 1.0或DMS LogicDB，消费订阅数据的...
概述
物联网平台支持广播通信，即向指定产品下的全量设备（设备无需订阅广播Topic），或订阅了指定Topic的所有设备发送消息。设备在线，即可收到服务器发送的广播消息。本文介绍通过配置C Link SDK，设备端实现广播通信功能。前提条件 已准备...
订阅者最佳实践
云消息队列 Kafka 版 负载均衡消费的内部原理是，把订阅的Topic的分区，平均分配给各个消费实例。因此，消费实例的个数不要大于分区的数量，否则会有消费实例分配不到任何分区而处于空跑状态。这个负载均衡发生的时间，除了第一次启动上线...
数据转发到AMQP服务端订阅消费组
直接使用AMQP服务端订阅实时获取设备数据，只能从产品维度获取所有设备的数据，使用消息转发的云产品流转功能，可以将全部设备或指定设备发送到物联网平台的消息，先经过SQL表达式处理和过滤，再转发到AMQP服务端订阅消费组，通过AMQP客户...
数据转发到AMQP服务端订阅消费组消费
直接使用AMQP服务端订阅实时获取设备数据，只能从产品维度获取所有设备的数据，使用消息转发的云产品流转功能，可以将全部设备或指定设备发送到物联网平台的消息，先经过解析脚本处理和过滤，再转发到AMQP服务端订阅消费组，通过AMQP客户端...
数据转发到消息服务（MNS）
工作原理 云产品流转可将同一产品所有设备或指定设备的指定Topic消息，实时转发到MNS队列已订阅的主题中。在上图中：数据源：支持的Topic类型消息，请参见 数据格式（非云网关产品和设备）、自定义Topic（MQTT云网关）、消息转发Topic（GB/...
添加待流转的数据源
工作原理 在物联网平台配置云产品流转的数据解析器，实现数据源（设备消息）转发至数据目（另一个Topic、AMQP服务端或其他阿里云产品），实现设备与设备、设备与服务器、设备与阿里云产品的通信。使用限制 数据源支持的Topic类型消息，请...
数据订阅启动SDK报如下的错误“keep alive error”
问题原因 SDK运行的服务器没有公网IP，不能连接数据传输服务的服务器，或者因为订阅通道的消费时间点不在订阅通道的数据范围之内。解决方案 创建公网IP，建立SDK的公网连接，或者重新修改消费位点，具体的修改方法详见 修改订阅通道消费...
什么是服务端订阅
配置服务端订阅后，物联网平台会将产品下所有设备中已订阅类型的消息，转发至您的服务器。使用场景 服务端订阅可应用于以下场景：服务端单纯的接收设备数据的场景，并且适用于高并发场景。服务端接收产品下全部设备的订阅数据。说明 如果您...
跨房间订阅功能
实现原理 为简化客户处理逻辑，跨频道订阅B房间B1主播时，如果B房间不存在或者B1不存在，A1会等待到B1直到App主动取消订阅。示例代码 跨频道订阅音视频流 Android示例代码：/*跨频道订阅B频道的B1的Camera流、音频流*/mAliRtcEngine....
使用Topic通信
定义Topic后，设备可以通过Topic与物联网平台通信，从而实现设备、物联网平台、业务服务器、其他云产品之间的通信。前提条件 使用物模型Topic通信，需要先 添加物模型。使用自定义Topic通信，需要先定义产品Topic类，具体步骤请参见 使用...
典型场景迁移说明
设备采用自定义Topic上报数据，通过AMQP服务端订阅发送给业务服务器。服务端调用 Pub 接口，给设备发送消息。迁移说明 设备端无需改造。采用灰度迁移方式，验证设备信息。灰度迁移过程中会自动迁移产品、并生成新的AMQP服务端订阅者，需要...
管理AMQP消费组
工作原理 AMQP服务端订阅 会将同一产品所有设备的指定类型消息，转发到一个或多个消费组中，每个消费组中随机一个消费者收到消息。不同消费组通过消费组ID区分，每个AMQP客户端只能配置一个消费组ID，每个消费组最多包括64个AMQP客户端。您...
设备数据订阅指引
配置服务端订阅后，物联网平台会将产品下所有设备的已订阅类型的消息转发至您的服务器。使用AMQP服务端订阅消息 AMQP（Advanced Message Queuing Protocol）即高级消息队列协议。您配置AMQP服务端订阅后，物联网平台会将产品下所有已订阅...
服务器端加密
本文介绍服务器端加密的工作原理、支持的地域及相关操作。使用限制 仅支持在创建文件系统时开启数据加密功能。已开启数据加密功能的文件系统不能关闭此功能。加密方式 当您对文件存储有高安全性或者合规性要求时，建议您开启服务器端加密...
应用总览
Top Flow Limit-flowlimit 应用总量、LDC 总量、IDC 总量、服务器 消息发布-msgpub 应用总量、LDC 总量、IDC 总量、Topic Eventcode 总量、服务器、应用实例 消息订阅-msgsub 应用总量、LDC 总量、IDC 总量、Topic Eventcode 总量、服务器...
应用总览
MOSN 调用外部服务-mosnsal 应用总量、IDC 总量、LDC 总量、服务器、下游应用接口方法明细 MOSN 消息订阅-mosnmsgsub 应用总量、LDC 总量、IDC 总量、服务器、Topic Eventcode 总量 MOSN 消息发布-mosnmsgpub 应用总量、LDC 总量、IDC 总量...
添加TCP监听
当您的业务属于注重可靠性、对数据准确性要求高和速度可以相对较慢的场景，例如文件传输、发送或接收邮件和远程登录等，您可以为CLB实例添加一个TCP监听，在CLB实例上转发来自客户端的TCP协议请求至后端服务器进行处理。前提条件 您已经...
添加HTTP监听
健康检查原理，您可参考 CLB健康检查工作原理。配置健康检查参数的详细介绍，您可参考 配置和管理CLB健康检查。负载均衡调度算法介绍，您可参考 负载均衡调度算法介绍。如果您需要为HTTP监听添加域名或URL的转发策略，请参见 基于域名或URL...
添加HTTPS监听
健康检查原理，您可参考 CLB健康检查工作原理。配置健康检查参数的详细介绍，您可参考 配置和管理CLB健康检查。负载均衡调度算法介绍，您可参考 负载均衡调度算法介绍。如果您需要为HTTPS监听添加域名或URL的转发策略，请参见 基于域名或...
- 产品推荐
- 这些文档可能帮助您