Module13.2 LAN

案例程序

通过 LAN 模块连接到 MQTT 服务器，订阅和发布消息，并轮询下行消息来控制设备的状态(例如控制继电器的开关)

from m5stack import *
from m5ui import *
from uiflow import *
import module
import time

setScreenColor(0x810000)

lan_topic = None
lan_msg = None

lan = module.get(module.LAN_MODULE)

label2 = M5TextBox(53, 219, "ON", lcd.FONT_DejaVu18, 0x810000, rotate=0)
label3 = M5TextBox(230, 219, "OFF", lcd.FONT_DejaVu18, 0x810000, rotate=0)

def module_lan_mqtt_cb(lan_mq_topic, lan_mq_payload):
  global lan_topic, lan_msg
  lan_topic = lan_mq_topic
  lan_msg = lan_mq_payload
  print(lan_msg)
  pass

lan.lan_init(18, 23, 19, 5, 0, 35)
print('Lan Init')
wait(1.5)
lan.mqtt_config('mqtt.m5stack.com', 1883, 'm5mqttid', '', '', 120)
print('Mqtt Configured')
wait(1.5)
lan.mqtt_connect()
print('Connect Server')
wait(1.5)
lan.mqtt_subscribe('m5stack/relay', module_lan_mqtt_cb, 0)
while True:
  lan.mqtt_publish('m5stack/relay', 'ON', 0)
  wait(1.5)
  lan.mqtt_poll_loop()
  if False:
    print('ON')
  else:
    print('OFF')
  wait_ms(2)
 

功能说明

lan.is_available_packet(1)

配置局域网 TCP 或 UDP 连接，指定套接字类型(如 TCP 或 UDP)、端口号和设备类型(如服务器或客户端)

lan.tcp_udp_config('', 0, 1, 1) 

通过指定的主题和 token 从服务器获取数据

lan.get_ezdata(ezdata_get_AlUvNcb, 'GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '')

异步获取EZData数据（需提供token和主题）

lan.remove_ezdata('GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '')

删除EZData云端数据

lan.set_ezdata('GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '', '', 0) 

保存数据到EZData云端（参数：token、主题、数据、超时时间）

req.text

获取HTTP请求返回的文本内容

lan.get_if_config()

获取当前网络接口配置（IP/掩码/网关/DNS）

req.status_code

获取HTTP请求状态码

try:
  req = lan.http_request(method='GET', url='', headers={})
  gc.collect()
  req.close()
except:
  pass 

发送HTTP请求（自动内存回收）

lan.lan_init(18, 23, 19, 5, 0, 35) 

初始化LAN模块（参数：RST/CS/INT/MOSI/MISO/SCLK引脚号）

lan.local_ip()

获取本地IP地址

lan.mqtt_is_connect()

检查MQTT连接状态

lan.mqtt_connect()

建立MQTT连接

lan.mqtt_disconnect()

断开MQTT连接

lan.mqtt_config('mqtt.m5stack.com', 1883, '', '', '', 120) 

配置MQTT参数（服务器/端口/用户名/密码/客户端ID/保活时间）

lan.mqtt_poll_loop()

MQTT消息轮询处理（需在循环中调用）

lan.mqtt_publish('', '', 0) 

MQTT消息发布（参数：主题/消息/QoS等级）

lan.mqtt_subscribe('', module_lan_mqtt_cb, 0)

订阅MQTT主题（带回调函数）

def module_lan_mqtt_cb(lan_mq_topic, lan_mq_payload):
  global ezdata_value1, lan_topic, lan_msg
  lan_topic = lan_mq_topic
  lan_msg = lan_mq_payload
  pass 

MQTT订阅回调函数模板

lan.remote_ip()

获取远程主机IP地址

lan.set_if_config('192.168.1.100', '255.255.255.0', '192.168.1.1', '8.8.8.8') 

手动设置网络接口（IP/掩码/网关/DNS）

lan.socket_close()

关闭当前socket连接

lan.tcp_receive_packet(0)

TCP接收数据包（参数：socket句柄）

lan.tcp_send_packet('1234')

TCP发送数据包

lan.udp_receive_packet(0)

UDP接收数据包（参数：socket句柄）

lan.udp_send_packet('', 0, '') 

UDP发送数据包（参数：目标IP/端口/数据）

Next UiFlow1 快速上手 - 1. UIFlow Web IDE 1.0

UiFlow1 快速上手

2. 固件烧录 & 程序推送

UiFlow1 开发指南

项目管理

使用 LTE 网络

UiFlow1 Blockly

Event

UI

Hardwares

Generic

Advanced

Unit