ESP8266-Arduino网络编程实例-异步TCP服务器

异步TCP服务器

本次实例将如何通过ESPAsyncTCP库实现一个简单的异步服务器。

实例主要由如下步骤组成：

WiFi连接
创建TCP服务器
注册客户连接回调函数。回调函数包含如下处理情形：
- 客户端数据处理
- 错误处理
- 连接断开处理
- 超时处理
启动TCP服务器

1、硬件准备

ESP8266 NodeMCU开发板一块
数据线一条

2、软件准备

Arduino IDE或VSCode + PlatformIO

在前面的文章中，对如何搭建ESP8266开发环境做了详细的介绍，请参考：

ESP8266 NodeMCU的引脚介绍在前面的文章中做了详细的介绍，请参考：

ESP8266-Arduino编程实例-认识ESP8266

3、代码实现

本次使用到的ESPAsyncTCp库下载地址如下：

https://github.com/me-no-dev/ESPAsyncTCP/archive/master.zip

第一步，导入依赖头文件

#include <ESP8266WiFi.h>
#include <ESPAsyncTCP.h>
#include <vector>

第二步，WiFi连接信息定义

#define SSID "你的WIFI名称"
#define PWD "你的WIFI密码"
#define TCP\_PORT 5050 // TCP端口
#define SERVER\_HOST\_NAME "esp8266\_server" // 主机名称

第三步，定义TCP连接客户端

1 2	static std::vector<AsyncClient\*> clients; // TCP客户端列表

第四步，TCP服务器回调函数定义

// 错误处理
static void handleError(void\* arg, AsyncClient\* client, int8\_t error) {
  Serial.printf("\n connection error %s from client %s \n", client->errorToString(error), client->remoteIP().toString().c\_str());
}

// 数据处理
static void handleData(void\* arg, AsyncClient\* client, void \*data, size\_t len) {
  Serial.printf("\n data received from client %s \n", client->remoteIP().toString().c\_str());
  Serial.write((uint8\_t\*)data, len);

  // reply to client
  if (client->space() > 32 && client->canSend()) {
    char reply[32];
    sprintf(reply, "this is from %s", SERVER_HOST_NAME);
    client->add(reply, strlen(reply));
    client->send();
  }
}

// 连接断开处理
static void handleDisconnect(void\* arg, AsyncClient\* client) {
  Serial.printf("\n client %s disconnected \n", client->remoteIP().toString().c\_str());
}

// 超时处理
static void handleTimeOut(void\* arg, AsyncClient\* client, uint32\_t time) {
  Serial.printf("\n client ACK timeout ip: %s \n", client->remoteIP().toString().c\_str());
}

// 处理服务器事件
static void handleNewClient(void\* arg, AsyncClient\* client) {
  Serial.printf("\n new client has been connected to server, ip: %s", client->remoteIP().toString().c\_str());

  // 添加到客户端列表
  clients.push\_back(client);
  
  // 注册事件处理函数
  client->onData(&handleData, NULL);
  client->onError(&handleError, NULL);
  client->onDisconnect(&handleDisconnect, NULL);
  client->onTimeout(&handleTimeOut, NULL);
}

第五步，在setup函数中连接WiFi和启动TCP服务器

void setup() {
  Serial.begin(74880); // 初始化串口
  delay(20);
  WiFi.begin(SSID, PWD); // 连接WIFI

   while (WiFi.status() != WL_CONNECTED){
        delay(500);
        Serial.print(".");
    }
    Serial.println();
	// 打印WiFi信息
    Serial.print("Connected\r\nIP address: ");
    Serial.println(WiFi.localIP());
    Serial.print("macAddress:");
    Serial.println(WiFi.macAddress());
    Serial.print("subnetMask:");
    Serial.println(WiFi.subnetMask());
    Serial.print("gatewayIP:");
    Serial.println(WiFi.gatewayIP());
  // 创建TCP服务器
  AsyncServer\* server = new AsyncServer(TCP_PORT);
  // 注册TCP服务器事件处理函数
  server->onClient(&handleNewClient, server);
    // 启动TCP服务器
  server->begin();
}