nodemcu利用MTTQ连接阿里云

一、固件的选择及产生Bin文件

  1. nodemcu固件生成网站选择自己需要的固件,并且生成bin文件,烧录到ESP8266中
  • 在Select branch里面选择master版本。(稳定版)
  • 在modules里面选择勾选下列:
    crypto----加密模块(hamc加密)
    sntp--获取时间戳模块
    file,gpio,net,node,timer,uart,wifi,mqtt为默认模块
    最后输入你的邮箱,就会把编译好的bin文件发送到你的邮箱,会提供2个版
    本(整形,浮点型)根据实际需求选择

注:这里的邮箱不要选择QQ邮件,不然会收不到邮件,本人使用的是网易邮件可行


固件菜单

二、刷固件

打开刷固件的软件,选择刚才生产的bin文件,选好对应的COM口,直接点击start就可以了(其他配置默认)使用方法在刷固件的软件中有很详细的说明

注:

  1. nodemcu模版的驱动程序为CP2102,所以要在cp2102 usb驱动官网下载安装后使用
  2. 若下载固件后模块不断发送乱码则看本网站,我当时也是糊里糊涂的解决的,看了网上很多解决办法,波特率问题或者开关ESPlorer中的DTR和RTS

三、在阿里云创建产品

这个创建没什么难度就不写出来了,阿里云中的三元组很重要!!!

注:
在阿里云的MTTQ通信中MQTT的Connect报文参数是有规定的,大家可以去阿里云帮助文档查看,在下面的代码编写中会用到

三、代码编写

编译环境esplorer下载

  1. wifi的配置
cfg={}  
cfg.ssid="leon"
cfg.pwd="123456"
----[wifi connect]---------------
wifi.setmode(wifi.STATION)  --设置为STA模式
wifi.sta.config(cfg)        --配置
wifi.sta.connect()          --连接wifi
-----[注册wifi事件]----
wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, function(T)
     print("Connected, IP is "..wifi.sta.getip())
end)

wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, function(T)
     print("wifi disconnect")
end)
  1. 阿里 MQTT 配置
----[阿里3元认证组]------
ProductKey ="a19bI5MaWV6"   --换成自己的
DeviceName ="ESP01"  -- 换成自己的
DeviceSecret="yourselfDeviceSecret"   --换成自己的设备秘钥

RegionId="cn-shanghai"     --华东2,regionid根据你的服务器选择
topic0="/a19bI5MaWV6/ESP01/DATA"   --这就是我们之前定义的一个topic
myMQTTport=1883    --port
myMQTT=nil      --client
myMQTTtimes='6666'     --随便定义即可
  1. 转换成MQTT的host,clientid,username,password
myMQTThost=ProductKey..".iot-as-mqtt."..RegionId..".aliyuncs.com"   --host
myMQTTClientId=ClientId.."|securemode=3,signmethod=hmacsha1,timestamp="..myMQTTtimes.."|" --设备ID 
myMQTTusername=DeviceName.."&"..ProductKey          --username
  1. hmacsha1 加密得到password
hmacdata="clientId"..ClientId.."deviceName"..DeviceName.."productKey"..ProductKey.."timestamp"..myMQTTtimes  --hmac 校验的数据
myMQTTpassword=crypto.toHex(crypto.hmac("sha1",hmacdata,DeviceSecret))    --hmacdata加上设备的秘钥 ,使用hmacsha1 加密得到password
  1. 创建MQTT客户端
myMQTT=mqtt.Client(myMQTTClientId, 120,myMQTTusername,myMQTTpassword)
  1. MQTT客户端发起连接请求
MQTTconnectFlag=0
tmr.alarm(0,1000,1,function()
    if myMQTT~=nil then
        print("Attempting client connect...")
        myMQTT:connect(myMQTThost, myMQTTport,0,MQTTSuccess,MQTTFailed)
    end
end)
  1. 连接成功,连接失败事件
function MQTTSuccess(client)
    print("MQTT connected")
    client:subscribe(topic0,0, function(conn)     --注册topic0
        print("subscribe success") 
    end) 
    myMQTT=client
    MQTTconnectFlag=1
    tmr.stop(0)        --关闭定时连接
end

---[连接失败]---
function MQTTFailed(client,reson)
    print("Fail reson:"..reson)
    MQTTconnectFlag=0
    tmr.start(0)     --重新启动连接
end
  1. 设备发送和接收数据及下线事件
--[注册 设备接收到订阅的topic 事件]-----
myMQTT:on("message", function(client, topic, data) 
    print(topic ..":") 
    if data ~= nil then
        print(data)
    end
end)

--[topic 定时上传数据]
tmr.alarm(1, 5000, 1, function()    --等待连接上
    if MQTTconnectFlag==1 and myMQTT~=nil then   
        myMQTT:publish(topic0,"this is data upload",0,0,function(client)
                        print("send ok" ) 
        end)
    end
end)
--[设备offline 事件]-----
myMQTT:on("offline", function(client) 
    print ("offline") 
    tmr.start(0)
end)
  1. 全部代码
-----[wifi config]-------------
---------------------------
cfg={}  
cfg.ssid="leon"
cfg.pwd="hyl123456"

-----[Aili MQTT 配置]---------
----------------------------
ProductKey ="a19bI5MaWV6"   --换成自己的
ClientId =wifi.sta.getmac()  -- 自定义clientId,这里使用mac地址
DeviceName ="ESP01"  -- 换成自己的
DeviceSecret="a1wLtTqCn6EzZ"
RegionId="cn-shanghai"     --华东2

myMQTTport=1883    --port
myMQTT=nil      --client

myMQTThost=ProductKey..".iot-as-mqtt."..RegionId..".aliyuncs.com"   --host
myMQTTusername=DeviceName.."&"..ProductKey          --username

topic0="/a19bI5MaWV6/ESP01/DATA"   --device 的topic

----[wifi connect]---------------
wifi.setmode(wifi.STATION)  --设置为STA模式
wifi.sta.config(cfg)        --配置
wifi.sta.connect()          --连接wifi

-----[注册wifi事件]----
wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, function(T)
     print("Connected, IP is "..wifi.sta.getip())
end)

wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, function(T)
     print("wifi disconnect")
end)


--------[获取时间戳]--------------------
function GetNetTime()
    sntp.sync({"0.nodemcu.pool.ntp.org","1.nodemcu.pool.ntp.org","2.nodemcu.pool.ntp.org","3.nodemcu.pool.ntp.org","www.beijing-time.org"},
         function(sec, usec, server, info)
                 print('sync', sec, usec, server)       
         end,
         function()
            print("get time error")
         end)  
    return 0
end

--------MQTT------------------
myMQTTtimes='6666'
hmacdata="clientId"..ClientId.."deviceName"..DeviceName.."productKey"..ProductKey.."timestamp"..myMQTTtimes  --hmac 校验的数据
myMQTTpassword=crypto.toHex(crypto.hmac("sha1",hmacdata,DeviceSecret))    --hmacdata加上设备的秘钥 ,使用hmacsha1 加密得到password
myMQTTClientId=ClientId.."|securemode=3,signmethod=hmacsha1,timestamp="..myMQTTtimes.."|"   --设备ID    
----[创建MQTT客户端]
myMQTT=mqtt.Client(myMQTTClientId, 120,myMQTTusername,myMQTTpassword) 

   
----[启动定时连接]
MQTTconnectFlag=0
tmr.alarm(0,1000,1,function()
    if myMQTT~=nil then
        print("Attempting client connect...")
        myMQTT:connect(myMQTThost, myMQTTport,0,MQTTSuccess,MQTTFailed)
    end
end)

---[连接成功]---
function MQTTSuccess(client)
    print("MQTT connected")
    client:subscribe(topic0,0, function(conn)     --注册topic0
        print("subscribe success") 
    end) 
    myMQTT=client
    MQTTconnectFlag=1
    tmr.stop(0)        --关闭定时连接
end

---[连接失败]---
function MQTTFailed(client,reson)
    print("Fail reson:"..reson)
    MQTTconnectFlag=0
    tmr.start(0)     --重新启动连接
end

--[设备offline 事件]-----
myMQTT:on("offline", function(client) 
    print ("offline") 
    tmr.start(0)
end)

--[注册 设备接收到订阅的topic 事件]-----
myMQTT:on("message", function(client, topic, data) 
    print(topic ..":") 
    if data ~= nil then
        print(data)
    end
end)

--[topic 定时上传数据]
tmr.alarm(1, 5000, 1, function()    --等待连接上
    if MQTTconnectFlag==1 and myMQTT~=nil then   
        myMQTT:publish(topic0,"this is data upload",0,0,function(client)
                        print("send ok" ) 
        end)
    end
end)

注:

  1. 上述代码中的tmr模块代码在现在及以后生成的固件中已经发送了改变,请大家在nodemcu官方API中查看最新的方法
  2. 由于阿里云用的是自己的ALink协议,如果大家想提交设备属性就必须为ALink JSON的数据格式。nodemcu如果要提交JSON就要在每个引号前加转义字符\而且还要删掉所有空格。下面是我写的例子
myMQTT:publish(topic1,"{\"id\": \"123\",\"version\": \"1.0\",\"params\": {\"LightSwitch\": {\"value\": 1,}},\"method\": \"thing.event.property.post\"}",0,0,function(client)
        end)

本文本参考自leon@suzhou
本人自写代码就不贴出了,大家可以参考本文章进行开发

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,445评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,889评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,047评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,760评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,745评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,638评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,011评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,669评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,923评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,655评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,740评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,406评论 4 320
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,995评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,961评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,197评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,023评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,483评论 2 342

推荐阅读更多精彩内容