基于MQTT Topic通信
从云端接收消息 rc,mid=lk.subscribe_topic(topic，qos=1)说明 在 mqtt_sub_pub_on.py 这个demo代码示例中，我们通过 lk.to_full_topic("user/test"）快速生成一个 topic。to_full_topic 是一个Topic自动生成接口，您在前面已经填入了...
消息通信计费
物联网平台收取消息通信费用，按消息数计费。计费项目 具体计费项目请参见下表。具体的收费接口请参见 附录：收费接口。项目 描述 消息传输费用（设备端）设备调用Pub接口发的消息。设备调用RPC接口的Request消息。设备响应服务端RRPC的...
通过RocketMQ客户端消费设备消息
初始化PushConsumer，需要绑定消费者分组ConsumerGroup、通信参数以及订阅关系。PushConsumer pushConsumer=provider.newPushConsumerBuilder().setClientConfiguration(clientConfiguration)/设置消费者分组。setConsumerGroup...
通过RocketMQ客户端消费设备消息
初始化PushConsumer，需要绑定消费者分组ConsumerGroup、通信参数以及订阅关系。PushConsumer pushConsumer=provider.newPushConsumerBuilder().setClientConfiguration(clientConfiguration)/设置消费者分组。setConsumerGroup...
基本概念
Topic Topic是UTF-8字符串，是发布（Pub）/订阅（Sub）消息的传输中介。可以向Topic发布或者订阅消息。Topic类 同一产品下不同设备的Topic集合，用${productkey} 和${deviceName} 通配一个唯一的设备，一个Topic类对一个ProductKey下所有...
使用限制
示例：设备向Topic A发送SUB请求，10秒后，订阅生效，设备开始收到实时消息，除非取消订阅，设备会一直接收Topic A的消息。10秒 广播Topic 要广播的消息主体报文大小不能超过64 KB。需要转换消息原文为二进制数据，并进行Base64编码，从而...
使用示例
本文以C Link SDK中的Demo文件./demos/mqtt_broadcast_demo.c 为例，介绍如何调用Link SDK的API，展示设备的广播通信功能。背景信息 广播消息功能的更多信息，请参见 概述。广播消息 功能基于MQTT接入，开发过程中涉及MQTT接入的代码说明，...
结构体说明
gmt_modified DATE 否 2018-10-10T10:10:00Z 更改时间 operator STRING 否 scott 操作人 sub_app_company STRING 否 sub_app_company1 订阅方应用公司信息 sub_app_desc STRING 否 sub_app_desc1 订阅方应用描述 sub_app_id STRING 否 sub_...
错误码表
请确认当前的channelProfile（频道类型），如果是Communication（通信）模式，无需设置ClientRole（角色类型）。更新角色需要在停止推流的时候。0x01020201 0x01020202 0x01020203 0x01020205 0x01020206 0x01020207 0x01020208 0x01020209...
MQTT接入使用示例
case AIOT_MQTTRECV_PUB:{ printf("pub,qos:%d,topic:%.*s",packet->data.pub.qos,packet->data.pub.topic_len,packet->data.pub.topic);printf("pub,payload:%.*s",packet->data.pub.payload_len,packet->data.pub.payload);TODO:处理...
基本概念
Topic Topic是UTF-8字符串，是发布（Pub）/订阅（Sub）消息的传输中介。可以向Topic发布或者订阅消息。Topic类 同一产品下不同设备的Topic集合，用${productkey} 和${deviceName} 通配一个唯一的设备，一个Topic类对一个ProductKey下所有...
DingRtcEngine
void Destroy(RtcEngine*instance)调用该方法将会释放所有内部使用的资源,当完成音视频通信之后都建议调用该方法释放实例.调用该方法后，你将不能再使用RtcEngine的其他方法和任何回调，如需要再次使用需要重新调用 Create 方法创建一个新...
AliRtcEngine接口
通过阅读本文，您可以了解到Android SDK的AliRtcEngine接口详情。接口说明 查看所有接口详情，请参见 AliRtcEngine。目录 基础接口 API 描述 支持的最低版本 setH5CompatibleMode 设置H5兼容模式。1.1 getH5CompatibleMode 检查当前是否...
使用示例
物联网平台与云网关设备之间通过MQTT协议的Topic实现消息通信，通信Topic符合标准MQTT协议的Topic规范即可，无需以/开头。MQTT协议云网关设备通信的更多内容，请参见 消息通信说明。配置状态监控和消息回调。配置状态监控回调函数。示例...
UpdateTopicConfig
若后续需要新增更多设备订阅该自定义Topic的广播消息，可使用MQTT 5.0版本通信协议进行通信，通过设置自定义Topic支持消息广播和设置自定义Topic消息为保留消息来实现。具体步骤为：1.调用本接口设置指定的自定义Topic（例如：/broadcast/a...
运行日志
广播通信功能的例程运行后，您可以在设备端 和物联网平台 查看日志信息。前提条件 已配置C Link SDK的广播通信功能的例程，详细信息，请参见 使用示例。设备端日志 您可以在设备端查看运行结果。连接日志：出现如下日志，表示设备与物联网...
错误码
配置错误 10111 ERROR_OPTIONS_CHANNELPROFILE_RTC 频道模式不是通信模式。10112 ERROR_OPTIONS_LIVE_CANNOT_PUBLISH 观众角色不能推流。10120 ERROR_OPTIONS_AUDIO_ONLY 纯音频模式推流或订阅其他流。10130 ERROR_OPTIONS_ENABLECAMERA ...
数据类型
枚举名 描述 AliRTCSDK_Communication 通信模式。AliRTCSDK_Interactive_live 互动模式。AliAudioType：音频类型枚举。枚举名 描述 PUB_OBSERVER 经过音频3A处理后的音频数据。SUB_OBSERVER 当前订阅到的远端用户混音后的音频数据。RAW_...
通信消息相关问题
本文介绍设备与物联网平台和物联网平台与服务器端的通信相关问题和解决方法。类目 问题 上下行消息 设备重复收到消息，如何去重？设备使用MQTT协议接入物联网平台后，接收不到通信数据，怎么办？物联网平台发送消息比较慢，存在超时情况，...
业务进程说明
[1644818817.611][LK-0309]sub:/sys/a1*XZe/tunnel_test_001/secure_tunnel/notify[1644818817.611][LK-0309]sub:/sys/a1*XZe/tunnel_test_001/secure_tunnel/proxy/request_reply heartbeat response suback,res:0x0000,packet id:2,max ...
如何发起MQTT亿级连接和千万消息吞吐性能测试
大量设备接入和设备管理对网络带宽、通信协议以及平台服务架构都带来了很大挑战。如何做好以MQTT为代表的物联网协议性能测试显得尤为重要。本文则介绍如何使用阿里云性能测试PTS对MQTT协议进行性能压测。进行MQTT性能测试可以帮助您实现...
AT+MQTT指令接入示例
[LK-0313]MQTT connect success in 1317 ms AIOT_MQTTEVT_CONNECT 订阅Topic[1.755][LK-0309]sub:/gb8*/mqtt_basic_demo/user/get[uart]>>>AT+QMTSUB=0,1,"/gb8*/mqtt_basic_demo/user/get",1[uart][1.788][LK-0000]mqtt sub result:0[uart...
基于 Paho 集成安全 Agent 最佳实践
src/samples/MQTTAsync_publish.c 该文件包含设备与物联网平台连接和通信的逻辑代码。src/samples/aliot_mqtt_sign.c 该文件中的代码用于生成 MQTT 建连参数。应用程序调用该文件中定义的aiotMqttSign()函数，计算出连接参数 username、...
设备接入和上报数据
sub:/a2*/Device1/user/get[1695199326.166][LK-0309]pub:/sys/a2*/Device1/thing/event/property/post[LK-030A]>7B 22 69 64 22 3A 22 31 22 2C 22 76 65 72 73 69|{"id":"1","versi[LK-030A]>6F 6E 22 3A 22 31 2E 30 22 2C 22 70 61 72 ...
基于 Paho 集成安全 Agent 最佳实践
src/samples/MQTTAsync_publish.c 该文件包含设备与物联网平台连接和通信的逻辑代码。src/samples/aliot_mqtt_sign.c 该文件中的代码用于生成 MQTT 建连参数。应用程序调用该文件中定义的aiotMqttSign()函数，计算出连接参数 username、...
CreateProductTopic
Operation String 是 PUB 设备对该Topic类的操作权限，取值：SUB：订阅。PUB：发布。ALL：发布和订阅。ProductKey String 是 aldDEin*要创建Topic类所属产品的 ProductKey。TopicShortName String 是 submit 设置Topic类的自定义类目名称。...
UpdateProductTopic
Operation String 是 PUB 设备对该Topic类的操作权限，取值：SUB：订阅。PUB：发布。ALL：发布和订阅。TopicId String 是 821*要修改的Topic类的ID。调用 CreateProductTopic 接口创建自定义Topic类成功后，返回的 TopicId。TopicShortName...
逻辑订阅
本文简单介绍逻辑订阅的使用流程，示例的流程如下：源实例的数据库src创建发布，发布表public.t1，然后在目的实例的数据库dst创建订阅sub1_from_pub1，订阅源库表public.t1。更多详情请参见 逻辑订阅原理与最佳实践。注意事项 您可以在单个...
什么是Topic
说明 在物联网平台，不可以调用 Pub 接口向物模型通信Topic发送消息。在物联网平台的云端，通过物模型功能远程控制设备，请调用 SetDeviceProperty 或 SetDevicesProperty 设置设备属性值；调用 InvokeThingService 或 InvokeThingsService...
权限策略示例
Effect":"Allow","Action":["mq:PUB","mq:SUB"],"Resource":["acs:mq:*:*:{storeInstanceId}%{topic}"]},{/授予Group的权限"Effect":"Allow","Action":["mq:SUB"],"Resource":["acs:mq:*:*:{mqttInstanceId}%{groupId}"]}]} 适用于无命名...
云消息队列 RocketMQ 版自定义权限策略
Effect":"Allow","Action":["mq:PUB","mq:SUB"],"Resource":["acs:mq:*:*:{instanceId}%{topic}"]},{/授予Group的权限。Effect":"Allow","Action":["mq:SUB"],"Resource":["acs:mq:*:*:{instanceId}%{groupId}"]}]} 适用于无命名空间的...
权限策略示例
Effect":"Allow","Action":["mq:PUB","mq:SUB"],"Resource":["acs:mq:*:*:topic/post-cn-09k1noy*/Topic_*"]},{/授予Group的权限。Effect":"Allow","Action":["mq:SUB"],"Resource":["acs:mq:*:*:groupId/post-cn-09k1noy*/GID_*"]}]} ...
一键建仓
修改同步表 AnalyticDB PostgreSQL版 实例已创建一键建仓任务sub1来同步RDS PostgreSQL实例发布pub1中的表logical_tb1，现在需要同步另一张表logical_tb2到 AnalyticDB PostgreSQL版 实例。在RDS PostgreSQL实例上创建测试表logical_tb2。...
基于 libmosquitto 集成安全 Agent 最佳实践
Built target mosquitto_rr[35%]Built target mosquitto_sub[38%]Built target mosquitto_pub.[100%]Built target mqtt.7 Install the project.#make install 成功之后 libmosquitto 位于/usr/local/lib64 或者/usr/local/lib 下 构建完...
基于 libmosquitto 集成安全 Agent 最佳实践
Built target mosquitto_rr[35%]Built target mosquitto_sub[38%]Built target mosquitto_pub.[100%]Built target mqtt.7 Install the project.#make install 成功之后 libmosquitto 位于/usr/local/lib64 或者/usr/local/lib 下 构建完...
消息通信说明
MQTT云网关设备可通过自定义的消息Topic与物联网平台进行通信，物联网平台会透传设备的上下行通信数据。...下行通信：服务端到设备端 服务端调用 Pub 接口，可向指定的自定义Topic发布消息。设备通过订阅该Topic，接收来自服务端的消息。
中间件监控指标
消息监控 指标名称 说明 单位 数据源 Msg Pub Count 消息推送数量 条 ant cloud agent Msg Pub Avg Cost 消息推送平均耗时 ms ant cloud agent Msg Sub Count 消息订阅数量 条 ant cloud agent Msg Sub Avg Cost 消息订阅平均耗时 ms ant ...
MQTT基于QUIC接入示例
id recvfrom size:934 recvfrom size:34[1677124291.611][LK-0313]MQTT connect success in 816 ms AIOT_MQTTEVT_CONNECT[1677124291.611][LK-0309]sub:/sys/gb8*7yX/devinfo_basic_demo/thing/event/property/post_reply[1677124291.611]...
Android SDK集成
auto pub mAliRtcEngine.publishLocalAudioStream(true);auto sub mAliRtcEngine.setDefaultSubscribeAllRemoteAudioStreams(true);mAliRtcEngine.subscribeAllRemoteAudioStreams(true);mAliRtcEngine.setAudioOnlyMode(true);JSONObject ...
QueryMqttTraceMessageOfClient-查询消息轨迹
取值说明如下 mqtt.trace.action.msg.pub.mqtt：消息动作取值为 pub_mqtt时返回该参数值。mqtt.trace.action.msg.sub：消息动作取值为 sub 时返回该参数值。mqtt.trace.action.msg.push.offline：消息动作取值为 push_offline时返回该参数...
- 产品推荐
- 这些文档可能帮助您