领域模型概述
因此发布订阅模型可以实现一对多通信。传输模型对比 点对点模型和发布订阅模型各有优势，点对点模型更为简单，而发布订阅模型的扩展性更高。云消息队列 RocketMQ 版 使用的传输模型为发布订阅模型，因此也具有发布订阅模型的特点。
限制发布订阅客户端的输出缓冲区大小
通过自定义 client-output-buffer-limit pubsub 的值，您可以调整Redis为发布订阅客户端分配的缓冲区大小。当缓冲数据超过限制时，Redis将断开客户端的连接，防止这些数据占用过多的内存，影响Redis服务的性能。Redis的输出缓冲限制 Redis...
限制发布订阅客户端的输出缓冲区大小
通过自定义 client-output-buffer-limit pubsub 的值，您可以调整 云原生内存数据库Tair 为发布订阅客户端分配的缓冲区大小。当缓冲数据超过限制时，Tair 将断开客户端的连接，防止这些数据占用过多的内存，影响 Tair 服务的性能。Tair 的...
DATASOURCE:ROCKETMQ:Topics
可发布订阅。MessageType Number 消息类型。取值：0：普通消息。1：分区顺序消息。2：全局顺序消息。4：事务消息。5：定时/延时消息。CreateTime string 创建时间。无 IndependentNaming boolean Topic所在实例是否有命名空间。取值：true...
OnsTopicList-获取Topic列表信息
取值说明如下：1：持有者 2：可以发布 4：可以订阅 6：可以发布和订阅 6 CreateTime long 创建时间。1570700947000 Topic string Topic 名称。test Tags object[]Topic 所绑定的标签。Key string 标签键。CartService Value string 标签值...
订阅关系一致
正确订阅关系三：订阅多个Topic且订阅多个Tag 如下图所示，同一Group ID下的三个Consumer实例C1、C2和C3分别都订阅了TopicA和TopicB，且订阅的TopicA都未指定Tag，即订阅TopicA中的所有消息，订阅的TopicB的Tag都是 Tag1 和 Tag2，表示订阅...
MQTT连接相关问题
打开MQTT over TLS，运行时提示MQTT创建失败，返回错误码0x2700 如果关闭MQTT over TLS则可以成功地订阅和发布信息；打开MQTT over TLS时，建连失败。首先确认mbedtls是否做了修改，这是用于传输层和应用层之间加密的功能，不能随意更改。...
数据转发到AMQP服务端订阅消费组
直接使用AMQP服务端订阅实时获取设备数据，只能从产品维度获取所有设备的数据，使用消息转发的云产品流转功能，可以将全部设备或指定设备发送到物联网平台的消息，先经过SQL表达式处理和过滤，再转发到AMQP服务端订阅消费组，通过AMQP客户...
什么是Topic
在发布/订阅消息的MQTT协议中，Topic用于定义消息传输的通道和路径，设备通过Topic将消息发布到物联网平台，物联网平台将消息发送给订阅Topic的设备。为方便海量设备基于Topic进行通信，简化授权操作，物联网平台定义了产品Topic类和设备...
常见问题
1 什么是问答接口、管控接口 公测期间，问答接口特指：实时问答（RecognizeMessage）测试窗（RecognizeMessageForTest）公测期间，管控接口特指：机器人管理相关：机器人创建、更新、删除 行业包管理相关：查询包/版本/场景列表、订阅/取消...
通信消息相关问题
如果需要获取设备数据，可以使用API查询，把数据推送到您自己的服务器，您自行做存储。自定义Topic数据 查询时序数据：QueryDevicesHotStorageData。查询快照数据：QueryDevicesHotStorageDataStatus。物模型数据 设备或IoT孪生节点的所有...
在支持TCP的广域网模组上集成SDK
该example将连接设备到阿里云，订阅一个指定的topic并发送数据给该topic，即设备上报的消息会被物联网平台发送给设备，下面是example的大概过程说明：注意：需要在云端将该topic从默认的权限从”订阅”修改为”发布和订阅”，如下图所示：...
功能发布记录
重构通知订阅能力 新增通知订阅页面，客户可以在列表页根据不同条件对通知组进行查询，也可以创建新的订阅。支持根据核对场景、核对点、核对模板进行订阅，并通知用户邮件、钉钉机器人。支持在订阅页面配置未处理异常定时通知。支持多租户...
将Spring Cloud集群（多应用）平滑迁移到EDAS
什么是平滑迁移 如果您的Spring Cloud应用集群及应用已经部署到生产环境并处于正常运行状态中，此时想将集群迁移到EDAS享受完整的EDAS功能，那么在迁移过程中，保证业务的平稳运行不中断是第一要务，而保证应用平台运行不中断迁移到EDAS即...
云端运行日志
device 设备到云消息：uplink 云到设备消息：downlink API调用：ApiService 服务端订阅：ServiceSubscribe 设备影子：DeviceShadow 规则引擎（云产品流转）：RuleEngine 订阅（订阅Topic）：subscribe 取消订阅（取消订阅Topic）：...
订阅
可以在一对发布者-订阅者之间定义多个订阅，在这种情况下要确保被订阅的发布对象不会重叠。每一个订阅都将通过一个复制槽接收更改。预先存在的表数据的初始数据同步过程可能会要求额外的临时复制槽。逻辑复制订阅可以是同步复制的后备...
主题+HTTP Endpoint使用手册
本文介绍如何使用Python SDK中的sample代码，完成创建主题、创建订阅、启动HTTP Endpoint、发布消息、查看HTTP Endpoint接收消息和删除主题操作。步骤一：准备工作 下载最新版Python SDK，解压后进入 mns_python_sdk 子目录。打开 sample....
客户端连接常见问题
您可以使用 MQTT.fx客户端 验证子级Topic发布和订阅消息。为什么控制台显示的订阅关系数比实际使用的高很多？当 cleanSession 设置为false时，客户端离线后订阅关系也会一直保留，不会被清理。若您不需要保留离线订阅关系，您可以使用 订阅...
消息队列
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 注意：集成阿里云消息队列Rocket MQ服务，需要您先参考安装云服务集成章节完成云服务集成的...
主题模型基本概念
订阅（Subscription）订阅关系，只有和主题建立订阅关系后，消息订阅者才可以接收发布者发布到该主题的消息。消息过滤标签（FilterTag）订阅中消息过滤的标签，标签一致的消息才会被推送。推送地址（Endpoint）消息接收端，订阅者用于接收...
为其他账号授权
授权简介 一个CSB实例就是一个单独的服务开放平台，被授权的账号可以在该实例上发布和订阅服务。创建CSB实例的用户，即该实例的拥有者，可以为其他账号授权，使其能够使用该实例、在该实例上发布和订阅服务。您拥有A、B两个实例。一般是两...
快速入门概述
队列模型 队列模型消息流 队列模型特性 队列模型基本概念 主题模型：支持一对多的发布订阅模式。主题模型 主题模型消息流 主题模型特性 主题模型基本概念 队列模型快速入门 如 队列模型快速入门流程 所示，本教程以直接在控制台发送和接收...
服务
在CSB实例上，不同角色的用户可以对服务进行发布、订阅及相关管理操作。简介 您可以使用CSB将一个已有的后端服务发布为API，以便其它应用订阅和调用。同时，您的服务也可以订阅和调用在CSB中发布的服务。服务的发布、订阅和授权的流程如下...
基本概念
可以向Topic发布或者订阅消息。Topic类 同一产品下不同设备的Topic集合，用${productkey} 和${deviceName} 通配一个唯一的设备，一个Topic类对一个ProductKey下所有设备通用。发布 操作Topic的权限类型，对应的英文名称为Pub。可以往此类...
基本概念
可以向Topic发布或者订阅消息。Topic类 同一产品下不同设备的Topic集合，用${productkey} 和${deviceName} 通配一个唯一的设备，一个Topic类对一个ProductKey下所有设备通用。发布 操作Topic的权限类型，对应的英文名称为Pub。可以往此类...
Android
阿里云RTC的基本功能包含初始化SDK、加入频道、本地发布、订阅远端和离开频道等。通过阅读本文，您可以了解阿里云RTC的基本功能。前提条件 您已下载并集成最新版本的SDK。具体操作，请参见 Android端集成SDK。您已获取加入频道必需的频道...
订阅端获取通信中发布端用户列表
例如：您可以获取订阅端和发布端用户详情信息。QPS 限制 本接口的单用户 QPS 限制为 5 次/秒。超过限制，API 调用会被限流，这可能会影响您的业务，请合理调用。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。...
DescribePubUserListBySubUser
例如：您可以获取订阅端和发布端用户详情信息。QPS限制 本接口的单用户QPS限制为10次/秒。超过限制，API调用会被限流，这可能会影响您的业务，请合理调用。更多信息，请参见 QPS限制。调试 您可以在OpenAPI Explorer中直接运行该接口，免去...
DescribeEndPointMetricData-获取端对端指标数据
例如：您可以获取订阅端和发布端的指标信息。QPS 限制 本接口的单用户 QPS 限制为 10 次/秒。超过限制，API 调用会被限流，这可能会影响您的业务，请合理调用。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行...
DescribeEndPointMetricData
例如：您可以获取订阅端和发布端的指标信息。QPS限制 本接口的单用户QPS限制为20次/秒。超过限制，API调用会被限流，这可能会影响您的业务，请合理调用。更多信息，请参见 QPS限制。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您...
iOS
阿里云RTC的基本功能包含初始化SDK、加入频道、本地发布、订阅远端和离开频道等。通过阅读本文，您可以了解阿里云RTC的基本功能。前提条件 您已下载并集成最新版本的SDK。具体操作，请参见 iOS端集成SDK。您已获取加入频道必需的频道鉴权...
Mac
阿里云RTC的基本功能包含初始化SDK、加入频道、本地发布、订阅远端和离开频道等。通过阅读本文，您可以了解阿里云RTC的基本功能。前提条件 您已下载并集成最新版本的SDK。具体操作，请参见 Mac端集成SDK。您已获取加入频道必需的频道鉴权...
看板订阅
概述 该功能分为看板订阅和订阅管理两个功能模块，看板订阅可以订阅需要关注的看板，并且在订阅看板配置进行发送配置与邮件内容编辑；订阅管理展示所有订阅看板的列表信息，在订阅管理可以对已有的订阅进行编辑与删除操作。功能介绍 订阅...
Windows
阿里云RTC的基本功能包含初始化SDK、加入频道、本地发布、订阅远端和离开频道等。通过阅读本文，您可以了解阿里云RTC的基本功能。前提条件 您已下载并集成最新版本的SDK。具体操作，请参见 Windows端集成SDK。您已获取加入频道必需的频道...
消息发布与订阅
云数据库Redis版也提供了与Redis相同的消息发布（publish）与订阅（subscribe）功能。即一个客户端发布消息，其他...视频介绍 您可以观看以下视频了解Redis发布订阅（Pub/Sub）功能的实现、相关接口、以及应用场景等信息，视频时长约14分钟。
共享订阅
背景信息 MQTT协议基于发布订阅者模式设计，一条消息发布后，所有的订阅者都可以收到。但在有些场景下，用户只希望一个或者几个订阅者可以收到特定消息，共享订阅就适用于这种场景，共享订阅需要订阅者订阅时添加共享订阅标记及订阅组。...
如何在线测试服务
CSB控制台为服务提供在线测试功能，服务的发布者和订阅者都可以在线测试服务。功能限制 只能测试RESTful或者WebService类型的服务。测试服务 登录 CSB控制台。在顶部菜单栏选择地域。在左侧导航栏单击 实例列表。在 实例列表 页面单击具体...
混合云解决方案
需要取得订阅服务器的名称，因为在分发和发布服务器上做别名映射时需要真实的订阅服务器名称。订阅的方式只能是Push（推送），不能是Pull（拉取）。订阅的登录方式不能使用SQL Agent Account，需要使用SQL 登录方式。镜像与复制共存 镜像和...
polar_create_table_with_full_replica_identity
PolarDB PostgreSQL版 的逻辑复制采用“发布-订阅”模式，可以将发布端的操作以类似SQL的形式在订阅端执行，达到数据同步的目的。为了在订阅端标识待更新或删除的数据，发布端需要配置表的复制标识。复制标识支持以下几种类型：主键 唯一...
常见问题
如何单独指定音频或者视频 发布或者订阅参数 PublishParam/SubscribeParam 里面的 enableVideo/enableAudio 可以指定是否发布音频和视频与是否订阅音频和视频。如何开启 P2P 模式 P2P 模式指的是客户端和 Linux 之间的媒体数据不经过服务器...
- 产品推荐
- 这些文档可能帮助您