ESP8266模組的UDP編程

ESP8266 模組的 UDP 編程

使用 UDP 協(xié)議通訊時(shí)服務(wù)器端和客戶端無需建立連接，只要知道對方套接字的地址信息，就可以發(fā)送數(shù)據(jù)。 服務(wù)器端只需創(chuàng)建一個(gè)套接字用于接收不同客戶端發(fā)來的請求，經(jīng)過處理后再把結(jié)果發(fā)送給對應(yīng)的客戶端。 服務(wù)器端和客戶端使用 UDP 的流程如下圖示：

UDP 編程包括 Client 和 Server 編程，下面將介紹如何使用 ESP8266 SDK 開發(fā) UDP 通信的客戶端和服務(wù)端

1. UDP Client 編程

UDP Client 要實(shí)現(xiàn)的功能：

• PC模擬UDP Server，指定IP和Port，等待Client數(shù)據(jù)
• UDP 客戶端向服務(wù)器發(fā)送 I am Client ！
• Server收到數(shù)據(jù)后，向Client發(fā)送I am Server ！

UDP Client 任務(wù)流程如下示：

實(shí)現(xiàn)步驟如下：

在ESP8266_RTOS_SDK目錄下新建 udpclient 文件夾，把station實(shí)驗(yàn)中的 station 目錄下所有文件拷貝到該文件夾中

在user目錄下新建udpclient.c文件，并添加如下代碼

/*******************udpclient.c******************************************/
#define SERVERADDR "192.168.191.25"//PC端IP地址，確保與ESP8266在同一無線網(wǎng)中
#define SERVERPORT 8000  //
//ATaskUdpClient任務(wù)
void ATaskUdpClient( void *pvParameters ){
    int iVariableExample = 0;
    int fd = -1;
    int NetTimeOnt = 5000;
    int ret;
    struct sockaddr_in ServerAddr;
    char udpmsg[48];
    STATION_STATUS StaStatus;
    do{
        StaStatus = wifi_station_get_connect_status();
        vTaskDelay(100);
    }while(StaStatus != STATION_GOT_IP);

    fd = socket(PF_INET,SOCK_DGRAM,0);
    if(fd == -1){
        printf("get socket fail!\\n");
        vTaskDelete(NULL);
    }

    setsockopt(fd,SOL_SOCKET,SO_RCVTIMEO,&NetTimeOnt,sizeof(int));
    memset(&ServerAddr,0,sizeof(ServerAddr));
    ServerAddr.sin_family = AF_INET;
    ServerAddr.sin_addr.s_addr = inet_addr(SERVERADDR);
    ServerAddr.sin_port = htons(SERVERPORT);
    ServerAddr.sin_len = sizeof(ServerAddr);

    for(;;){
        sendto(fd,"I am UdpClient!",sizeof("I am UdpClient!"), 0,\\
(struct sockaddr *)&ServerAddr,(socklen_t)ServerAddr.sin_len);
do{
            ret =recvfrom(fd,udpmsg,48,0,\\
(struct sockaddr *)&ServerAddr,(socklen_t*)(&ServerAddr.sin_len));
if(ret >0){
printf("UdpServer:%s\\n",udpmsg);
}
else{
printf("UdpServer data is no!\\n");
}
}while(ret ==-1);
}
vTaskDelete(NULL);
}
//UdpClient_init初始化
voidUdpClient_init(void){
xTaskCreate(ATaskUdpClient,"UdpClient",256,NULL,4,NULL);
}

在include目錄下新建udpclient.h文件，并添加聲明

void ATaskUdpClient( void *pvParameters );
void UdpClient_init(void);

在user_main.c文件中的user_init()函數(shù)下添加如下代碼

#define SSID "Hotspot"			//PC端和ESP8266要加入的無線網(wǎng)
#define PASSWORD "88888888"		
void ICACHE_FLASH_ATTR
user_init(void){
    printf("SDK version:%s\\n", system_get_sdk_version());
    Led_init();
    wifi_set_opmode(STATION_MODE);
    struct station_config *config = (struct station_config *)\\
        zalloc(sizeof(struct station_config));
    sprintf(config->ssid,SSID);
    sprintf(config->password,PASSWORD);
    wifi_station_set_config(config);
    free(config);
    wifi_station_set_auto_connect(TRUE);    
    UdpClient_init();
    xTaskCreate(ATaskLed, "LED", 256, NULL, 2, NULL);
}

code在ESP8266編譯器中編譯完成，燒寫bin文件到ESP8266，打開串口助手，建立UDP服務(wù)器，模組復(fù)位后，即可與UDP服務(wù)器建立連接

2. UDP Server 編程

UDP Server 要實(shí)現(xiàn)的功能：

• PC模擬UDP Client，指定UDP Server 的IP和Port，發(fā)送I am Client!
• Server收到數(shù)據(jù)后，向Client發(fā)送I am Server！

UDP Server 任務(wù)流程如下示：

實(shí)現(xiàn)步驟如下：

在ESP8266_RTOS_SDK目錄下新建 udpserver 文件夾，把station實(shí)驗(yàn)中的 station 目錄下所有文件拷貝到該文件夾中

在 user 目錄下新建 udpserver.c 文件，并添加如下代碼

/*******************udpserver.c***********************************************/
#define SERVERADDR "192.168.191.29"	//esp8266連上WiFi后的IP地址
#define SERVERPORT 8000
//ATaskUdpServer任務(wù)
void ATaskUdpServer( void *pvParameters ){
    int iVariableExample = 0;
    int fd = -1;
    int NetTimeOnt = 5000;
    int ret;
    struct sockaddr_in ServerAddr;
    struct sockaddr from;
    socklen_t fromlen = sizeof(struct sockaddr);
    char udpmsg[48];
    STATION_STATUS StaStatus;
    do{
        StaStatus = wifi_station_get_connect_status();
        vTaskDelay(100);
    }while(StaStatus != STATION_GOT_IP);

    fd = socket(PF_INET,SOCK_DGRAM,0);
    if(fd == -1){
        printf("get socket fail!\\n");
        vTaskDelete(NULL);
        return;
    }

    setsockopt(fd,SOL_SOCKET,SO_RCVTIMEO,&NetTimeOnt,sizeof(int));
    memset(&ServerAddr,0,sizeof(ServerAddr));
    ServerAddr.sin_family = AF_INET;
    ServerAddr.sin_addr.s_addr = INADDR_ANY;
    ServerAddr.sin_port = htons(SERVERPORT);
    ServerAddr.sin_len = sizeof(ServerAddr);

    if(bind(fd,(struct sockaddr*)&ServerAddr,ServerAddr.sin_len) != 0){   
        printf("bind socket fail!\\n");
        vTaskDelete(NULL);
        return;
    }

    for(;;){
        do{
            ret = recvfrom(fd,udpmsg,48,0,&from,&fromlen);
            if(ret > 0){
                printf("UdpClient:%s\\n",udpmsg);
            }
            else{
                printf("UdpClient data is no!\\n");
            }
         }while(ret == -1);

        sendto(fd,"I am UdpServer!",sizeof("I am UdpServer!"),\\
               0,&from,fromlen);      
    }
    vTaskDelete( NULL );
}
//UdpServer_init初始化
void UdpServer_init(void){
    xTaskCreate(ATaskUdpServer, "UdpServer", 256, NULL, 4, NULL);
}

在 include 目錄下新建 udpserver.h 文件，并添加聲明

void ATaskUdpServer( void *pvParameters );
void UdpServer_init(void);

在 user_main.c 文件中的 user_init() 函數(shù)下添加如下代碼

#define SSID "Hotspot"			//PC端和ESP8266要加入的無線網(wǎng)
#define PASSWORD "88888888"	
user_init(void){
    printf("SDK version:%s\\n", system_get_sdk_version());
    Led_init();
    wifi_set_opmode(STATION_MODE);
    struct station_config *config = (struct station_config *)\\
        zalloc(sizeof(struct station_config));
    sprintf(config->ssid,SSID);
    sprintf(config->password,PASSWORD);
    wifi_station_set_config(config);
    free(config);
    wifi_station_set_auto_connect(TRUE);    
    UdpServer_init();
    xTaskCreate(ATaskLed, "LED", 256, NULL, 2, NULL);
}

在ESP8266編譯器中編譯完成，燒寫bin文件到ESP8266，打開串口助手，建立UDPclient，模組復(fù)位后，即可與UDP客戶端建立連接