Wi-Fi 模块开发快速入门

import network

# 创建 Wi-Fi 网卡，并设置为 STATION 模式
nic = network.WLAN(network.STA_MODE)
print('- Created a Wi-Fi NIC.')

# 定义 Wi-Fi 事件回调函数
def wifi_event_cb(event):
    # 打印事件信息
    print("- Event:\r\n   ", event)

    # 当获取到 IP 地址时，打印 IP 地址相关信息
    if event['id'] == 3305:
        print("- Got IP:\r\n   ", nic.ifconfig())

# 设置事件回调函数
nic.config(event_callback = wifi_event_cb)

# 连接热点
SSID = "Quectel-Customer-2.4G"
PASSWD = "Customer-Quectel"
print('- Connecting to', SSID)
nic.connect(ssid = SSID, password = PASSWD)

- Created a Wi-Fi NIC.
- Connecting to Quectel-Customer-2.4G
- Event:
    {'msg': None, 'type': 3300, 'id': 3301}
- Event:
    {'msg': {'password': 'Customer-Quectel', 'ssid': 'Quectel-Customer-2.4G', 'rssi': -62, 'channel': 1, 'bssid': 'a4:00:e2:ef:f7:80', 'auth': 4, 'cipher': 4}, 'type': 3300, 'id': 3302}
- Event:
    {'msg': ('10.66.117.73', '255.255.252.0', '10.66.116.1', '0.0.0.0', '0.0.0.0'), 'type': 3300, 'id': 3305}
- Got IP:
    ('10.66.117.73', '255.255.252.0', '10.66.116.1', '211.138.180.2', '114.114.114.114')

import network

# 创建 Wi-Fi 网卡，并设置为 AP 模式
nic = network.WLAN(network.AP_MODE)
print('- Created a Wi-Fi NIC.')

# 定义 Wi-Fi 事件回调函数
def wifi_event_cb(event):
    if event['id'] == 3201: # 热点创建成功
        print("- AP is created successfully.")
    elif event['id'] == 3202: # 热点创建失败
        print("- AP is created failed.")
    elif event['id'] == 3203: # 接入了设备连接
        print("- AP accepted a device joining.")
    elif event['id'] == 3204: # 与接入的设备断开连接
        print("- AP disconnected from a joined device.")
    elif event['id'] == 3205: # 为接入的设备分配了 IP 地址
        print("- AP assigned IP address to the joined device.")
    else:
        print("- Other event occured.")

    # 打印事件信息
    print("    Event:", event)

# 设置事件回调函数
nic.config(event_callback = wifi_event_cb)

# 设置热点名称和密码
# 如果不设置热点名称和密码，则默认的热点名称和密码均为: quecpython
SSID = "QuecPython_SoftAP"
PASSWD = "12345678"
print("- Will create a AP:")
print("    SSID:", SSID)
print("    PASSWD:", PASSWD)
nic.config(ap_ssid = SSID, ap_password = PASSWD)

# 激活网卡，触发热点的产生
nic.active(True)

- Created a Wi-Fi NIC.
- Will create a AP:
    SSID: QuecPython_SoftAP
    PASSWD: 12345678
- AP is created successfully.
    Event: {'msg': None, 'type': 3200, 'id': 3201}
- AP accepted a device joining.
    Event: {'msg': {'mac': 'd6:d7:f0:b0:a3:bf', 'aid': 1}, 'type': 3200, 'id': 3203}
- AP assigned IP address to the joined device.
    Event: {'msg': {'ip': '10.10.10.2', 'aid': 1, 'mac': 'd6:d7:f0:b0:a3:bf'}, 'type': 3200, 'id': 3205}
- AP disconnected from a joined device.
    Event: {'msg': {'ip': '10.10.10.2', 'aid': 1, 'mac': 'd6:d7:f0:b0:a3:bf'}, 'type': 3200, 'id': 3204}

import network
from queue import Queue

# 创建消息队列
msg_q = Queue(8)

# 创建 Wi-Fi 网卡，并设置为 STATION 模式
nic = network.WLAN(network.STA_MODE)
print('- Created a Wi-Fi NIC.')

# 设置为非阻塞模式
nic.config(block = False)

# 定义 Wi-Fi 事件回调函数
def wifi_event_cb(event):
    # 打印事件信息
    print("- Event:", event)

    # 发送消息到队列
    msg_q.put(event)

# 设置事件回调函数
nic.config(event_callback = wifi_event_cb)

# 连接热点
SSID = "Quectel-Customer-2.4G"
PASSWD = "Customer-Quectel"
print('- Connecting to', SSID)
nic.connect(ssid = SSID, password = PASSWD)

# TCP 客户端函数
def tcp_echo_client(server_addr, server_port):
    pass

while True:
    # 等待队列中的消息
    event = msg_q.get()

    if event['id'] == 3302: # 成功连接到热点
        print("- Connected to AP.")
    elif event['id'] == 3305: # 当获取到 IP 地址时，打印 IP 地址相关信息，并启动 TCP 客户端
        print("- Got IP:", nic.ifconfig())
        print("- Start TCP client.")
        # TCP 服务器的地址和端口分别为 `192.0.2.2` 和 `8305`
        tcp_echo_client('192.0.2.2', 8305)

def tcp_echo_client(server_addr, server_port):
    import usocket
    import utime

    # DNS 解析
    print('- DNS resolving for', server_addr, ":", server_port)
    addr = usocket.getaddrinfo(server_addr, server_port)[0][-1]

    # 创建 socket 对象
    sock = usocket.socket(usocket.AF_INET, usocket.SOCK_STREAM, usocket.IPPROTO_TCP)
    print('- Socket object created.')

    # 连接服务器
    print('- Connecting to', addr)
    sock.connect(addr)
    print('- TCP link established.')

    # 数据收发
    for i in range(10):
        data = "Hello world!"
        sock.send(data)
        print("- - C --> S:", data)

        data = sock.recv(1024)
        print("- - S --> C:", data)

        utime.sleep(1)

    # 断开连接
    sock.close()
    print('- TCP link disconnected.')

- Created a Wi-Fi NIC.
- Connecting to Quectel-Customer-2.4G
- Event: {'msg': None, 'type': 3300, 'id': 3301}
- Event: {'msg': {'password': 'Customer-Quectel', 'ssid': 'Quectel-Customer-2.4G', 'rssi': -61, 'channel': 1, 'bssid': 'a4:00:e2:ef:f7:80', 'auth': 4, 'cipher': 4}, 'type': 3300, 'id': 3302}
- Connected to AP.
- Event: {'msg': ('10.66.117.73', '255.255.252.0', '10.66.116.1', '0.0.0.0', '0.0.0.0'), 'type': 3300, 'id': 3305}
- Got IP: ('10.66.117.73', '255.255.252.0', '10.66.116.1', '211.138.180.2', '114.114.114.114')
- Start TCP client.
- DNS resolving for 192.0.2.2 : 8305
- Socket object created.
- Connecting to ('192.0.2.2', 8305)
- TCP link established.
- C --> S: Hello world!
- S --> C: b'Hello world!'
- C --> S: Hello world!
- S --> C: b'Hello world!'
- C --> S: Hello world!
- S --> C: b'Hello world!'
- C --> S: Hello world!
- S --> C: b'Hello world!'
- C --> S: Hello world!
- S --> C: b'Hello world!'
- C --> S: Hello world!
- S --> C: b'Hello world!'
- C --> S: Hello world!
- S --> C: b'Hello world!'
- C --> S: Hello world!
- S --> C: b'Hello world!'
- C --> S: Hello world!
- S --> C: b'Hello world!'
- C --> S: Hello world!
- S --> C: b'Hello world!'
- TCP link disconnected.

import network
from queue import Queue

# 创建消息队列
msg_q = Queue(8)

# 创建 Wi-Fi 网卡，并设置为 AP 模式
nic = network.WLAN(network.AP_MODE)
print('- Created a Wi-Fi NIC.')

# 设置为非阻塞模式
nic.config(block = False)

# 定义 Wi-Fi 事件回调函数
def wifi_event_cb(event):
    # 打印事件信息
    print("- Event:", event)

    # 发送消息到队列
    msg_q.put(event)

# 设置事件回调函数
nic.config(event_callback = wifi_event_cb)

# 设置热点名称和密码
# 如果不设置热点名称和密码，则默认的热点名称和密码均为: quecpython
SSID = "QuecPython_SoftAP"
PASSWD = "12345678"
print("- Will create a AP:")
print("    SSID:", SSID)
print("    PASSWD:", PASSWD)
nic.config(ap_ssid = SSID, ap_password = PASSWD)

# 激活网卡，触发热点的产生
nic.active(True)

# TCP 服务器函数
def tcp_echo_server(server_addr, server_port):
    pass

while True:
    # 等待队列中的消息
    event = msg_q.get()

    if event['id'] == 3201: # 热点创建成功
        print("- AP is created successfully.")
        print("- Start TCP server.")
        # 读取模块本地的 IP 地址
        local_addr = nic.ifconfig()[0]
        # 启动 TCP 服务器
        tcp_echo_server(local_addr, 8080)
    elif event['id'] == 3202: # 热点创建失败
        print("- AP is created failed.")
    elif event['id'] == 3203: # 接入了设备连接
        print("- AP accepted a device joining.")
    elif event['id'] == 3204: # 与接入的设备断开连接
        print("- AP disconnected from a joined device.")
    elif event['id'] == 3205: # 为接入的设备分配了 IP 地址
        print("- AP assigned IP address to the joined device.")
    else:
        print("- Other event occured.")

def tcp_echo_server(server_addr, server_port):
    import usocket
    import _thread

    # 服务器与每一个客户端连接的处理线程
    def _client_conn_proc(conn, ip_addr, port):
        while True:
            try:
                # 接收客户端发送的数据
                data = conn.recv(1024)
                print('- Recv data: [client addr: %s, %s]:' % (ip_addr, port), data)

                # 将数据回发给客户端
                conn.send(data)
            except:
                # 出现异常，关闭连接
                print('- Disconnected from client: %s, %s' % (ip_addr, port))
                conn.close()
                break

    # 创建 socket 对象
    sock = usocket.socket(usocket.AF_INET, usocket.SOCK_STREAM, usocket.IPPROTO_TCP_SER)
    print('- Socket object created.')

    # 绑定服务器端口与地址
    sock.bind((server_addr, server_port))
    print('- Bind address: %s, %s' % (server_addr, server_port))

    # 监听客户端连接请求
    sock.listen(10)
    print('- Start listening ...')

    while True:
        # 等待接受客户端连接
        cli_conn, cli_ip_addr, cli_port = sock.accept()
        print('- Accept a client: %s, %s' % (cli_ip_addr, cli_port))

        # 为每一个客户端连接创建一个新线程
        _thread.start_new_thread(_client_conn_proc, (cli_conn, cli_ip_addr, cli_port))