2. 程式人生 > 實用技巧 >ESP8266學習實戰之UdpClient與UdpSever(FreeRTOS)

ESP8266學習實戰之UdpClient與UdpSever(FreeRTOS)

阿新 • • 發佈：2020-07-22

Udpclient 任務流程

①判斷是否獲取ip地址

新建狀態變數

STATION_STATUS stastatus;

呼叫wifi介面，並判斷是否獲取IP地址

　　·do
        {
        stastatus = wifi_station_get_connect_status();
        vTaskDelay(100);
        }
    while (stastatus != STATION_GOT_IP)；

②建立Socket

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

③設定接收超時時間

int setsockopt（int sock，int level，int optname，void *optval，socklen to optlen ）；

sock：將要被設定或者獲取選項的套接字

level：選項所在的協議層

optname：需要訪問的選項名

optval：對於getsockopt()指向返回值的緩衝，對於setsockopt()指向包含新選項的緩衝。

optlen：對於getsockop()，作為入口引數時，選項值得最大長度；作為出口引數時，選項值得實際長度。對於setsockopt()，現選項的長度。

　　int NetTimeOut = 1000;
　　setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, &NetTimeOut, sizeof(int))

④賦值sever資訊

定義一個struct_sockaddr_in型別的變數並清空

struct sockaddr_in myaddr;

memset(&myaddr,0,sizeof(myaddr));

填充地址資訊

myaddr.sin_family = PF_INET;

myaddr.sin_port = htons(8888);

myaddr.sin_addr.s_addr = inet_addr("192.168.x.xxx");

將該變數強制轉換為struct sockaddr 型別在函式中使用

bind(listenfd,(struct sockaddr*)(&myaddr),sizeof(myaddr));

#define SEVERADDR "192.168.0.207"
#define SEVERPORT 8000

    struct sockaddr_in SeverAddr;
    memset(&SeverAddr,0,sizeof(SeverAddr));

    SeverAddr.sin_family = AF_INET;
    SeverAddr.sin_addr.s_addr = inet_addr(SEVERADDR);
    SeverAddr.sin_port = htons(SEVERPORT);
    SeverAddr.sin_len = sizeof(SeverAddr);

⑤傳送資料到sever端

ssize t send(int socket,const void *buffer,size t length,int flages);

ssize t sendto( int s,const void *data ,size t size ,int falges,const struct sockaddr *to,socklen t tolen);

標頭檔案：#include<sys/socket.h>

buffer:傳送緩衝區首地址

length：傳送位元組數

flages：傳送方式（通常為0）

    //傳送資料
    sendto(fd, "I am Udp", sizeof("I am Udp"), 0, (struct sockaddr *)&SeverAddr, (socklen_t)SeverAddr.sin_len);

⑥從sever端接收資料

　　　　　int ret;
　　　　　char udpmsg[48];


       do
            {
                 ret = recvfrom(fd, udpmsg, 48, 0, (struct sockaddr *)&SeverAddr, (socklen_t*)(&SeverAddr.sin_len));
                 vTaskDelay(100);
                 if(ret > 0)
                     {
                         printf("UdpSever:%s\n",udpmsg);
                     }
                 else
                     printf("UdpSever data is no\n");
             }
        while (ret == -1);

udpsever任務流程

直接複製SDK中的udpclient資料夾的所有檔案到新建資料夾udpsever中

在udpsever中新建udpsever.c和udpsever.h

將udpcline.c和udpcline.h中的程式碼分別複製到udpsever.c和udpsever.h中並修改標頭檔案以及函式名

修改sever地址

sever地址後新增

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

修改發射接收端

struct sockaddr from;
socklen_t fromlen = sizeof(struct sockaddr);


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

            //傳送返回資料
            sendto(fd, "I am UdpSever", sizeof("I am UdpSever"), 0, &from, fromlen);

        }
    vTaskDelete( NULL );

UDPClient原始碼：

//udpclient.c
#include "esp_common.h"
    
#include "freertos/FreeRTOS.h"
#include "freertos/task.h"
    
#include "lwip/sockets.h"
#include "lwip/dns.h"
#include "lwip/netdb.h"
#include "udpclient.h"

#define SEVERADDR "192.168.0.207"
#define SEVERPORT 8000

/******************************************************************************
 * FunctionName : ATaskUdpclient
 * Description  : ATaskUdpclient 任務
 * Parameters   : none
 * Returns      : none
*******************************************************************************/
void ATaskUdpclient(void *pvParameters)
{
    int iVariableExample = 0;
    int fd = -1;
    int NetTimeOut = 5000;
    int ret;
    char udpmsg[48];

    STATION_STATUS stastatus;
    
    struct sockaddr_in SeverAddr;
    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!");
            vTaskDelete(NULL);
        }
    
    setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, &NetTimeOut, sizeof(int));
    memset(&SeverAddr,0,sizeof(SeverAddr));

    SeverAddr.sin_family = AF_INET;
    SeverAddr.sin_addr.s_addr = inet_addr(SEVERADDR);
    SeverAddr.sin_port = htons(SEVERPORT);
    SeverAddr.sin_len = sizeof(SeverAddr);
    for(;;)
        {
            //傳送資料
            sendto(fd, "I am Udp", sizeof("I am Udp"), 0, (struct sockaddr *)&SeverAddr, (socklen_t)SeverAddr.sin_len);
            do
                {
                    ret = recvfrom(fd, udpmsg, 48, 0, (struct sockaddr *)&SeverAddr, (socklen_t*)(&SeverAddr.sin_len));
                    vTaskDelay(100);
                    if(ret > 0)
                        {
                            printf("UdpSever:%s\n",udpmsg);
                        }
                    else
                        printf("UdpSever data is no\n");
                }
            while (ret == -1);
        
            
        }
    vTaskDelete( NULL );
}

/******************************************************************************
 * FunctionName : Udpclient_init
 * Description  : Udpclient_init 初始化
 * Parameters   : none
 * Returns      : none
*******************************************************************************/
void Udpclient_init(void)
{
    xTaskCreate(ATaskUdpclient, "Udpclient", 256, NULL, 4 , NULL);
}

//udpclient.h
#ifndef __UART_H__
#define __UART_H__

#ifdef __cplusplus
extern "C" {
#endif

void ATaskUdpclient(void *pvParameters);
void Udpclient_init(void);

#ifdef __cplusplus
}
#endif

#endif

UDPSever原始碼：

//udpsever.c
#include "esp_common.h"
    
#include "freertos/FreeRTOS.h"
#include "freertos/task.h"
    
#include "lwip/sockets.h"
#include "lwip/dns.h"
#include "lwip/netdb.h"
#include "udpsever.h"

#define SEVERADDR "192.168.0.207"
#define SEVERPORT 8000

/******************************************************************************
 * FunctionName : ATaskUdpsever
 * Description  : ATaskUdpsever 任務
 * Parameters   : none
 * Returns      : none
*******************************************************************************/
void ATaskUdpsever(void *pvParameters)
{
    int iVariableExample = 0;
    int fd = -1;
    int NetTimeOut = 5000;
    int ret;
    char udpmsg[48];

    STATION_STATUS stastatus;
    
    struct sockaddr_in SeverAddr;
    struct sockaddr from;
    socklen_t fromlen = sizeof(struct sockaddr);
    
    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!");
            vTaskDelete(NULL);
            return;
        }
    
    setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, &NetTimeOut, sizeof(int));
    memset(&SeverAddr,0,sizeof(SeverAddr));

    SeverAddr.sin_family = AF_INET;
    SeverAddr.sin_addr.s_addr = INADDR_ANY;
    SeverAddr.sin_port = htons(SEVERPORT);
    SeverAddr.sin_len = sizeof(SeverAddr);

    if(bind(fd,(struct sockaddr*)&SeverAddr,SeverAddr.sin_len) != 0)
        {
            printf("bind socket fail!\n");
            vTaskDelete(NULL);
            return;
        }
    
    for(;;)
        {
            do
                {
                    ret = recvfrom(fd, udpmsg, 48, 0, &from, &fromlen);
                    vTaskDelay(100);
                    if(ret > 0)
                        {
                            printf("UdpClient:%s\n",udpmsg);
                        }
                    else
                        printf("UdpClient data is Null\n");
                }
            while (ret == -1);
        
            

            //傳送資料
            sendto(fd, "I am UdpSever", sizeof("I am UdpSever"), 0, &from, fromlen);

        }
    vTaskDelete( NULL );
}

/******************************************************************************
 * FunctionName : Udpsever_init
 * Description  : Udpsever_init 初始化
 * Parameters   : none
 * Returns      : none
*******************************************************************************/
void Udpsever_init(void)
{
    xTaskCreate(ATaskUdpsever, "Udpsever", 256, NULL, 4 , NULL);
}

//udpsever.h
#ifndef __UDPSEVER_H__
#define __UDPSEVER_H__

#ifdef __cplusplus
extern "C" {
#endif

void ATaskUdpsever(void *pvParameters);
void Udpsever_init(void);

#ifdef __cplusplus
}
#endif

#endif

相關推薦

ESP8266學習實戰之UdpClient與UdpSever(FreeRTOS)

Udpclient 任務流程 ①判斷是否獲取ip地址 新建狀態變數 STATION_STATUS stastatus; 呼叫wifi介面，並判斷是否獲取IP地址

ES6學習筆記之let與const用法例項分析

本文例項講述了ES6學習筆記之let與const用法。分享給大家供大家參考，具體如下：

機器學習實戰之決策樹學習筆記

from math import log import operator def calcShannonEnt(dataSet): numEntries=len(dataSet)#計算資料集例項總數

C++學習筆記之 初識與概述

概述 C++ = C + 面向物件程式設計 + 泛型程式設計 C語言是面向過程的，C++是面向物件的

機器學習實戰之K-近鄰演算法

一、K-近鄰演算法概念 1、書上概念： K-近鄰演算法採用不同特徵值之間的距離的方法進行分類

機器學習實戰之決策樹

一、決策樹概念 1、概念以及適用場景 概念： 決策樹(decision tree)是一類常見的機器學習方法。

機器學習實戰 | SKLearn入門與簡單應用案例

作者：韓信子@ShowMeAI教程地址：http://www.showmeai.tech/tutorials/41本文地址：http://www.showmeai.tech/article-detail/202

深度學習實戰之手寫簽名識別（100%準確率、語音播報）

手寫簽名在日常生活中隨處可見，簡單來說就是親筆書寫自己的名字，在紙質文件上使用手寫簽名主要用以確定簽字者的身份，並表示簽字者同意所簽署文件中規定的內容，對文件的真實性負責，且具有法律效力。由此看見手寫

深度學習實戰之垃圾分類

垃圾分類，指按一定規定或標準將垃圾分類儲存、分類投放和分類搬運，從而轉變成公共資源的一系列活動的總稱。分類的目的是提高垃圾的資源價值和經濟價值，力爭物盡其用；然而我們在日常生活中認為對垃圾分類還是有些

Spring實戰之抽象Bean和子Bean定義與用法示例

本文例項講述了Spring實戰之抽象Bean和子Bean定義與用法。分享給大家供大家參考，具體如下：

React學習之JSX與react事件例項分析

本文例項講述了React學習之JSX與react事件。分享給大家供大家參考，具體如下：

C++ STL學習筆記之：佇列（queue）、雙端佇列（deque）與棧（stack）

queue（佇列） 定義一個名為 que 的儲存 int 型別元素的佇列： queue<int> que; 入隊操作：

Java學習之繼承與抽象篇

Java學習之繼承與抽象篇 0x00 前言 前面講到了面向物件，面向物件的三大特性是封裝、繼承、多型。那麼這次就來講講繼承。

Java學習之介面與多型篇

Java學習之介面與多型篇 0x00 前言 在前面寫的幾篇文章裡，講了封裝和繼承，那麼這篇文章就來講講第三大面向物件的特性多型吧，在此之前先接著上篇文章的抽象先來看看Java裡面介面的應用。

Java學習之final與匿名內部類

Java學習之final與匿名內部類 0x00 前言 續上幾篇文章，得知子類繼承父類後是可以在父類的基礎上進行改寫的，那麼在程式中有些東西可能是不能讓我們給輕易給改動的，那麼Java給提供了final關鍵字。

.Net微服務實戰之Kubernetes的搭建與使用

系列文章 .Net微服務實戰之技術選型篇 .Net微服務實戰之技術架構分層篇 .Net微服務實戰之DevOps篇

微服務學習實戰筆記 4.3-系統部署篇-Nginx Ingress的安裝與配置

一、Nginx Ingress介紹 Kubernetes關於服務的暴露主要是通過NodePort方式，通過繫結主機的某個埠,然後進行pod的請求轉發和負載均衡，但這種方式下缺陷是Service可能有很多個，如果每個都繫結一個node主機埠的話，主機

OpenCV與影象處理實戰之車道線檢測！無人駕駛第一步！

一、效果展示 對車輛所在車道的車道線檢測效果： ​ 二、基本思路 如下圖所示，實現車道線的基本流程如下：

ceph學習筆記之五 Pool與對映過程

Pool Pool是一個抽象的儲存池，它規定了資料冗餘的型別以及對應的副本分佈策略。目前實現了兩種Pool型別：

學習記錄之 標頭檔案內函式與函式命名衝突問題查詢並解決

由於初學C語言，總是習慣將#include<stdio.h>、#include<stdlib.h>、#include<math.h>置於程式開始位置，在編寫本程式時，可以看到max處提示錯誤，檢查很久也沒有發現執行錯誤原因。無意