订阅消息
广播订阅同一个 Group ID 所标识的所有 Consumer 都会各自消费某条消息一次。例如某个 Topic 有 9 条消息，一个 Group ID 有 3 个 Consumer 实例，那么在广播消费模式下每个实例都会各自消费 9 条消息。广播订阅方式设置 properties.put...
订阅消息
广播订阅方式设置 factoryInfo.setFactoryProperty(ONSFactoryProperty.MessageModel,ONSFactoryProperty.BROADCASTING);示例代码 using System;using System.Threading;using System.Text;using ons;从Broker拉取消息时要执行的回调函数。...
订阅消息
广播订阅 同一个Group ID所标识的所有Consumer都会各自消费某条消息一次。例如某个Topic有9条消息，一个Group ID有3个Consumer实例，那么在广播消费模式下每个实例都会各自消费9条消息。设置方式如下所示。广播订阅方式设置 factoryInfo....
订阅消息
广播订阅 同一个Group ID所标识的所有Consumer都会各自消费某条消息一次。例如某个Topic有9条消息，一个Group ID有3个Consumer实例，那么在广播消费模式下每个实例都会各自消费9条消息。设置方式如下所示。广播订阅方式设置。properties....
OnsTopicSubDetail-查看Topic的订阅信息
取值说明如下：CLUSTERING：集群订阅 BROADCASTING：广播订阅 消费模式的更多信息，请参见 集群消费和广播消费。CLUSTERING SubString string 订阅表达式。Topic string Topic 名称。test 示例 正常返回示例 JSON 格式 {"RequestId":"87B...
OnsGroupSubDetail-查看Group ID的订阅信息
取值说明如下：CLUSTERING：集群订阅 BROADCASTING：广播订阅 消费模式的更多信息，请参见 集群消费和广播消费。CLUSTERING Online boolean 消费者是否在线。true 示例 正常返回示例 JSON 格式 {"RequestId":"3364E875-013B-442A-BC3C-C1A...
概述
物联网平台支持广播通信，即向指定产品下的全量设备（设备无需订阅广播Topic），或订阅了指定Topic的所有设备发送消息。设备在线，即可收到服务器发送的广播消息。本文介绍通过配置C Link SDK，设备端实现广播通信功能。前提条件 已准备...
调用TCP协议的SDK收发普通消息
广播订阅方式。properties.put(PropertyKeyConst.MessageModel,PropertyValueConst.BROADCASTING);Consumer consumer=ONSFactory.createConsumer(properties);consumer.subscribe("TopicTestMQ","TagA|TagB",new MessageListener(){/订阅多...
广播通信
物联网平台支持广播通信，即向指定产品下的全量设备（设备无需订阅广播Topic），或订阅了指定Topic的所有设备发送消息。设备在线，即可收到服务器发送的广播消息。本文以向全量在线设备广播消息为例，介绍广播通信的具体配置流程。背景信息...
PubBroadcast
赋值，表示指定Topic订阅广播，推送消息到指定 ProductKey 的已订阅广播Topic的在线设备。传入要接收广播消息的Topic全称，格式为：/broadcast/${productKey}/自定义字段。其中，${productKey} 是要接收广播消息的具体产品 ProductKey；...
概述
RRPC能力 广播通信 设备无需订阅广播Topic，即可收到服务器发送的广播消息。广播通信 设备管理 物模型 基于物模型对设备进行管理，无需关心设备与物联网平台之间的数据交互格式，降低开发成本。物模型开发 设备标签 为设备自定义标识，以便...
概述
RRPC 广播通信 设备无需订阅广播Topic，即可收到服务器发送的广播消息。广播通信 设备管理 物模型 基于物模型对设备进行管理，无需关心设备与物联网平台之间的数据交互格式，降低开发成本。物模型 设备标签 为设备自定义标识，以便灵活管理...
广播通信
批量广播 批量广播是系统广播，无需端上进行订阅即可收到。topic格式：/sys/${pk}/${dn}/broadcast/request/。定向广播 定向广播是需要端上进行订阅才能收到广播下行的。topic格式：/broadcast/${pk}/${自定义action}。广播接收 本功能需要...
Link SDK运行相关问题
如果订阅同一个广播Topic的设备数量超过1,000，怎么办？广播Topic最多支持1,000个订阅者。如果设备数量超过1,000，可以对设备进行分组，每组设备数量等于或小于1,000。例如，有5000个设备，需分为5组，调用5次广播接口广播消息。能不能订阅...
使用示例
如果需指定Topic的所有设备接收广播消息，需订阅该Topic。广播通信的Topic格式为：/broadcast/${productKey}/自定义字段。您可根据业务需要，编写回调函数的处理逻辑。示例代码对广播消息仅做打印处理。void demo_mqtt_default_recv_...
Pub
调用该接口通过自定义Topic向设备发布消息，支持向指定产品下订阅了指定自定义Topic的在线设备发送广播消息。使用说明 发送广播消息时：相关Topic是在设备开发时编码定义的，无需控制台创建。一个Topic默认最多可被1,000个设备订阅。若后续...
UpdateTopicConfig
调用该接口可设置自定义Topic的操作权限，及是否支持消息广播、是否开启代理订阅和是否开启压缩或解压缩。使用说明 一个自定义Topic广播消息时，最多可被1,000个设备订阅。若后续需要新增更多设备订阅该自定义Topic的广播消息，可使用MQTT ...
运行日志
fd=6(cost 44763 bytes in total,max used 47675 bytes)[1583135792.888][LK-0313]MQTT connect success in 147 ms AIOT_MQTTEVT_CONNECT 订阅Topic日志：如果要向指定产品下所有设备发送广播消息，设备需订阅该Topic，例如/broadcast/a18...
OnsConsumerStatus-查询Group ID消费状态
取值说明如下：CLUSTERING：集群消费模式 BROADCASTING：广播消费模式 两种订阅模式的详细信息，请参见 集群消费和广播消费。CLUSTERING ConnectionSet object[]该集群当前在线客户端信息。RemoteIP string 宿主机 IP 地址或公网 IP 地址。...
国标协议介绍
本文为您介绍《安全防范视图计算联网系统信息传输、交换、...订阅和通知：宜支持订阅和通知机制，支持事件以及目录订阅和通知。语音广播和语音对讲：宜支持语音广播、语音对讲机制。以上的控制协议在GB/T28181-2016中都有详细的控制过程定义。
什么是消息服务MNS
更多信息，请参见：推送到队列 广播拉取消息模型 一对多广播消息 发布到主题中的一条消息可以被多个订阅者订阅。消息服务MNS 会按照多个订阅指定的队列去推送消息。您仅需发布一次，就可以将消息推送到多个接收端，保证了消息发布的原子性...
使用自定义Topic通信
Pub 通过自定义Topic向指定设备发布消息，支持向指定产品下订阅了指定自定义Topic的在线设备发送广播消息。BatchPub 通过自定义Topic向指定产品下的多个设备批量发送消息。PubBroadcast 向指定产品所有设备，或向订阅了指定Topic的所有设备...
什么是Topic
调用云端API PubBroadcast 向订阅了该Topic的所有设备发送广播消息，实现批量控制设备。物模型通信Topic 属性上报 各物模型功能的Topic。说明 在物联网平台，不可以调用 Pub 接口向物模型通信Topic发送消息。在物联网平台的云端，通过物...
API列表
是 Pub 通过自定义Topic向指定设备发布消息，支持向指定产品下订阅了指定自定义Topic的在线设备发送广播消息。是。BatchPub 通过自定义Topic向指定产品下的多个设备批量发送消息。是。PubBroadcast 向指定产品所有设备，或向订阅了指定...
集群消费和广播消费
适用场景 通知公告：当某个重要公告或通知发布时，系统可以使用广播消费模式，将通知发送给所有订阅了该消息的用户。这样可以确保每个用户都能及时收到通知，并避免遗漏。实时数据同步：在分布式系统中，有时需要将某个数据进行实时同步，...
查询消费者组订阅关系列表
BROADCASTING：广播模式 CLUSTERING：集群模式 CLUSTERING subscriptionStatus string 订阅状态。ONLINE：在线。消费者分组下如果有多个消费者，只要有一个消费者在线则显订阅状态为在线。OFFLINE：离线。消费者分组下如果有多个消费者，...
常见问题
消息队列RocketMQ版订阅的Tag数量有限制吗？消息队列RocketMQ版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？消息队列RocketMQ版的消息体最大是多少？消息在消息队列RocketMQ版中能保存多久？消息的负载均衡...
常见问题
云消息队列 RocketMQ 版订阅的Tag数量有限制吗？云消息队列 RocketMQ 版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？云消息队列 RocketMQ 版的消息体最大是多少？消息在云消息队列 RocketMQ 版中能保存多久？...
集群消费和广播消费
本文介绍 SOFAStack 消息...广播模式下服务端不维护消费进度，所以消息队列控制台不支持消息堆积查询、消息堆积报警和订阅关系查询功能。更多信息 集群消费模式和广播消费模式的具体配置方法，请参见以下文档：TCP 协议 Java SDK：订阅消息
重置消费位点
重置消费位点是指改变订阅者当前的消费位置。当消费者出现故障或者消费错误数据时，您可通过重置消费位点将消费位置回滚到之前的某个位点，重新开始消费。您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。背景信息 云消息队列 ...
通信消息相关问题
PubBroadcast 向指定产品下在线设备发布广播消息。在线设备可指定为所有在线设备或订阅了指定Topic的在线设备。RRpc 向指定设备发送请求消息，并同步返回响应。SetDeviceProperty 设置指定设备的物模型属性值。SetDevicesProperty 设置指定...
消费者负载均衡
广播消费和共享消费 在 云消息队列 RocketMQ 版 领域模型中，同一条消息支持被多个消费者分组订阅，同时，对于每个消费者分组可以初始化多个消费者。您可以根据消费者分组和消费者的不同组合，实现以下两种不同的消费效果：消费组间广播...
管理订阅任务
订阅任务创建完成后，您可以在订阅任务管理页面对订阅任务进行管理。进入订阅管理页面 登录 Quick BI控制台。在顶部菜单栏单击 订阅管理。进入 订阅管理 页面。查询订阅任务 组织成员可查询自己创建的订阅任务，组织管理员可查看并管理所有...
共享订阅
但在有些场景下，用户只希望一个或者几个订阅者可以收到特定消息，共享订阅就适用于这种场景，共享订阅需要订阅者订阅时添加共享订阅标记及订阅组。说明 每个订阅组内只有一个订阅者可以收到消息。在上图中，订阅者C、订阅者D、发布者A都...
订阅管理
订阅内容 订阅信息主要包括：告警订阅名称 成员 修改人 修改时间 操作 订阅信息入口 全部订阅入口 在自定义监控页面，单击所添加的监控产品右侧 操作>订阅告警，并在弹出的页面上添加订阅告警信息后，所配置的告警订阅信息会出现在 全部...
设置NIS事件订阅
网络智能服务 NIS（Network Intelligence Service）集成 云监控，支持设置事件订阅，当资源的系统事件或监控指标达到报警条件时，云监控自动发送原始报警通知给报警联系人，您可以对报警通知进行合并降噪，自定义通知方式等操作。...
修改订阅对象
DTS支持在数据消费的过程中动态增加或减少订阅对象，本文将介绍修改订阅对象的操作流程。注意事项 执行了增加订阅对象操作后，订阅通道会从当前时间拉取该对象的增量数据。执行了移除订阅对象操作后，如果数据订阅的客户端还能订阅到该对象...
订阅告警
本文主要介绍订阅告警的方式以及如何取消订阅。前提条件 已创建告警规则。已创建通知组，并将联系人添加到通知组中。已配置钉钉或短信通知方式。订阅告警入口 订阅自定义监控告警 打开 自定义监控配置 页面，单击右上角 更多>订阅告警 打开...
如何配置通知订阅
本文档主要介绍如何配置通知订阅。新增通知订阅 前提条件：已创建需要订阅的服务或服务关联的流转规则。登录 运维事件中心控制台；左侧导航栏 策略中心>通知订阅 页面配置通知订阅；在 通知订阅 页面点击 新增通知订阅 进入 新增通知订阅 ...
看板订阅
如果填写了结尾，则在图片信息结尾展示结尾内容 发送PDF附件：默认不勾选，勾选后除图片外会另外生成PDF附件 订阅管理 订阅管理路径为：「行为分析」-「首页」-「订阅管理」订阅管理用于管理所有的订阅，在订阅看板配置完成后，点击配置...
- 产品推荐
- 这些文档可能帮助您