ESP8266 SDK开发: 网络篇-TCP服务器(LWIP,RAW模式,PCB控制块)

#include "lwip/api.h"
#include "lwip/err.h"
#include "lwip/ip_addr.h"
#include "lwip/dns.h"
#include "lwip/igmp.h"
#include "lwip/tcp.h"

err_t err = ERR_OK;//接收返回的错误信息

struct tcp_pcb *tcp_pcb1 = tcp_new();//建立一个TCP控制块

    //控制块绑定IP地址和端口号
    err = tcp_bind(tcp_pcb1, IP_ADDR_ANY, 8080);//IP_ADDR_ANY:绑定本模块IP  8080:绑定8080端口
    if (err == ERR_OK) {//没有错误
        struct tcp_pcb *pcb1 = tcp_listen(tcp_pcb1);//启动监听
    }

struct tcp_pcb *tcp_pcb_server;//定义一个TCP控制块

/**
* @brief   TCP接收数据
* @param   arg:tcp_arg函数传入的参数
* * @param   p:接收的数据缓存
* @param   err:错误信息
* @param   None
* @retval  None
* @warning None
* @example
**/
static err_t net_tcp_recv_cb(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err) {
    tcp_pcb_server = tpcb;

    if (!p || err!=ERR_OK) {
        if(p){
            pbuf_free(p);
        }
        tcp_close(tcp_pcb_server);//关闭连接
        return ERR_CLSD;
    }

    //固定处理
    tcp_recved(tcp_pcb_server, p->tot_len);/*更新接收,告诉底层可以接着缓存数据了*/
    pbuf_free(p);//释放链表
    return ERR_OK;
}


/**
* @brief   TCP链接错误
* @param   arg:tcp_arg函数传入的参数
* @param   err:错误信息
* @param   None
* @param   None
* @retval  None
* @warning None
* @example
**/
static void net_err_cb(void *arg, err_t err) {
    tcp_pcb_server = (struct tcp_pcb*)arg; //tcp_arg传递了该参数
    tcp_close(tcp_pcb_server);//关闭连接
    tcp_pcb_server = NULL;//清空
}

/**
* @brief   客户端连接回调
* @param   arg:tcp_arg函数传入的参数
* @param   newpcb:链接的TCP控制块
* @param   err:错误信息
* @param   None
* @retval  None
* @warning None
* @example
**/
static err_t net_accept_cb(void *arg, struct tcp_pcb *newpcb, err_t err) {
    tcp_pcb_server = newpcb;//赋值给定义的控制块

    tcp_arg(newpcb, newpcb);//传递的arg参数为 tcp_pcb_server
    tcp_err(newpcb, net_err_cb);//错误回调
    tcp_recv(newpcb, net_tcp_recv_cb);//接收数据回调

    printf("客户端连接 \n");
    return ERR_OK;
}

#define TcpServerBuffLen 1460
u8 TcpServerBuff[TcpServerBuffLen];//接收缓存

/**
* @brief   TCP接收数据
* @param   arg:tcp_arg函数传入的参数
* * @param   p:接收的数据缓存
* @param   err:错误信息
* @param   None
* @retval  None
* @warning None
* @example
**/
static err_t net_tcp_recv_cb(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err) {
    struct pbuf *q;
    u32 length = 0,i=0;

    tcp_pcb_server = tpcb;

    if (!p || err!=ERR_OK) {
        if(p){
            pbuf_free(p);
        }
        tcp_close(tcp_pcb_server);//关闭连接
        return ERR_CLSD;
    }

    //接收TCP数据(固定处理)
    for(q=p;q!=NULL;q=q->next)
    {
        if(q->len > (TcpServerBuffLen-length))//接收的数据个数大于了数组可以接收的数据个数
            memcpy(TcpServerBuff+length,q->payload,(TcpServerBuffLen-length));//只接收数组可以接收的数据个数
        else
            memcpy(TcpServerBuff+length,q->payload,q->len);//接收TCP所有数据
        length += q->len;
        if(length > TcpServerBuffLen) break;
    }


    /*串口输出接收的数据*/
    for(i=0;i<length;i++){
        uart_tx_one_char(UART0,TcpServerBuff[i]);
    }

    //固定处理
    tcp_recved(tcp_pcb_server, p->tot_len);/*更新接收,告诉底层可以接着缓存数据了*/
    pbuf_free(p);//释放链表

    return ERR_OK;
}