正文

树莓派Pico入门：轻松订阅MQTT消息，开启智能物联网之旅

/0 浏览量
1103

树莓派Pico是一款小巧而强大的微控制器，非常适合初学者和专业人士进行物联网（IoT）项目。通过订阅MQTT消息，我们可以轻松地实现设备之间的通信和数据交换。本文将带你入门，学习如何在树莓派Pico上订阅MQTT消息，开启你的智能物联网之旅。

环境准备

在开始之前，你需要准备以下工具和材料：

  • 树莓派Pico微控制器
  • USB线
  • 一个可用的MQTT服务器（例如：MQTTX客户端）
  • 一台电脑（Windows、macOS或Linux）

安装MicroPython

树莓派Pico默认运行的是MicroPython，这是一个轻量级的Python实现，非常适合微控制器编程。以下是安装MicroPython的步骤：

  1. 下载MicroPython固件：MicroPython固件下载
  2. 使用树莓派Pico的MicroPython固件加载器将固件刷入树莓派Pico。
  3. 重启树莓派Pico，等待其连接到你的电脑。

连接MQTT服务器

在开始订阅MQTT消息之前，我们需要连接到一个MQTT服务器。以下是连接到MQTT服务器的步骤：

  1. 打开MQTTX客户端。
  2. 输入MQTT服务器的地址、端口、用户名和密码（如果有）。
  3. 点击“连接”按钮。

编写订阅MQTT消息的代码

在MicroPython中，我们可以使用umqtt.simple模块来订阅MQTT消息。以下是一个简单的例子：

import umqtt.simple as mqtt

# MQTT服务器地址和端口
MQTT_SERVER = "mqtt.example.com"
MQTT_PORT = 1883

# 订阅的主题
SUB_TOPIC = "my/topic"

# MQTT服务器用户名和密码
MQTT_USER = "username"
MQTT_PASS = "password"

# 连接到MQTT服务器
client = mqtt.Client()

# 连接回调函数
def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    # 订阅主题
    client.subscribe(SUB_TOPIC)

# 消息回调函数
def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))

# 设置连接回调函数
client.on_connect = on_connect

# 设置消息回调函数
client.on_message = on_message

# 连接到MQTT服务器
client.connect(MQTT_SERVER, MQTT_PORT, 60)

# 启动网络循环
client.loop_forever()

运行代码

将上述代码保存到一个名为subscribe.py的文件中，然后使用MicroPython的machine模块来运行它：

import machine

# 初始化树莓派Pico的LED灯
led = machine.Pin(25, machine.Pin.OUT)

# 运行订阅MQTT消息的代码
try:
    exec(open('subscribe.py').read())
finally:
    led.value(0)

当MQTT服务器上有人发布my/topic主题的消息时，树莓派Pico将会收到该消息，并在串口打印出来。

总结

通过订阅MQTT消息，你可以轻松地实现树莓派Pico与其他设备之间的通信和数据交换。本文介绍了如何在树莓派Pico上订阅MQTT消息，并提供了相应的代码示例。希望这篇文章能帮助你开启你的智能物联网之旅！

-- 展开阅读全文 --