参考: https://blog.csdn.net/freemote/article/details/105348959
环境: micropython ESP32-C3 腾讯云物联网IOT
说明:
esp32-c3的固件中 没有umqtt模块,所以需要手动引入simple.py(参考https://github.com/micropython/micropython-lib/blob/master/micropython/umqtt.simple/umqtt/simple.py)
可以使用 help(‘modules’) 查看
剩下的直接上代码
simple.py

import usocket as socket
import ustruct as struct
from ubinascii import hexlify
class MQTTException(Exception):
class MQTTClient:
    def __init__(
            self,
            client_id,
            server,
            port=0,
            user=None,
            password=None,
            keepalive=0,
            ssl=False,
            ssl_params={},
        if port == 0:
            port = 8883 if ssl else 1883
        self.client_id = client_id
        self.sock = None
        self.server = server
        self.port = port
        self.ssl = ssl
        self.ssl_params = ssl_params
        self.pid = 0
        self.cb = None
        self.user = user
        self.pswd = password
        self.keepalive = keepalive
        self.lw_topic = None
        self.lw_msg = None
        self.lw_qos = 0
        self.lw_retain = False
    def _send_str(self, s):
        self.sock.write(struct.pack("!H", len(s)))
        self.sock.write(s)
    def _recv_len(self):
        n = 0
        sh = 0
        while 1:
            b = self.sock.read(1)[0]
            n |= (b & 0x7F) << sh
            if not b & 0x80:
                return n
            sh += 7
    def set_callback(self, f):
        self.cb = f
    def set_last_will(self, topic, msg, retain=False, qos=0):
        assert 0 <= qos <= 2
        assert topic
        self.lw_topic = topic
        self.lw_msg = msg
        self.lw_qos = qos
        self.lw_retain = retain
    def connect(self, clean_session=True):
        self.sock = socket.socket()
        addr = socket.getaddrinfo(self.server, self.port)[0][-1]
        self.sock.connect(addr)
        if self.ssl:
            import ussl
            self.sock = ussl.wrap_socket(self.sock, **self.ssl_params)
        premsg = bytearray(b"\x10\0\0\0\0\0")
        msg = bytearray(b"\x04MQTT\x04\x02\0\0")
        sz = 10 + 2 + len(self.client_id)
        msg[6] = clean_session << 1
        if self.user is not None:
            sz += 2 + len(self.user) + 2 + len(self.pswd)
            msg[6] |= 0xC0
        if self.keepalive:
            assert self.keepalive < 65536
            msg[7] |= self.keepalive >> 8
            msg[8] |= self.keepalive & 0x00FF
        if self.lw_topic:
            sz += 2 + len(self.lw_topic) + 2 + len(self.lw_msg)
            msg[6] |= 0x4 | (self.lw_qos & 0x1) << 3 | (self.lw_qos & 0x2) << 3
            msg[6] |= self.lw_retain << 5
        i = 1
        while sz > 0x7F:
            premsg[i] = (sz & 0x7F) | 0x80
            sz >>= 7
            i += 1
        premsg[i] = sz
        self.sock.write(premsg, i + 2)
        self.sock.write(msg)
        # print(hex(len(msg)), hexlify(msg, ":"))
        self._send_str(self.client_id)
        if self.lw_topic:
            self._send_str(self.lw_topic)
            self._send_str(self.lw_msg)
        if self.user is not None:
            self._send_str(self.user)
            self._send_str(self.pswd)
        resp = self.sock.read(4)
        assert resp[0] == 0x20 and resp[1] == 0x02
        if resp[3] != 0:
            raise MQTTException(resp[3])
        return resp[2] & 1
    def disconnect(self):
        self.sock.write(b"\xe0\0")
        self.sock.close()
    def ping(self):
        self.sock.write(b"\xc0\0")
    def publish(self, topic, msg, retain=False, qos=0):
        pkt = bytearray(b"\x30\0\0\0")
        pkt[0] |= qos << 1 | retain
        sz = 2 + len(topic) + len(msg)
        if qos > 0:
            sz += 2
        assert sz < 2097152
        i = 1
        while sz > 0x7F:
            pkt[i] = (sz & 0x7F) | 0x80
            sz >>= 7
            i += 1
        pkt[i] = sz
        # print(hex(len(pkt)), hexlify(pkt, ":"))
        self.sock.write(pkt, i + 1)
        self._send_str(topic)
        if qos > 0:
            self.pid += 1
            pid = self.pid
            struct.pack_into("!H", pkt, 0, pid)
            self.sock.write(pkt, 2)
        self.sock.write(msg)
        if qos == 1:
            while 1:
                op = self.wait_msg()
                if op == 0x40:
                    sz = self.sock.read(1)
                    assert sz == b"\x02"
                    rcv_pid = self.sock.read(2)
                    rcv_pid = rcv_pid[0] << 8 | rcv_pid[1]
                    if pid == rcv_pid:
                        return
        elif qos == 2:
            assert 0
    def subscribe(self, topic, qos=0):
        assert self.cb is not None, "Subscribe callback is not set"
        pkt = bytearray(b"\x82\0\0\0")
        self.pid += 1
        struct.pack_into("!BH", pkt, 1, 2 + 2 + len(topic) + 1, self.pid)
        # print(hex(len(pkt)), hexlify(pkt, ":"))
        self.sock.write(pkt)
        self._send_str(topic)
        self.sock.write(qos.to_bytes(1, "little"))
        while 1:
            op = self.wait_msg()
            if op == 0x90:
                resp = self.sock.read(4)
                # print(resp)
                assert resp[1] == pkt[2] and resp[2] == pkt[3]
                if resp[3] == 0x80:
                    raise MQTTException(resp[3])
                return
    # Wait for a single incoming MQTT message and process it.
    # Subscribed messages are delivered to a callback previously
    # set by .set_callback() method. Other (internal) MQTT
    # messages processed internally.
    def wait_msg(self):
        res = self.sock.read(1)
        self.sock.setblocking(True)
        if res is None:
            return None
        if res == b"":
            raise OSError(-1)
        if res == b"\xd0":  # PINGRESP
            sz = self.sock.read(1)[0]
            assert sz == 0
            return None
        op = res[0]
        if op & 0xF0 != 0x30:
            return op
        sz = self._recv_len()
        topic_len = self.sock.read(2)
        topic_len = (topic_len[0] << 8) | topic_len[1]
        topic = self.sock.read(topic_len)
        sz -= topic_len + 2
        if op & 6:
            pid = self.sock.read(2)
            pid = pid[0] << 8 | pid[1]
            sz -= 2
        msg = self.sock.read(sz)
        self.cb(topic, msg)
        if op & 6 == 2:
            pkt = bytearray(b"\x40\x02\0\0")
            struct.pack_into("!H", pkt, 2, pid)
            self.sock.write(pkt)
        elif op & 6 == 4:
            assert 0
    # Checks whether a pending message from server is available.
    # If not, returns immediately with None. Otherwise, does
    # the same processing as wait_msg.
    def check_msg(self):
        self.sock.setblocking(False)
        return self.wait_msg()
main.py
 
# main.py
import time
from umqttsimple import MQTTClient
from gc import mem_free
import network
def connect_wifi(ssid, passwd):
    global wlan
    wlan = network.WLAN(network.STA_IF)  # create a wlan object
    wlan.active(True)  # Activate the network interface
    wlan.disconnect()  # Disconnect the last connected WiFi
    wlan.connect(ssid, passwd)  # connect wifi
    while (wlan.ifconfig()[0] == '0.0.0.0'):
        time.sleep(1)
    wlan_info = wlan.ifconfig()
    print("Wifi is connected with the following information:")
    print(" IP address : " + wlan_info[0])
    print("Subnet mask : " + wlan_info[1])
    print("    Gateway : " + wlan_info[2])
    print("        DNS : " + wlan_info[3])
mqtt_client = None
def sub_cb(topic, msg):
    print("接收到数据", (topic, msg))
    mymessage = '{"AAAA": %d }' % (time.time())
    print("mqtt_client 1: %s" % mqtt_client.client_id)
    mqtt_client.publish(topic=publish_topic, msg=mymessage, retain=True, qos=1)
    mqtt_client.publish(topic=publish_topic, msg='13244654', retain=True, qos=1)
    print("发送消息", mymessage)
broker_address = 'product_id.iotcloud.tencentdevices.com'  #  MQTT服务器地址
broker_port = '1883'   #  MQTT服务器端口
client_id = 'XXXXXX'   #  MQTT设备id
user_name = 'XXXXXXXXXXXXXX'  # mqtt 设备用户名
password = 'XXXXXXXXXXXXXXXXXXXXXXX' # mqtt 设备密码
publish_topic = 'LGSODS81VJ/ESP32Devcice1/data'   # 推送主题
subscribe_topic = 'LGSODS81VJ/ESP32Devcice1/data'  # 订阅主题
SSID = 'WLAN_NAME'  # 无线网名称
PASSWORD = 'WLAN_PASSWORD'  #无线网密码
if __name__ == '__main__':
        print("\n可用内存1: %s Byte" % str(mem_free()))
        connect_wifi(SSID, PASSWORD)
        print("\n可用内存2: %s Byte" % str(mem_free()))
        mqtt_client = MQTTClient(client_id=client_id, server=broker_address, port=broker_port, user=user_name,
                                 password=password, keepalive=60)
        mqtt_client.set_callback(sub_cb)
        mqtt_client.connect()
        mqtt_client.subscribe(subscribe_topic)
        mqtt_client.publish(topic=publish_topic, msg="12345678900000", retain=False, qos=1)
        print("mqtt_client 1: %s" % mqtt_client.client_id)
        while True:
            mqtt_client.wait_msg()  # wait message
    except Exception as ex_results:
        print('exception1', ex_results)
    finally:
        if (mqtt_client is not None):
            mqtt_client.disconnect()
        wlan.disconnect()
        wlan.active(False)
我这边使用的是腾讯云物联网通讯(使用设备发送消息 最好使用数字和json格式 字符串可能无法接收)
 
 由 ESP32提供支持。
该比重计是独立的，这意味着您无需使用电子表格即可进行校准。 平台/ sg倾斜角关系的多项式回归已经内置在前端中。 因此，只需按照指南进行操作，即可轻松进行校准。 校准甚至具有可选的温度校正功能，因此即使您的自来水真的很冷或很热，该校准仍然有效。
 重力/柏拉图数据可以选择发送到发酵控制器（例如CraftBeerPi3）或MQTT代理（例如Ubidots）。
 该API与现成的CraftBeerPi3兼容（还请确保签出我的Fermenter-ESP32-Micropyth
                                    我的博文 《认识ESP-IDF-v4.3+工程结构（ESP32-C3应用调整示例）》最终工程结构，
使用 自己画的 ESP32-C3 开发板《自己画一块ESP32-C3 的开发板（立创EDA）（PCB到手）》 。
实现了 ESP32-C3 通过 MQTT 协议连接 ONENET 云平台，实现了数据的上传，平台的下行控制等功能 。
使用了ESP32-C3的 ADC采样， I2C接口， GPIO按键驱动，TIMG 硬件定时器，RMT这些功能，Wi-Fi 使用 Smart_config 的配网方式 。
同时对于 ESP-IDF-v4.3+工程结构进行了分析，使得结构更加规范，整洁。
是一个实际可用的物联网小应用实例，通过此案例，使得新朋友能够快速的使用ESP32-C3来实现自己的项目。
使用esp-idf的esp-now和MQTT之间的网关。
我的灵感来自于。
 ESP-NOW可以与ESP8266 / 8285一起使用，但我们不能同时使用WiFi。该项目将ESP-NOW接收的数据传输到MQTT。
ESP8266 / 8285 +电池+ ESP-NOW + DeelSpeep可实现长时间运行。这是Wifi和ESP-NOW之间电池消耗的比较。
电池寿命预测
ESP12E可以从2.5V的深度睡眠模式唤醒。 
 ESP12S / 07S可以从2.2V的深度睡眠模式中唤醒。 
git clone https://github.com/nopnop2002/esp-idf-espnow-gateway
cd esp-idf-espnow-gateway
make menuconfig
make flash monitor
                                    2022 / 01/ 30: 新版esptool 刷micropython固件指令不是 esptool.py cmd... 而是 esptool cmd... 即可;另外rshell 在 >= python 3.10 的时候出错解决方法可以查看:  已于2022年发布的:  第二章：修复rshell在python3.10出错 免费内容： https://edu.csdn.net/course/detail/29666 micropython语法和python3一样,编写起来非常方便。如果你快速入门单片机玩物联网而且像轻松实现各种功能，那绝力推荐使用micropython。方便易懂易学。 同时如果你懂C语音，也可以用C写好函数并编译进micropython固件里然后进入micropython调用（非必须）。 能通过WIFI联网(2.1章)，也能通过sim卡使用2G/3G/4G/5G联网（4.5章）。 为实现语音控制，本教程会教大家使用tensorflow利用神经网络训练自己的语音模型并应用。为实现通过网页控制，本教程会教大家linux(debian10 nginx->uwsgi->python3->postgresql)网站前后台入门。为记录单片机传输过来的数据， 本教程会教大家入门数据库。   本教程会通过通俗易懂的比喻来讲解各种原理与思路，并手把手编写程序来实现各项功能。  本教程micropython版本是 2019年6月发布的1.11；  更多内容请看视频列表。   学习这门课程之前你需要至少掌握:   1: python3基础（变量, 循环, 函数, 常用库, 常用方法）。       本视频使用到的零件与淘宝上大致价格:       1: 超声波传感器(3)       2: MAX9814麦克风放大模块(8)       3: DHT22(15)       4: LED(0.1)       5: 8路5V低电平触发继电器(12)       6: HX1838红外接收模块(2)       7：红外发射管(0.1)，HX1838红外接收板(1)       other: 电表, 排线, 面包板(2)*2,ESP32(28)   
                                    MQTT协议是轻量、简单、开放和易于实现的，这些特点使它适用范围非常广泛。在很多情况下，包括受限的环境中，如：机器与机器（M2M）通信和物联网（IoT）。其在，通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。
2.搭载了BLE5.0；
3.加强了安全性。
简单说就是压低了成本出的最新款，个人也理解为取代esp8266的新款，也可以说这个esp32c3可能是跟其他esp32系列差距最大的一个，flash download tools等软件不更新最新版甚至都无法识别出来芯片。
我觉得在一些特别追求成本的项目中，这个芯片可能会特别吃香，在stm32疯涨的背景下，esp32还出了廉价款，业界良心。
/bin/emqx start
这里有个坑，如果服务器版本是WINDOWS 2019 数据中心的云服务器镜像则会提示少.DLL  解决办法下载是  2013的C++ redist  （别下高版本的2015）下载地址为
https://www.microsoft.com/zh-CN/download/details.aspx?id
                                    先感谢这篇文章
esp32c3+air101Lcd用micropython点亮
这个屏幕虽然可以配合esp32c3使用，但是很显然这个lcd不是原生搭配的，因为看针脚的定义，esp32c3的IO10是硬件spi的MISO引脚，在屏幕中，这个引脚定义为RES，看起来还是略显尴尬。
根据官方介绍屏幕驱动使用的是st7735s，在使用的时候，先引用st7735.py，然后定义软SPI，不理res针脚这件事情，还是把IO10定义为MISO。
测试代码如下：
from machine import Pin, Soft
                                    我们购买智能家居产品后，买回来拆箱后第一件事通常就是给这个新的硬件进行配网，所谓配网，也就是让这个新的物联网设备联入我们的局域网内，让这个物联网设备可以进行网络通讯。我们在上一篇文章《MicroPython(ESP32/ESP8266) 实现web控制GPIO》中已经了解到了如何使用ESP32和ESP8266通过联网来实现在Web中控制板载的 LED 灯开关。本文将介绍基于 MicroPython 来实现的 ESP32/ESP8266 Wifi配网。
在开始代码之前，需要先准备以下：
                                    这里有个技巧，直接到固件的目录下面按住shift 再点击鼠标右键，打开powershell。擦除完成之后重启一下设备（上面有个res按钮，不然可能下一步找不到串口）下载完成之后安装的时候记得点击下面的自动配置环境变量。（这里不会的可以百度一下，教程很多）这里需要自己查查看串口是com几手动指定一下。再输入个e 按Tab键就可以自动补全。简单点可以用自动补全  先输入这个。再回车就可以执行烧录了。