订阅者最佳实践
消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 Group 可以包含多个消费实例，即可以启动多个 云消息队列 Kafka 版 Consumer，并把参数 group...
消息类型
TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息 定时和延时消息 定时消息：Producer 将消息发送到消息队列服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到 ...
订阅关系一致
本文提供订阅关系不一致的示例代码，帮助您顺畅地订阅消息。背景信息 SOFAStack 消息队列里的一个消费者 Group ID 代表一个消费者群组。对于大多数分布式应用来说，一个消费者 Group ID 下通常会挂载多个消费者。由于消息队列的订阅关系...
功能使用相关问题
您可以使用终端SDK发送消息，云端SDK订阅消息。云端SDK适用于云端业务应用集成场景。更多信息，请参见 云端开发概述。云消息队列 MQTT 版 是否支持设置其他告警接收人？监控报警会默认向您的阿里云账号绑定的手机号发送通知，暂不支持修改...
AMQP客户端接收不到实时消息，为什么？
本文介绍通过物联网平台配置的AMQP服务端订阅消息无法接收的常见问题及解决方法。配置AMQP服务端订阅后，为什么在线消费端收不到消息？问题描述 AMQP服务端订阅完成后，消费组对应在线AMQP客户端没有接收到消息。可能原因 当前设备通信的...
旧版订阅迁移至新版订阅
订阅消息的格式 旧版订阅的格式。新版的订阅SDK：DefaultUserRecord。Flink客户端：DataStream API、Table API和SQL。Kafka客户端：Avro。问题排查 无 根据新版SDK的报错排查新版订阅任务问题：问题排查 使用DTS定制工具包排查新版订阅任务...
RAM主子账号授权
仅限有权限的RAM用户在 云消息队列 MQTT 版 的控制台上管理资源，以及通过SDK或API发布与订阅消息。说明 云消息队列 MQTT 版 目前还不支持跨云账号授权。应用场景 企业A购买了 云消息队列 MQTT 版 服务，企业A的员工需要操作这些服务所涉及...
RAM主子账号授权
仅限有权限的RAM用户在 云消息队列 MQTT 版 的控制台上管理资源，以及通过SDK或API发布与订阅消息。说明 云消息队列 MQTT 版 目前还不支持跨云账号授权。应用场景 企业A购买了 云消息队列 MQTT 版 服务，企业A的员工需要操作这些服务所涉及...
RAM主子账号授权
仅限有权限的RAM用户在 云消息队列 RocketMQ 版 的控制台上管理资源，以及通过SDK/API发布与订阅消息。应用场景 企业A购买了 云消息队列 RocketMQ 版 服务，企业A的员工需要操作这些服务所涉及的资源，例如实例、Topic或Group资源，有的...
控制台使用相关问题
订阅关系在订阅消息的SDK代码中设置，控制台只能查询。为什么控制台查询不到离线消息的消费轨迹？若您未设置离线消息功能，客户端离线时服务端不会推送消息，且客户端再次上线后，也接收不到离线期间产生的消息。若需要支持离线消息，请将 ...
数据转发到消息服务（MNS）
当需要对设备数据进行复杂或精细化处理，且单个产品下所有设备或指定设备的消息量小于1,000 QPS时，可以使用云产品流转功能将物联网平台数据转发到消息服务（MNS）中，服务端再从消息服务主题中订阅消息，实现设备端与服务端之间高性能的...
配置AMQP服务端订阅
如果AMQP客户端不在线，AMQP服务端订阅消息会堆积，AMQP客户端重新上线后，物联网平台重新推送消息。如果不需要消费堆积的消息，可在AMQP客户端上线前，清空堆积的消息。所有配置完成，设备上报订阅数据并被AMQP客户端接收后，您可以登录 ...
消息收发计算规格费用
消息收发TPS计算规则 消息收发TPS即为每秒钟消息发送和订阅消息次数的最大总和。实例默认的收发能力比例为1:1，对于写少读多的场景，您可以在 云消息队列 RocketMQ 版 控制台修改收发比例。消息大小以4 KB为最小计量单位，不足4 KB按照4 KB...
配置消息日志
后续步骤 通过 云消息队列 RabbitMQ 版 SDK发送消息，并订阅消息。具体操作，请参见 SDK概述。查询消息。具体操作，请参见 查询消息。您可以登录 日志服务控制台 对日志进行查询与分析。具体操作，请参见 查询和分析日志。查询结果示例如下...
名词解释
MQTT目前对外QoS2消息不支持非 cleanSession，如果客户端以QoS2方式订阅消息，即使设置 cleanSession=false 也不会生效。P2P消息的 cleanSession 判断以接收方客户端的配置为准。消费端QoS和 cleanSession 的不同组合产生的结果如 QoS和...
管理AMQP消费组
在 消费组状态 页签，查看订阅消息的 实时消息消费速率、堆积消息消费速率、消息堆积量、最近消费时间 和在线客户端列表。当消息堆积量大于等于（≥）1时，消息堆积量 右侧会显示 清空 按钮，您可清除堆积消息。说明 消息组创建后：若未...
Queue管理
如何设置Consumer Tag，请参见客户端示例代码 订阅消息。重要 Consumer Tag必须保持唯一，即已被某个Consumer使用的Consumer Tag不可同时被另一个Consumer使用。Consumer Tag在同一个channel内有效，即已在某个channel内被创建的Consumer ...
快速使用MQTT.fx模拟SDK收发消息
支持Windows、Mac和Linux操作系统，可用于验证设备是否可以连接 云消息队列 MQTT 版，并通过Topic发布和订阅消息。本文以Windows系统为例，介绍如何使用MQTT.fx模拟SDK接入 云消息队列 MQTT 版 并进行消息收发。前提条件 下载并安装 MQTT....
MQTT快速入门
下载Demo工程，以查看对应的参数说明，然后您可以运行Demo发送和订阅消息。Demo下载地址，请参见 Demo工程。目前的Demo程序库只覆盖了一部分主流语言，后续会陆续更新。如果没有覆盖对应的开发语言，可以参考Java语言的Demo来修改。Demo...
基本概念
可以向Topic发布或者订阅消息。Topic类 同一产品下不同设备的Topic集合，用${productkey} 和${deviceName} 通配一个唯一的设备，一个Topic类对一个ProductKey下所有设备通用。发布 操作Topic的权限类型，对应的英文名称为Pub。可以往此类...
使用Topic通信
例如Topic：/a19mzPZ*/device1/user/update 归属于设备 device1，只能被设备 device1 用于发布或订阅消息，而不能被设备 device2 用于发布或订阅消息。如果需要，请参见下面的 设备与设备通信。设备端可按需订阅物联网平台预定义的系统...
在Knative上实现Kafka消息推送
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
数据转发到AMQP服务端订阅消费组
后续操作 如果AMQP客户端不在线，AMQP服务端订阅消息会堆积，AMQP客户端重新上线后，物联网平台重新推送消息。如果不需要消费堆积的消息，可在AMQP客户端上线前，清空堆积的消息。所有配置完成，设备上报订阅数据并被AMQP客户端接收后，您...
RAM主子账号授权
应用场景 企业A购买了 云消息队列 RocketMQ 版 服务，企业A的员工需要操作这些服务所涉及的资源，例如实例、Topic或Group资源，有的员工负责创建资源，有的负责发布消息，还有的负责订阅消息。由于每个员工的工作职责不一样，需要的权限也...
消息通知概述
主题模型支持一对多发布和订阅消息，旨在提供一对多的发布订阅以及消息通知功能，支持您实现一站式多种消息通知方式，主题中的一条消息可以同时被多个订阅者订阅，且按照多个订阅指定的推送方式和服务器接入地址进行消息推送，您可以从多个...
如何快速测试云消息队列 Kafka 版服务端是否正常？
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
使用自定义Topic进行通信
设备订阅消息Topic：/a1uzcH0*/${deviceName}/user/cloudmsg，权限为订阅。在 服务端订阅 页签下，单击 创建订阅，设置AMQP服务端订阅，订阅 设备上报消息 到 默认消费组。设备上报消息 包含自定义Topic消息和物模型消息。详细操作和说明，...
作为Input接入
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
使用自定义Topic进行通信
设备订阅消息Topic：/a1uzcH0*/${deviceName}/user/cloudmsg，权限为订阅。在 服务端订阅 页签下，单击 创建订阅，设置AMQP服务端订阅，订阅 设备上报消息 到 默认消费组。设备上报消息 包含自定义Topic消息和物模型消息。详细操作和说明，...
步骤三：调用SDK收发消息
云消息队列 RocketMQ 版 支持 SimpleConsumer 和 PushConsumer 两种消费者类型，您可以选择任意一种方式订阅消息，具体的消费者类型的差异如下：对比项 PushConsumer SimpleConsumer 接口方式 使用监听器回调接口返回消费结果，消费者仅...
Python SDK收发消息
执行以下命令订阅消息（当前示例的Python版本为3.9）。python kafka_consumer.py 消息程序kafka_consumer.py示例代码如下：默认接入点 from confluent_kafka import Consumer,KafkaError import setting conf=setting.kafka_setting c=...
作为Input接入
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
Go SDK接入示例
本文介绍使用AMQP协议的Go客户端接入阿里云物联网平台，接收服务端订阅消息的示例。前提条件 已获取消费组ID，并订阅Topic消息。管理消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可通过...
订阅仪表盘
日志服务支持您订阅仪表盘，即定期将仪表盘渲染为图片，通过邮件、钉钉等方式发送给指定人员。本文介绍如何在日志服务控制台上订阅仪表盘。前提条件 已创建仪表盘。具体操作，请参见 创建仪表盘。...取消订阅后，不再向指定渠道发送订阅消息。
作为Input接入
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
PHP SDK收发消息
订阅消息 执行如下命令订阅消息。php kafka-consumer.php 消息程序 kafka-consumer.php 示例代码如下：说明 示例代码为SSL接入点的代码。如果是默认接入点，无SASL相关代码，即删除如下代码中包含 sasl.和 ssl.相关的代码即可。php $...
功能与特性概述
消息过滤：云消息队列 RocketMQ 版 支持设置消息属性给消息进行分类，云消息队列 RocketMQ 版 服务端会根据您订阅消息时设置的过滤条件对消息进行过滤，您将只消费到需要关注的消息。消息功能 消息查询：云消息队列 RocketMQ 版 提供了三种...
管理AMQP消费组
在 消费组状态 页签，查看订阅消息的 实时消息消费速率、堆积消息消费速率、消息堆积量、最近消费时间 和在线客户端列表。在 消费组状态 页签，单击 报警配置，然后在 创建报警规则 页面，配置云监控阈值报警规则，监控消费组消息堆积数、...
作为Input接入
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
消息通知功能说明
订阅消息的HTTP地址 HTTP地址仅指定域名或IP地址（可设定自定义Web服务端口），实际消息推送至 Web服务的/notifications。取消接收消息的HTTP地址强制为“Web服务的/notifications路径”的限制，支持用户自行设定接收消息的Web服务的路径。...
- 产品推荐
- 这些文档可能帮助您