ESP8266（nodeMUC）+ 华为IoT设备接入

发表于 2023-03-22 更新于 2024-06-26 分类于物联网本文字数： 1.7k 阅读时长 ≈ 6 分钟

ESP8266是一款高度集成的WiFi芯片，可以作为微控制器的一部分来控制其他设备。它可以通过串口连接到计算机，并通过编程实现控制。NodeMCU是一种基于ESP8266的开发板，使得使用ESP8266更加简单。使用NodeMCU，可以通过Lua编程语言来控制ESP8266。这种芯片和开发板非常适合物联网设备和远程控制应用程序。

最近我想买一个来玩一下物联网的乐趣，然后买来一个最便宜最广泛的一个开发板，就是ESP8266，具有Wifi功能，然后想用MQTT协议连接华为云IOT代理，但是搜索了整个网络，都没有好的教程，要么就是刷的固件都是很老的，要么是AT固件，然后没有MQTT模块。今天我来记录我的一次教程。

1. 准备材料

在淘宝上购买来ESP8266,大约12元钱左右

接下来就是开始进行操作，先进去官网，官网是最好的教程说的没错

NodeMCU Documentation

下载刷固件的工具

NodeMCU PyFlasher

Untitled

下载固件

NodeMCU custom builds

在云上自定义自己固件模块，进去有几个默认模块

然后勾选来Mqtt 和 sjson，crypto模块，填写自己的邮箱，然后点击开始build，过几分钟就会收到固件邮件

收到邮件通过邮件提供的链接下载固件

下载开发工具ESPlorer 进入4refr0nt/ESPlorer: Integrated Development Environment (IDE) for ESP8266 developers 下载ESPlorer工具

2. 开始烧录固件

打开 nodeMCU pyflasher,

通过USB链接自己的开发板，选择CoM3，选择固件，点击烧录

出现‘Firmware successfully flashed. Unplug/replug or reset device
to switch back to normal boot mode.‘ 则烧录成功

3. 开始开发MQTT

打开Esplorer开发工具，连上串口出现下图则成功连接上。然后开始编写代码。连上wifi 建立连接

代码中显示ssid是wifi名字，注意:有些wifi有5G之类的，请使用普通的，因为这个板子不太支持那么高级的wifi协议

新建文件init.lua

代码如下：

-- init.lua
print('Setting up WIFI...')
wifi.setmode(wifi.STATION)
cfg={}
cfg.ssid="TP-LINK_38B1" 
cfg.pwd=""
wifi.sta.config(cfg)
wifi.sta.connect()
mytime = tmr.create()
mytime:alarm(1000, tmr.ALARM_AUTO, function()
    if wifi.sta.getip() == nil then
        print('Waiting for IP ...')
    else
        print('IP is ' .. wifi.sta.getip())
    mytime:stop()
    end
end)

然后开始上传代码。在ESplorer中左下角有个upload…按钮上传之后按一下开发板的rest键则出现开始连接wifi了

4.华为云设备接入 IoTDA

打开华为云网站进入设备接入IotDA，点击免费试用，试用免费产品

新建产品模型，例如我这边产品名称填esp8266、设备类型选择自定义，填来一个W

模型定义，新增服务，服务id自己取，英文+数字，例如我这边就取名字peng，服务类型和服务ID一致即可

Untitled

新增下发命令，这边我们开发板很简单没有触发的事件这边我就模拟一个下发命令点亮了他自身带的灯，新增参数参数为ON和OFF

Untitled

新建设备，点击设备—所有设备—注册设备，弹出解码，所属资源空间就是之前上面注册的产品空间，空间下的产品填入所属产品，设备标识码，自己随便命名，成功之后会有一个密钥下载，这块记得保存

Untitled

5. 编写esp8266客户端MQTT代码

如下编写代码，把一下代码放入之前init.lua后面主要的一些参数需要从刚才的配置的华为云端拿

HOST、PORT、USERNAME、PASSWORD还有public地址和subscribe地址

m=nil
config={}
config.HOST = "15c3bcdf8c.st1.iotda-device.cn-north-4.myhuaweicloud.com"
config.PORT = 1883
config.USERNAME = "641474d140773741f9fb9dab_wifi1234"
config.PASSWORD = "123"
config.ID = node.chipid()
config.ENDPOINT = "$oc/devices/641474d140773741f9fb9dab_wifi1234/sys/bootstrap/down"

-- Sends a simple ping to the broker
local function send_ping()
    m:publish("$oc/devices/641474d140773741f9fb9dab_wifi1234/sys/bootstrap/up",gpio.read(1)..gpio.read(2)..gpio.read(3)..gpio.read(4),0,1)
    print("Published the status")
end

local function get_request(topic)
	local t = string.find(topic, "=")
	return string.sub(topic,t+1,-1)
end

--响应消息命令
local function send_suf()
	msg = {}
	msg.object_device_id = "641474d140773741f9fb9dab_wifi1234"
	msg.name="open_light"
	msg.id="12345"
	msg.content ={}
	msg.content.result = true
	print(sjson.encode(msg))
	m:publish("$oc/devices/641474d140773741f9fb9dab_wifi1234/sys/messages/up",sjson.encode(msg),0,1)
	print("Published the responce")
end
-- 响应命令
local function send_command(request_id)
	local msg ={}
	msg.result_code = 0
	msg.response_name = "COMMAND_RESPONSE"
	msg.paras ={}
	msg.paras.result="success"
	m:publish("$oc/devices/641474d140773741f9fb9dab_wifi1234/sys/commands/response/request_id="..request_id,sjson.encode(msg),0,1)
end

IO_BLINK=4
gpio.mode(IO_BLINK, gpio.OUTPUT)
local function blinking(flag)
	print(flag)
	gpio.write(IO_BLINK, flag and gpio.HIGH or gpio.LOW)
end

local function consume_data( payload, request_id )
	print(sjson.decode(payload).paras.light)
	if sjson.decode(payload).paras.light == "on" then
		blinking(true)
	else
		blinking(false)
	end
	 
  --do someting with the payload and send responce
    send_suf()
	print(request_id)
	send_command(request_id)
end

-- Sends my id to the broker for registration
local function register_myself()
    m:subscribe(config.ENDPOINT,0,function(conn)
        print("Successfully subscribed to data endpoint")
        send_ping()
    end)
end

local function mqtt_start()
	print("init mqtt")
    m = mqtt.Client("641474d140773741f9fb9dab_wifi1234_0_0_2023031715", 120,config.USERNAME,config.PASSWORD)
    -- register message callback beforehand
    m:on("message", function(conn, topic, data)
      if data ~= nil then
        print(topic .. ": " .. data)
        consume_data(data, get_request(topic))
      end
    end)
    -- Connect to broker
    m:connect(config.HOST, config.PORT, false, function(con)
		print("connect sucess")
        register_myself()
    end,
	function(client, reason)
		print("Connection failed reason: " .. reason)
	end)

end

mqtt_start()