阿里物联网平台（一）Windows系统+VS2017 模拟设备端接入

小鱼儿 2021-11-09 08:32 397阅读 0赞

阿里物联网平台（二）.net 实现移动端（WEB、HTML）与设备端通讯

一、阿里物联网平台

平台地址：https://account.aliyun.com

根据文档设置平台端，跟着文档一步步来

文档地址：https://help.aliyun.com/document\_detail/42648.html?spm=a2c4g.11174283.6.642.78b01668rFZaSZ

二、Windows模拟设备端

1.安装vs2017开发工具，配置好Python环境

使用pip来安装linkkit最新版本

pip install aliyun-iot-linkkit  
2.Python实现客户端与平台连接、发送消息、接收消息

参考文档：https://help.aliyun.com/document\_detail/98292.html?spm=a2c4g.11186623.6.617.4ca226831rShZt

\#coding=utf-8  
   
from linkkit import linkkit  
import time  
   
\#阿里云三元组，在平台上创建产品、设备后取得  
lk = linkkit.LinkKit(  
    host\_name="cn-shanghai",  
    product\_key="", \#三元组  
    device\_name="", \#三元组  
    device\_secret="") \#三元组  
   
\#连接成功回调  
def on\_connect(session\_flag, rc, userdata):  
    print("on\_connect:%d,rc:%d,userdata:" % (session\_flag, rc))  
    pass  
   
\#断开连接回调  
def on\_disconnect(rc, userdata):  
    print("on\_disconnect:rc:%d,userdata:" % rc)  
   
lk.on\_connect = on\_connect  
lk.on\_disconnect = on\_disconnect  
   
lk.config\_device\_info("Eth|03ACDEFF0032|Eth|03ACDEFF0031")  
   
lk.connect\_async()  
   
\#订阅云端消息  
def on\_subscribe\_topic(mid, granted\_qos, userdata):  
    print("on\_subscribe\_topic mid:%d, granted\_qos:%s" %  
          (mid, str(','.join('%s' % it for it in granted\_qos))))  
    pass  
   
\#发送消息到云端  
def on\_publish\_topic(mid, userdata):  
    print("on\_publish\_topic mid:%d" % mid)  
   
\#接收与处理来自云端的消息  
def on\_topic\_message(topic, payload, qos, userdata):  
    print("on\_topic\_message:" + topic + " payload:" + str(payload) + " qos:" + str(qos))  
    pass  
   
time.sleep(5)  
   
lk.on\_publish\_topic = on\_publish\_topic  
lk.on\_topic\_message = on\_topic\_message  
lk.on\_subscribe\_topic = on\_subscribe\_topic  
   
\#订阅云端消息,系统消息  
\#rc, mid = lk.subscribe\_topic("/sys/a1hSxOQhke5/smp001/thing/service/property/set")  
   
\#订阅云端消息,自定义消息  
rc, mid = lk.subscribe\_topic(lk.to\_full\_topic("user/get"))  
   
i=1  
   
\#阿里云系统参数上报数据，t1对应云平台属性名称  
payload\_json = \{  
                'id': int(time.time()),  
                'params': \{  
                    't1':  88  
                \},  
                'method': "thing.event.property.post"  
                \}  
   
\#阿里云自定义参数上报数据  
payload\_json2 = \{'params': \{'t1':  123\}\}  
   
while(True):  
   
    print(str(i))  
   
    \#发送消息到云端，系统订阅上报  
    \#rc, mid = lk.publish\_topic("/sys/a1hSxOQhke5/smp001/thing/event/property/post", str(payload\_json))  
      
    \#发送消息到云端，自定义订阅上报  
    \#rc, mid = lk.publish\_topic(lk.to\_full\_topic("user/update"), str(payload\_json2))  
   
    i = i + 1  
      
    time.sleep(15)  
运行，连接成功，订阅成功！

pw的其他原创文章导航  
C\#的MQTT系列  
MQTT（一）C\#使用 MQTTnet 快速实现 MQTT 通信（文末有完整Demo下载）

MQTT（二）在windows64位上安装Python环境

MQTT（三）Python客户端+net客户端+net服务端 简单通信

MQTT（四）树莓派开机自动运行Python客户端

MQTT（五）EMQ开源MQTT消息服务器

C\#的阿里物联网平台  
阿里物联网平台（一）Windows系统+VS2017 模拟设备端接入

阿里物联网平台（二）.net 实现移动端（WEB、HTML）与设备端通讯

落地项目  
落地项目-智慧海绵城市

落地项目-智能焊机，钢塑管行业物联网应用  
\---------------------   
作者：weixin\_pwtank1983   
来源：CSDN   
原文：https://blog.csdn.net/panwen1111/article/details/88365636   
版权声明：本文为博主原创文章，转载请附上博文链接！