设为首页收藏本站
首页 > 论坛 > ESP32

[ESP8266/ESP32]thonny更新固件和手机远程点灯

得劲滋润爽 | 初级技师 | 创造力： | 帖子： | 发消息 | 串个门 | 加好友 | 打招呼
2023-6-2 13:27:51 [显示全部楼层]
2416浏览
0回复
0收藏
查看: 2416|回复: 0

[ESP8266/ESP32] thonny更新固件和手机远程点灯

[复制链接]
本帖最后由 得劲滋润爽 于 2023-6-2 13:30 编辑

thonny更新固件和手机远程点灯

板子：合宙ESP32-C3简约版
thonny：4.0.2
MQTT服务器：broker.emqx.io
在线调试助手：http://www.emqx.io/online-mqtt-client
手机APP：IOT MQTT panel
micropython固件：esp32c3-usb-20230426-v1.20.0


我的板子是已经有固件了，并且可以正常使用，如果你的条件不满足请使用乐鑫官方的flash_download_tool进行固件的烧写。（社区搜索ESP32 C3能搜到教程）


一、连接板子，烧写固件
thonny更新固件和手机远程点灯图1thonny更新固件和手机远程点灯图2thonny更新固件和手机远程点灯图3thonny更新固件和手机远程点灯图4thonny更新固件和手机远程点灯图5thonny更新固件和手机远程点灯图6

报错了
thonny更新固件和手机远程点灯图7
[tr][/tr]
  


按住boot键再插数据线试一下
thonny更新固件和手机远程点灯图8thonny更新固件和手机远程点灯图9
OK了，如果还是失败或者刷完固件无法正常运行可以再尝试重新烧写一次，还不行就请使用乐鑫官方的烧写工具进行烧写固件。！




二、测试MQTT通信
  1. '''

  2. 实验名称：MQTT通信

  3. 版本：v1.1

  4. 日期：2023.5

  5. 改编：maikemaker

  6. 说明：编程实现MQTT通信，实现接收到消息后打印出消息和topic并且往另一个topic发送一条消息

  7. MQTT助手：http://www.emqx.io/online-mqtt-client

  8. '''

  9. import network,time

  10. from simple import MQTTClient #导入MQTT板块

  11. from machine import Pin,Timer

  12. 

  13. 

  14. #WIFI连接函数

  15. def WIFI_Connect():

  16. 

  17.     WIFI_LED=Pin(12, Pin.OUT) #初始化WIFI指示灯

  18. 

  19.     wlan = network.WLAN(network.STA_IF) #STA模式

  20.     wlan.active(True)                   #激活接口

  21.     start_time=time.time()              #记录时间做超时判断

  22. 

  23.     if not wlan.isconnected():

  24.         print('connecting to network...')

  25.         wlan.connect('waoo2111280', 'waoo2111280') #输入WIFI账号密码

  26. 

  27.         while not wlan.isconnected():

  28. 

  29.             #LED闪烁提示

  30.             WIFI_LED.value(1)

  31.             time.sleep_ms(300)

  32.             WIFI_LED.value(0)

  33.             time.sleep_ms(300)

  34. 

  35.             #超时判断,15秒没连接成功判定为超时

  36.             if time.time()-start_time > 15 :

  37.                 print('WIFI Connected Timeout!')

  38.                 wlan.active(False) #反激活WiFi

  39.                 break

  40. 

  41.     if wlan.isconnected():

  42.         #LED点亮

  43.         WIFI_LED.value(1)

  44. 

  45.         #串口打印信息

  46.         print('network information:', wlan.ifconfig())

  47.         

  48.         return True

  49. 

  50.     else:

  51.         return False

  52.     

  53. #MQTT发布数据任务

  54. def MQTT_Send(tim):

  55.     client.publish(TOPIC2, 'Im fine.Thanks')

  56. 

  57. #设置MQTT回调函数,有信息时候执行

  58. def MQTT_callback(topic, msg):

  59.     print('topic: {}'.format(topic))

  60.     print('msg: {}'.format(msg))

  61.     MQTT_Send(None) #调用MQTT_Send()函数

  62.     

  63. #接收数据任务

  64. def MQTT_Rev(tim):

  65.     client.check_msg()

  66. 

  67. 

  68. 

  69. #执行WIFI连接函数并判断是否已经连接成功

  70. if WIFI_Connect():

  71. 

  72.     SERVER = 'broker.emqx.io'# MQTT服务器

  73.     PORT = 1883 #端口

  74.     CLIENT_ID = '202306021143' # 客户端ID
复制代码


程序效果，给接收的话题发送一个消息，接收到之后串口打印消息并给回复的话题回复一条消息。


上传MQTT库
  1. import usocket as socket

  2. import ustruct as struct

  3. from ubinascii import hexlify

  4. 

  5. class MQTTException(Exception):

  6.     pass

  7. 

  8. class MQTTClient:

  9. 

  10.     def __init__(self, client_id, server, port=0, user=None, password=None, keepalive=0,

  11.                  ssl=False, ssl_params={}):

  12.         if port == 0:

  13.             port = 8883 if ssl else 1883

  14.         self.client_id = client_id

  15.         self.sock = None

  16.         self.server = server

  17.         self.port = port

  18.         self.ssl = ssl

  19.         self.ssl_params = ssl_params

  20.         self.pid = 0

  21.         self.cb = None

  22.         self.user = user

  23.         self.pswd = password

  24.         self.keepalive = keepalive

  25.         self.lw_topic = None

  26.         self.lw_msg = None

  27.         self.lw_qos = 0

  28.         self.lw_retain = False

  29. 

  30.     def _send_str(self, s):

  31.         self.sock.write(struct.pack("!H", len(s)))

  32.         self.sock.write(s)

  33. 

  34.     def _recv_len(self):

  35.         n = 0

  36.         sh = 0

  37.         while 1:

  38.             b = self.sock.read(1)[0]

  39.             n |= (b & 0x7f) << sh

  40.             if not b & 0x80:

  41.                 return n

  42.             sh += 7

  43. 

  44.     def set_callback(self, f):

  45.         self.cb = f

  46. 

  47.     def set_last_will(self, topic, msg, retain=False, qos=0):

  48.         assert 0 <= qos <= 2

  49.         assert topic

  50.         self.lw_topic = topic

  51.         self.lw_msg = msg

  52.         self.lw_qos = qos

  53.         self.lw_retain = retain

  54. 

  55.     def connect(self, clean_session=True):

  56.         self.sock = socket.socket()

  57.         addr = socket.getaddrinfo(self.server, self.port)[0][-1]

  58.         self.sock.connect(addr)

  59.         if self.ssl:

  60.             import ussl

  61.             self.sock = ussl.wrap_socket(self.sock, **self.ssl_params)

  62.         premsg = bytearray(b"\x10\0\0\0\0\0")

  63.         msg = bytearray(b"\x04MQTT\x04\x02\0\0")

  64. 

  65.         sz = 10 + 2 + len(self.client_id)

  66.         msg[6] = clean_session << 1

  67.         if self.user is not None:

  68.             sz += 2 + len(self.user) + 2 + len(self.pswd)

  69.             msg[6] |= 0xC0

  70.         if self.keepalive:

  71.             assert self.keepalive < 65536

  72.             msg[7] |= self.keepalive >> 8

  73.             msg[8] |= self.keepalive & 0x00FF

  74.         if self.lw_topic:

  75.             sz += 2 + len(self.lw_topic) + 2 + len(self.lw_msg)

  76.             msg[6] |= 0x4 | (self.lw_qos & 0x1) << 3 | (self.lw_qos & 0x2) << 3

  77.             msg[6] |= self.lw_retain << 5

  78. 

  79.         i = 1

  80.         while sz > 0x7f:

  81.             premsg[i] = (sz & 0x7f) | 0x80

  82.             sz >>= 7

  83.             i += 1

  84.         premsg[i] = sz

  85. 

  86.         self.sock.write(premsg, i + 2)

  87.         self.sock.write(msg)

  88.         #print(hex(len(msg)), hexlify(msg, ":"))

  89.         self._send_str(self.client_id)

  90.         if self.lw_topic:

  91.             self._send_str(self.lw_topic)

  92.             self._send_str(self.lw_msg)

  93.         if self.user is not None:

  94.             self._send_str(self.user)

  95.             self._send_str(self.pswd)

  96.         resp = self.sock.read(4)

  97.         assert resp[0] == 0x20 and resp[1] == 0x02

  98.         if resp[3] != 0:

  99.             raise MQTTException(resp[3])

  100.         return resp[2] & 1

  101. 

  102.     def disconnect(self):

  103.         self.sock.write(b"\xe0\0")

  104.         self.sock.close()

  105. 

  106.     def ping(self):

  107.         self.sock.write(b"\xc0\0")

  108. 

  109.     def publish(self, topic, msg, retain=False, qos=0):

  110.         pkt = bytearray(b"\x30\0\0\0")

  111.         pkt[0] |= qos << 1 | retain

  112.         sz = 2 + len(topic) + len(msg)

  113.         if qos > 0:

  114.             sz += 2

  115.         assert sz < 2097152

  116.         i = 1

  117.         while sz > 0x7f:

  118.             pkt[i] = (sz & 0x7f) | 0x80

  119.             sz >>= 7

  120.             i += 1

  121.         pkt[i] = sz

  122.         #print(hex(len(pkt)), hexlify(pkt, ":"))

  123.         self.sock.write(pkt, i + 1)

  124.         self._send_str(topic)

  125.         if qos > 0:

  126.             self.pid += 1

  127.             pid = self.pid

  128.             struct.pack_into("!H", pkt, 0, pid)

  129.             self.sock.write(pkt, 2)

  130.         self.sock.write(msg)

  131.         if qos == 1:

  132.             while 1:

  133.                 op = self.wait_msg()

  134.                 if op == 0x40:

  135.                     sz = self.sock.read(1)

  136.                     assert sz == b"\x02"

  137.                     rcv_pid = self.sock.read(2)

  138.                     rcv_pid = rcv_pid[0] << 8 | rcv_pid[1]

  139.                     if pid == rcv_pid:

  140.                         return

  141.         elif qos == 2:

  142.             assert 0

  143. 

  144.     def subscribe(self, topic, qos=0):

  145.         assert self.cb is not None, "Subscribe callback is not set"

  146.         pkt = bytearray(b"\x82\0\0\0")

  147.         self.pid += 1

  148.         struct.pack_into("!BH", pkt, 1, 2 + 2 + len(topic) + 1, self.pid)

  149.         #print(hex(len(pkt)), hexlify(pkt, ":"))

  150.         self.sock.write(pkt)

  151.         self._send_str(topic)

  152.         self.sock.write(qos.to_bytes(1, "little"))

  153.         while 1:

  154.             op = self.wait_msg()

  155.             if op == 0x90:

  156.                 resp = self.sock.read(4)

  157.                 #print(resp)

  158.                 assert resp[1] == pkt[2] and resp[2] == pkt[3]

  159.                 if resp[3] == 0x80:

  160.                     raise MQTTException(resp[3])

  161.                 return

  162. 

  163.     # Wait for a single incoming MQTT message and process it.

  164.     # Subscribed messages are delivered to a callback previously

  165.     # set by .set_callback() method. Other (internal) MQTT

  166.     # messages processed internally.

  167.     def wait_msg(self):

  168.         res = self.sock.read(1)

  169.         self.sock.setblocking(True)

  170.         if res is None:

  171.             return None

  172.         if res == b"":

  173.             raise OSError(-1)

  174.         if res == b"\xd0":  # PINGRESP

  175.             sz = self.sock.read(1)[0]

  176.             assert sz == 0

  177.             return None

  178.         op = res[0]

  179.         if op & 0xf0 != 0x30:

  180.             return op

  181.         sz = self._recv_len()

  182.         topic_len = self.sock.read(2)

  183.         topic_len = (topic_len[0] << 8) | topic_len[1]

  184.         topic = self.sock.read(topic_len)

  185.         sz -= topic_len + 2

  186.         if op & 6:

  187.             pid = self.sock.read(2)

  188.             pid = pid[0] << 8 | pid[1]

  189.             sz -= 2

  190.         msg = self.sock.read(sz)

  191.         self.cb(topic, msg)

  192.         if op & 6 == 2:

  193.             pkt = bytearray(b"\x40\x02\0\0")

  194.             struct.pack_into("!H", pkt, 2, pid)

  195.             self.sock.write(pkt)

  196.         elif op & 6 == 4:

  197.             assert 0

  198. 

  199.     # Checks whether a pending message from server is available.

  200.     # If not, returns immediately with None. Otherwise, does

  201.     # the same processing as wait_msg.

  202.     def check_msg(self):

  203.         self.sock.setblocking(False)

  204.         return self.wait_msg()

  205. 

复制代码
新建文件，输入上面的代码，点击保存，选择保存到micropython设备，文件名simple.py
thonny更新固件和手机远程点灯图11thonny更新固件和手机远程点灯图12thonny更新固件和手机远程点灯图13
打开文件视图
thonny更新固件和手机远程点灯图10

运行程序
thonny更新固件和手机远程点灯图14
打开调试助手，进行调试
thonny更新固件和手机远程点灯图15thonny更新固件和手机远程点灯图16thonny更新固件和手机远程点灯图17thonny更新固件和手机远程点灯图18thonny更新固件和手机远程点灯图19


订阅程序里面的两个主题（Topic）
thonny更新固件和手机远程点灯图20thonny更新固件和手机远程点灯图21
效果
thonny更新固件和手机远程点灯图22


三、点灯测试
  1. '''

  2. 实验名称：MQTT通信

  3. 版本：v1.1

  4. 日期：2023.6

  5. 改编：maikemaker

  6. 说明：点灯测试

  7. MQTT助手：http://www.emqx.io/online-mqtt-client

  8. '''

  9. import network,time

  10. from simple import MQTTClient #导入MQTT板块

  11. from machine import Pin,Timer

  12. 

  13. led=Pin(13,Pin.OUT,value=0)

  14. #WIFI连接函数

  15. def WIFI_Connect():

  16. 

  17.     WIFI_LED=Pin(12, Pin.OUT) #初始化WIFI指示灯

  18. 

  19.     wlan = network.WLAN(network.STA_IF) #STA模式

  20.     wlan.active(True)                   #激活接口

  21.     start_time=time.time()              #记录时间做超时判断

  22. 

  23.     if not wlan.isconnected():

  24.         print('connecting to network...')

  25.         wlan.connect('waoo2111280', 'waoo2111280') #输入WIFI账号密码

  26. 

  27.         while not wlan.isconnected():

  28. 

  29.             #LED闪烁提示

  30.             WIFI_LED.value(1)

  31.             time.sleep_ms(300)

  32.             WIFI_LED.value(0)

  33.             time.sleep_ms(300)

  34. 

  35.             #超时判断,15秒没连接成功判定为超时

  36.             if time.time()-start_time > 15 :

  37.                 print('WIFI Connected Timeout!')

  38.                 wlan.active(False) #反激活WiFi

  39.                 break

  40. 

  41.     if wlan.isconnected():

  42.         #LED点亮

  43.         WIFI_LED.value(1)

  44. 

  45.         #串口打印信息

  46.         print('network information:', wlan.ifconfig())

  47.         

  48.         return True

  49. 

  50.     else:

  51.         return False

  52.     

  53. #MQTT发布数据任务

  54. def MQTT_Send(tim):

  55.     client.publish(TOPIC2, 'Im fine.Thanks')

  56. 

  57. #设置MQTT回调函数,有信息时候执行

  58. def MQTT_callback(topic, msg):

  59.     print('topic: {}'.format(topic))

  60.     print('msg: {}'.format(msg))

  61.     if msg==b'on':

  62.         led.value(1)

  63.     if msg==b'off':

  64.         led.value(0)

  65.     MQTT_Send(None) #调用MQTT_Send()函数

  66.     

  67. #接收数据任务

  68. def MQTT_Rev(tim):

  69.     client.check_msg()

  70. 

  71. 

  72. 

  73. #执行WIFI连接函数并判断是否已经连接成功

  74. if WIFI_Connect():

  75. 

  76.     SERVER = 'broker.emqx.io'# MQTT服务器

  77.     PORT = 1883

  78.     CLIENT_ID = '202306021143' # 客户端ID

  79.     #话题1

  80.     TOPIC = '/T1/test/1' # TOPIC名称，接收消息的主题

  81.     #话题2

  82.     TOPIC2 = '/T2/test/2' # TOPIC名称，回复的主题

  83.     

  84.     client = MQTTClient(CLIENT_ID, SERVER, PORT)

  85.     client.set_callback(MQTT_callback)  #配置回调函数

  86.     client.connect()

  87.     client.subscribe(TOPIC) #订阅主题

  88. 

  89.     #开启RTOS定时器，编号为0或2,周期1000ms，执行MQTT发布

  90.     tim = Timer(0)

  91.     tim.init(period=300, mode=Timer.PERIODIC,callback=MQTT_Rev)

  92. 

复制代码

thonny更新固件和手机远程点灯图35
设置APP
thonny更新固件和手机远程点灯图23thonny更新固件和手机远程点灯图24thonny更新固件和手机远程点灯图25thonny更新固件和手机远程点灯图26thonny更新固件和手机远程点灯图27thonny更新固件和手机远程点灯图28thonny更新固件和手机远程点灯图29
添加两个按钮
thonny更新固件和手机远程点灯图30thonny更新固件和手机远程点灯图31thonny更新固件和手机远程点灯图32thonny更新固件和手机远程点灯图33thonny更新固件和手机远程点灯图34


测试
thonny更新固件和手机远程点灯图36

效果还不错吧
试一下开关控件
thonny更新固件和手机远程点灯图37
thonny更新固件和手机远程点灯图38
效果也不错。


不想用blynk和点灯的可以试试这个APP。
micropython, MQTT, 物联网

相关帖子

回复

使用道具 举报

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

为本项目制作心愿单
购买心愿单
心愿单 编辑
[[wsData.name]]

硬件清单

  • [[d.name]]
btnicon
我也要做!
点击进入购买页面
撰写新帖
关于楼主

楼主的其它帖子

background 创造力兑换 background 心愿单 background 创客导航
上海智位机器人股份有限公司 沪ICP备09038501号-4

© 2013-2024 Comsenz Inc. Powered by Discuz! X3.4 Licensed

mail