MQ订阅消息
通过MQ订阅系统消息格式说明。消息定义 消息体 字段 类型 说明 EventCatgory String 事件分类，取值范围："DEVICE"：设备事件"BIZ":业务事件 Event String 事件说明："DEVICE_OFFLINE":设备下线"DEVICE_PROPERTY"：设备属性变更"BIZ_...
MQ配置
参数 字段含义 消息topic rocketmq中配置的topic 消息组ID rocketmq中配置的groupid MQ接入点 rocketmq中配置的NAMESRV_ADDR 消息tag 填写个性化tag信息，用于消费端识别来源 订阅消息内容 请查阅 MQ订阅消息 了解从云价签中订阅到的消息...
MQ监控
ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布和订阅消息的情况。功能入口 登录 ARMS控制台，在左侧导航栏选择 应用监控>应用列表。在 应用列表 页面顶部选择目标地域，然后单击目标应用名称。说明 语言 列显示 图标的...
AMQP服务端订阅可以只推送某个设备的消息吗？
配置AMQP服务端订阅产品的 推送消息类型 后，该产品下所有设备中已订阅类型的消息，都转发至AMQP客户端消费。如果需要转发指定的设备消息到AMQP客户端进行消费，可以使用物联网平台提供的云产品流转功能，先指定设备Topic消息转发至AMQP...
调用TCP协议的SDK收发普通消息
要启动消费者并进行消息订阅请继续下一步操作订阅消息。更多消息状态请参见 消息查询 和 查询消息轨迹。调用TCP协议的SDK订阅普通消息 消息发送成功后，需要启动消费者来订阅普通消息。请按需运行对应语言的示例代码来启动消费者，并测试...
权限策略
mq:SUB 消息订阅 控制台实例操作权限 不论您的 云消息队列 MQTT 版 实例是否有独立命名空间，Resource命名格式都统一为acs:mq:*:*:{mqttInstanceId}。涉及的Action及相关说明如下表所示。Action名称 Action说明 备注 mq:MqttInstanceAccess...
权限策略
AliyunMQSubOnlyAccess 云消息队列 MQTT 版 的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK订阅消息的权限。AliyunMQReadOnlyAccess 云消息队列 MQTT 版 的只读权限，被授予该权限的RAM用户仅有通过访问控制台或调用...
Serverless实例计费说明
阶梯单价 Serverless实例的消息收发单价在不同地域有所差异，具体价格如下：公共云地域单价 标准版实例消息收发单价 地域 计费阶梯 月度消息收发累计次数（亿次）普通消息发送（元/百万次）普通消息订阅（元/百万次）高级消息发送（元/百万...
参数说明
参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey AccessKey ID，阿里云身份验证标识。...更多信息 收发普通消息 收发顺序消息 收发定时消息 收发事务消息 订阅消息
参数说明
消息订阅参数 参数名 参数说明 ConsumerId 您在 云消息队列 RocketMQ 版 控制台 上创建的Group ID，更多信息，请参见 基本概念。MessageModel 设置Consumer实例的消费模式，取值说明如下：CLUSTERING（默认值）：表示集群消费。...
主题模型基本概念
订阅者（Subscriber）消息订阅者，从主题接收消息的客户端，主题所有者默认拥有该主题的订阅权限。订阅（Subscription）订阅关系，只有和主题建立订阅关系后，消息订阅者才可以接收发布者发布到该主题的消息。消息过滤标签（FilterTag）...
普通消息
TCP SDK收发普通消息的示例代码 Java 发送普通消息（三种方式）发送消息（多线程）订阅消息 C或C++ 收发普通消息 订阅消息.NET 收发普通消息 订阅消息 HTTP SDK收发普通消息的示例代码 云消息队列 RocketMQ 版 支持RESTful风格的HTTP协议...
查看应用性能详情
消息订阅 页签显示了指标趋势和数据源明细，包括所选应用调用的消息订阅的消息主题（Topic）、请求次数等信息。参数说明可参考下表。参数名 说明 单位 Topic 所选应用调用的消息订阅的消息主题（Topic）。请求次数 所选应用调用消息订阅的...
数据出口
Link WAN支持通过阿里云物联网平台流转数据，也支持用户自建云服务流转数据。数据出口至 物联网平台控制台，...节点分组N:1映射到产品设备列表 节点分组N:1映射到MQ消息队列的Topic 说明 N:1汇聚到消息队列MQ的Topic，数据流转至自建云服务
接口和参数说明
消息订阅接口 消息订阅参数 参数名 参数说明 GROUP_ID 您在消息队列控制台上创建的 Group ID，详情参见 基础术语。MESSAGE_MODEL 设置 Consumer 的消费模式，取值说明如下：CLUSTERING（默认值）：表示集群消费。BROADCASTING：表示广播...
产品概述
平台组件：是指产品对平台提供的服务目录的依赖项，例如：一个办公软件，依赖MQ消息中间件，如果用户希望由ADP平台提供该中间件，则他应该在产品依赖中，声明对该MQ组件的依赖。用户组件：是指用户自身代码构建的业务应用，打包上传至ADP...
消费托管MQ接口
确认消息 消费托管MQ消息成功后，进行确认，方法名称：ackMQMessage。函数原型 AckMQMessageResponse ackMQMessage(final AckMQMessageRequest request)请求参数 参数 必选 说明 streamId 是 队列ID，即数据导出服务中的任务ID。...
开发部署扩展程序：自建服务方式
因此，开发并使用扩展程序前，需先开启消息订阅，获取消息订阅的EventBridge信息、订阅事件的消息体格式，用于后续扩展程序的代码开发。开启消息订阅，详情请参见 开启消息订阅。订阅事件的消息体格式，详情请参见 附录：消息格式。步骤二...
服务关联角色
应用场景 物联网无线连接服务的MQ消息推送功能，需要访问消息队列RocketMQ版云服务的资源，通过服务关联角色功能获取访问权限。关联角色介绍 角色名称：AliyunServiceRoleForLinkcard 权限说明：{"Version":"1","Statement":[{"Effect":...
配置变更
修改或删除消息订阅 在 消息订阅配置 下，单击 修改/删除，在配置窗口中，选择变更类型为 修改 或 删除。勾选需要变更的订阅关系，选定的消息订阅会出现在变更列表中，单击 修改 进行配置调整，或单击 删除，然后单击 保存 完成修改或删除...
参数说明
由于云端SDK订阅消息一般用于云上应用进行消息汇总和分析等场景，因此，云端SDK订阅消息不支持设置子级Topic。设备上下线事件 表 3.设备上下线事件参数 参数 说明 gid 您在 云消息队列 MQTT 版 控制台创建的Group的ID。更多信息，请参见 ...
应用总览
MOSN 消息订阅-mosnmsgsub MOSN 消息订阅时的监控指标。MOSN 消息发布-mosnmsgpub MOSN 消息发布时的监控指标。MOSN Error-mosnerror MOSN 错误信息监控指标。ob proxy 指标-odpstat ob 代理监控指标。ODP 异常-odperror ODP 异常监控指标...
接口和参数说明
由于云端SDK订阅消息一般用于云上应用进行消息汇总和分析等场景，因此，云端SDK订阅消息不支持设置子级Topic。messageListener 消息订阅回调，在回调中处理订阅的消息。设备上下线事件接口 接口名称：subscribeStatus 类名称：...
应用总览
MOSN 消息订阅-mosnmsgsub MOSN 消息订阅时的监控指标。MOSN 消息发布-mosnmsgpub MOSN 消息发布时的监控指标。MOSN Error-mosnerror MOSN 错误信息监控指标。OB Proxy 指标-odpstat OB（OceanBase）代理监控指标。ODP 异常-odperror ODP...
API 概览
本节给出BaaS REST的所需的SDK列表，具体接口信息请参阅相关文档。...针对两种模式，有对应的配套的API，分别介绍如下。...消费托管MQ接口 接口 描述 consumeMQMessage 获取托管MQ中的消息 ackMQMessage 消费托管MQ消息成功后，进行确认
开启消息订阅
DataWorks的OpenEvent通过EventBridge为您提供事件消息订阅与发送服务。在EventBridge中创建自定义总线后，您需要在DataWorks中配置消息事件分发通道，以便在EventBridge中创建规则并完成事件的发布。本文为您介绍如何开启消息订阅服务与...
消息队列
当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 注意：集成阿里云消息队列Rocket MQ服务，需要您先参考安装云服务集成章节完成云服务集成的...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从...更多信息 消息收发示例代码的更多信息，请参见以下文档：发送普通消息（三种方式）收发顺序消息 收发定时消息 收发延时消息 收发事务消息 订阅消息
基于MQTT Topic通信
取消消息订阅 重要 Python Link SDK的1.0.0至1.2.11版本中，设备与物联网平台连接断开后，继续调用以下接口取消消息订阅会抛出异常，需要您做好异常处理。在1.2.12版本后，该API执行失败后，会返回非零错误值，不再抛出异常。通过调用 ...
设备模拟器
具体功能如下：功能项 说明 上行指令调试 设备上报消息到物联网平台，包含：自定义Topic的消息上报和消息订阅 属性上报 事件上报 下行指令调试 物联网平台下发指令到设备，包含：自定义Topic的消息下发 属性调试（含获取、设置）服务调用 ...
消息发布与订阅
即一个客户端发布消息，其他多个客户端订阅消息。场景介绍 云数据库Redis版发布的消息是“非持久”的，即消息发布者只负责发送消息，而不管消息是否有接收方，也不会保存之前发送的消息，即发布的消息“即发即失”；消息订阅者也只能得到...
旧版样例简介
sample-mq-consumer：该工程主要为上述案例中的 MQ 消息提供者（provider）提供一个消费者（consumer）案例，该工程不依赖 GTS，仅为方便用户理解 MQ 案例。sample-txc-edas：在 EDAS 上使用 GTS 的案例，该案例综合了 GTS、EDAS 及 MQ 的...
开放平台概览
开放事件（OpenEvent）DataWorks开放平台的开放事件功能为您提供消息订阅服务，通过订阅DataWorks事件状态，应用系统对接DataWorks，实时获取相关内容的状态变化，帮助您及时响应，满足您的个性化决策需求。关于开放事件功能，具体请参见 ...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的SDK使用.NET语言进行消息订阅。说明 请确保同一个Group ID下所有Consumer实例的订阅关系保持一致。更多信息，请参见 订阅关系一致。云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同...
参数说明
消息订阅参数 参数名 参数说明 consumerGroup Consumer组名，多个Consumer如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一组，即您在阿里云RocketMQ控制台上创建的Group ID，详情请参见 基本概念。...
sample-txc-edas 样例
该样例综合了 GTS、EDAS 及 MQ 的使用，...在 sample-mq-consumer 目录下执行 build.sh 编译该工程，编译完成后在 sample-mq-consumer/client/bin 目录下执行 run.sh 可以消费掉刚刚 sample-txc-edas/txc-client-mq 工程生产出来的 MQ 消息。
API概览
消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。UpdateConsumerGroup 更新消费者分组 更新消费者分组的基础信息和消费重试策略。DeleteConsumerGroup 删除消费者分组 删除指定的消费者分组。ListConsumerGroups 查询消费者...
设备数据订阅
完成身份认证和对接进行设备的消息订阅。Demo示例 a.配置参数/System.getenv("iot.hosting.appKey")方法可以从环境变量中获取appkey和appsecret String appKey=System.getenv("iot.hosting.appKey");String appSecret=System.getenv("iot....
基础版/铂金版实例计费
对于QoS=1且cleanSession=false的消息，服务端如果没有推送成功，则存储为离线消息等待重试，并计算为一次订阅消息。消息TPS计算时，需要根据传输质量乘以对应倍率。具体倍率，请参见 计价倍率。例如，若客户端设置为QoS=2且cleanSession=...
操作链路概述
具体操作步骤如下：创建资源 创建工作空间 创建 Topic 创建 Group ID 获取 AK（AccessKey ID）和 SK（AccessKey Secret）获取接入配置 发送消息 订阅消息 创建资源 注意事项 在使用 SOFAStack 消息队列时，请注意以下网络访问限制：Topic ...
- 产品推荐
- 这些文档可能帮助您