订阅消息
本文介绍如何通过 SOFAStack 消息队列的 Java SDK 订阅消息。订阅方式 消息队列支持以下两种订阅方式：集群订阅同一个 Group ID 所标识的所有 Consumer 平均分摊消费消息。例如某个 Topic 有 9 条消息，一个 Group ID 有 3 个 Consumer ...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的Java SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的SDK使用.NET语言进行消息订阅。说明 请确保同一个Group ID下所有Consumer实例的订阅关系保持一致。更多信息，请参见 订阅关系一致。云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同...
订阅消息API
订阅者可通过调用订阅消息API来消费 云消息队列 RocketMQ 版 服务端中的消息。请求构造 请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要 请求行总长度不能超过...
开启消息订阅
DataWorks的OpenEvent通过EventBridge为您提供事件消息订阅与发送服务。在EventBridge中创建自定义总线后，您需要在DataWorks中配置消息事件分发通道，以便在EventBridge中创建规则并完成事件的发布。本文为您介绍如何开启消息订阅服务与...
MQ订阅消息
通过MQ订阅系统消息格式说明。消息定义 消息体 字段 类型 说明 EventCatgory String 事件分类，取值范围："DEVICE"：设备事件"BIZ":业务事件 Event String 事件说明："DEVICE_OFFLINE":设备下线"DEVICE_PROPERTY"：设备属性变更"BIZ_...
Quick BI使用订阅消息时，只有部分人员能收到工作通知
问题描述 Quick BI使用订阅消息时，只有部分人员能收到工作通知。问题原因 无法收到工作通知的几个用户没有在钉钉里点击过微应用。解决方案 无法收到工作通知的几个用户需要在钉钉里点击微应用。访问过微应用以后就可以收到工作通知。适用...
服务端订阅设备消息
本文描述两种配置方法，您可根据实际场景进行选择：订阅设备上报的自定义数据和物模型数据（属性上报、事件上报、属性设置响应和服务调用响应），请参见 配置AMQP服务端订阅消息组。将设备上报的自定义数据或物模型数据进行处理后，再流转...
服务端订阅设备消息
背景信息 通过AMQP服务端订阅获取设备消息流程如下图所示。详细说明，请参见 配置AMQP服务端订阅 和 AMQP客户端接入说明。操作步骤 登录 物联网平台控制台。在 实例概览 页签，单击 公共实例。为消息消费端配置消费组身份，用于企业服务器...
查询订阅房间消息列表
调用ListEventSub查询订阅房间消息列表。QPS限制 本接口的单用户QPS限制为50次/秒。超过限制，API调用会被限流，这可能会影响您的业务，请合理调用。更多信息，请参见 QPS限制。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算...
消息发布与订阅
即一个客户端发布消息，其他多个客户端订阅消息。场景介绍 云数据库Redis版发布的消息是“非持久”的，即消息发布者只负责发送消息，而不管消息是否有接收方，也不会保存之前发送的消息，即发布的消息“即发即失”；消息订阅者也只能得到...
更新订阅房间消息回调
调用UpdateEventSub更新订阅房间消息回调。使用说明 调用本接口前，您必须已经调用 CreateEventSub 创建订阅房间消息回调。已有关联频道，依然使用原规则。频道关闭20分钟以上，再次开启才会适用新规则。如果只想更新某些字段，则其他字段...
删除订阅房间消息回调
调用DeleteEventSub删除订阅房间消息的回调。使用说明 调用本接口前，您必须已经调用 CreateEventSub 创建订阅房间消息的回调。QPS限制 本接口的单用户QPS限制为100次/秒。超过限制，API调用会被限流，这可能会影响您的业务，请合理调用。...
创建订阅房间消息回调
调用CreateEventSub创建订阅房间消息的回调。使用说明 本接口用于创建订阅房间消息的回调。例如：在创建回调时，您可以配置回调地址、事件类型等参数。QPS限制 本接口的单用户QPS限制为100次/秒。超过限制，API调用会被限流，这可能会影响...
Webhook订阅API变更消息
本文介绍如何获取钉钉机器人Webhook地址，便于开发者通过Webhook地址接受订阅消息。前提条件 已创建用于接收订阅消息的钉钉群。操作步骤 请按照如下步骤在钉钉群中添加自定义钉钉机器人并获取Webhook地址。在PC版钉钉上打开您想要添加报警...
服务端订阅设备消息
为家庭温控器产品配置服务端订阅，用于您的服务器直接订阅产品下多种类型的消息。在左侧导航栏，选择。在 服务端订阅 页面的 订阅列表 页签下，单击 创建订阅。在 创建订阅 对话框，设置参数后单击 确认。参数 说明 产品 选择 家庭温控器。...
消息服务MNS的订阅成功后收不到消息
问题描述 消息服务MNS的订阅成功后收不到消息，并且在日志中查不到相关记录。问题原因 可能是由于订阅时配置了 FilterTag 参数。该参数描述了订阅中消息过滤的标签，标签一致的消息才会被推送。解决方案 请参考如下步骤进行排查。检查消息...
最佳实践：订阅实例状态变更消息
开启并配置消息订阅（OpenEvent）开启并配置消息订阅的详细步骤请参见 开启消息订阅，以下为本实践中的核心配置流程与注意事项。在 EvenBridge控制台，跳过事件源等配置，快速创建一个自定义总线。在 EvenBridge控制台 对应的事件总线中，...
教程示例：结合消息服务实现PDS事件通知订阅
您可以通过PDS管理控制台配置事件通知规则，当这些PDS接口中对资源操作发生指定事件时，您可以通过消息服务指定的接收终端，及时收到指定的事件通知。场景描述 某企业在华东1（杭州）地域创建了名为xxxx的域，该企业期望能够对于上传文件...
AMQP服务端订阅可以只推送某个设备的消息吗？
配置AMQP服务端订阅产品的 推送消息类型 后，该产品下所有设备中已订阅类型的消息，都转发至AMQP客户端消费。如果需要转发指定的设备消息到AMQP客户端进行消费，可以使用物联网平台提供的云产品流转功能，先指定设备Topic消息转发至AMQP...
设备数据订阅指引
使用AMQP服务端订阅消息 AMQP（Advanced Message Queuing Protocol）即高级消息队列协议。您配置AMQP服务端订阅后，物联网平台会将产品下所有已订阅类型的消息，通过AMQP通道推送至您的服务器。参考SDK链接：...
使用MNS服务端订阅
订阅消息类型后，该类型下对应的设备Topic消息才能转发到MNS客户端。消息类型对应设备Topic消息，请参见下文 消息类型Topic表。物联网平台提供服务端订阅和云产品流转服务，均可将设备消息转发到消息服务MNS客户端进行消费。对比服务端订阅...
消息推送SLR说明（订阅事件前准备,和删除SLR方法）
确定 此时可回到cvc控制台,可成功开通消息传送 2、产品将在何时替用户创建SLR 当服务关联角色AliyunServiceRoleForAliyunCVC不存在时，具有上面权限的用户在云视频会议控制台开通会议消息推送时，视频会议服务会替用户创建...
服务端订阅
接收服务端订阅消息 本案例使用Java SDK接收服务端订阅消息，详细步骤请参见 Java SDK接入示例。以下Demo中涉及的参数说明，请参见 AMQP客户端接入说明。AMQP服务端订阅*/参数说明，请参见AMQP客户端接入说明文档。String accessKey="*;...
MQ监控
ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布和订阅消息的情况。功能入口 登录 ARMS控制台，在左侧导航栏选择 应用监控>应用列表。在 应用列表 页面顶部选择目标地域，然后单击目标应用名称。说明 语言 列显示 图标的...
本账号RAM用户授权服务端订阅
物联网平台服务端订阅功能支持通过RAM角色授权RAM用户操作，本文档介绍如何通过RAM角色授权RAM用户接收物联网平台配置的服务端订阅消息。背景信息 STS（Security Token Service）是阿里云提供的一种临时访问权限管理服务。RAM提供RAM用户和...
参数说明
云消息队列 RocketMQ 版 提供C/C++ SDK实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点...更多信息 收发普通消息 收发顺序消息 收发定时消息 收发事务消息 订阅消息
参数说明
参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey AccessKey ID，阿里云身份验证标识。...更多信息 收发普通消息 收发顺序消息 收发定时消息 收发事务消息 订阅消息
为什么在控制台看不到Group的订阅关系？
可能原因 客户端的配置错误或者所处的网络环境异常导致无法成功订阅消息。您采用 assign 方式手动指定消费者订阅某个Topic分区的消息，并未提交消费位点。解决方案 排查客户端配置问题，请参见 订阅者最佳实践。排查客户端网络问题，请参见...
Go SDK接入示例
本文介绍使用AMQP协议的Go客户端接入阿里云物联网平台，接收服务端订阅消息的示例。前提条件 已获取消费组ID，并订阅Topic消息。管理消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可通过...
订阅关系一致
云消息队列 RocketMQ 版 支持使用TCP协议和HTTP协议的SDK客户端收发消息，除了保证同一Group ID下的Consumer实例订阅关系一致，还必须保证订阅消息的Group ID的协议版本和SDK的协议版本一致，例如，使用TCP协议的SDK收发消息，订阅消息时也...
OpenEvent概述
DataWorks的OpenEvent旨在将DataWorks的各类状态变更情况以消息的方式触达到用户，便于用户订阅消息并做出个性化的响应。例如，您可以通过OpenEvent订阅表变更，从而实现核心表的实时监控；通过OpenEvent订阅任务变更，实现定制化开发实时...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从...更多信息 消息收发示例代码的更多信息，请参见以下文档：发送普通消息（三种方式）收发顺序消息 收发定时消息 收发延时消息 收发事务消息 订阅消息
订阅者最佳实践
消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 Group 可以包含多个消费实例，即可以启动多个 云消息队列 Kafka 版 Consumer，并把参数 group...
QueryTopicRouteTable
调用该接口查询向指定自定义Topic订阅消息的目标Topic，即指定Topic的路由表。QPS限制 单个阿里云账号调用该接口的每秒请求数（QPS）最大限制为50。说明 RAM用户共享阿里云账号配额。调试 您可以在OpenAPI Explorer中直接运行该接口，免去...
基于MQTT Topic通信
订阅消息 您可以订阅指定Topic的消息，订阅关系将保存在物联网平台。物联网平台收到指定Topic发布的消息后，会将消息转发给设备。更多内容，请参见 MqttSubscribeRequest。订阅成功后，相应的下行消息，会通过 认证与连接 的 连接状态与...
配置AMQP服务端订阅
如果AMQP客户端不在线，AMQP服务端订阅消息会堆积，AMQP客户端重新上线后，物联网平台重新推送消息。如果不需要消费堆积的消息，可在AMQP客户端上线前，清空堆积的消息。所有配置完成，设备上报订阅数据并被AMQP客户端接收后，您可以登录 ...
园区空间数据变更订阅
1、消息订阅 1、获取项目appkey和appSecret 使用阿里云账号登录数字园区引擎，登录后如下图所示 点击对应的园区，则会进入该园区的管理页面，在园区概览菜单下，可以查看园区项目的appKey和appSecret 2、获取实例ID 3、获取数据模型id 在...
- 产品推荐
- 这些文档可能帮助您