Linux之UDP協(xié)議及其編程全流程

更新時間：2023年03月23日 14:30:44 作者：Dutkig

這篇文章主要介紹了Linux之UDP協(xié)議及其編程全流程，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

UDP協(xié)議的特點

UDP 不提供可靠性的傳輸，它只是把應(yīng)用程序傳給 IP 層的數(shù)據(jù)報發(fā)送出去，但是并不能保證它們能到達(dá)目的地。

由于 UDP 在傳輸數(shù)據(jù)報前不用在客戶和服務(wù)器之間建立一個連接，且沒有超時重發(fā)等機制，故而傳輸速度很快。

無連接
不可靠
數(shù)據(jù)報服務(wù)

UDP發(fā)出的數(shù)據(jù)包不經(jīng)過確認(rèn)，可以繼續(xù)發(fā)送。發(fā)送成功與否都不管，盡最大能力去發(fā)送，丟包也不負(fù)責(zé)。有自己的使用特點：適合于做視頻（實時性）適合于即使丟包了，處理起來也比較方便。

適合于攝像頭以恒定速率發(fā)，對方以恒定速率收，丟包了繼續(xù)發(fā)，可以實時。

但是如果是TCP，如果丟包，會重發(fā)，時間花銷大了，不能實時。不適合做攝像頭和視頻。

UDP的編程流程

UDP接口原型

接收

int recvfrom(int sockfd,void *buf,size_t size,int flag,struct sockaddr *peer_addr,socklen_t *addr_len);

peer_addr：用來保存recvfrom接收到的數(shù)據(jù)是來自哪臺主機的地址信息
addr_len：地址結(jié)構(gòu)的長度

發(fā)送

int sendto(int sockfd,void *buf,size_t size,int flag,struct sockaddr *peer_addr,socklen_t addr_len);

peer_addr：用來指定數(shù)據(jù)的接收方的地址信息
addr_len：地址信息的長度

示例代碼

UDP服務(wù)器端

#include<stdio.h>
#include<stdlib.h>
#include<assert.h>
#include<string.h>
#include<unistd.h>

#include<sys/socket.h>
#include<sys/types.h>
#include<arpa/inet.h>
#include<netinet/in.h>

int main()
{
    //SOCK_DGRAM表示使用的是UDP協(xié)議
    int sockfd = socket(AF_INET,SOCK_DGRAM,0);
    assert(sockfd != -1);

    struct sockaddr_in ser_addr;
    memset(&ser_addr,0,sizeof(ser_addr));
    ser_addr.sin_family = AF_INET;
    //將主機字節(jié)序轉(zhuǎn)化為網(wǎng)絡(luò)字節(jié)序
    ser_addr.sin_port = htons(6000);
    //將點分十進(jìn)制的地址字符串轉(zhuǎn)為unit32類型的值
    ser_addr.sin_addr.s_addr = inet_addr("192.168.246.128");

    int res = bind(sockfd,(struct sockaddr*)&ser_addr,sizeof(ser_addr));
    assert(res != -1);

    //循環(huán)接受不同客戶端的數(shù)據(jù)
    while(1)
    {
        char buff[128] = {0};

        struct sockaddr_in cli_addr;
        socklen_t cli_len = sizeof(cli_addr);
        int n = recvfrom(sockfd,buff,127,0,(struct sockaddr*)&cli_addr,&cli_len);
        if(n <= 0)
        {
            break;            
        }

        printf("%s:%d -- %s\n",inet_ntoa(cli_addr.sin_addr),ntohs(cli_addr.sin_port),buff);   
     
        n = sendto(sockfd,"OK",2,0,(struct sockaddr*)&cli_addr,cli_len);
        if(n <= 0)
        {
            break;
        }
    }

    close(sockfd);
    exit(0);
}

UDP客戶端

#include<stdio.h>
#include<stdlib.h>
#include<assert.h>
#include<string.h>
#include<unistd.h>

#include<sys/socket.h>
#include<sys/types.h>
#include<arpa/inet.h>
#include<netinet/in.h>

int main()
{
    int sockfd = socket(AF_INET,SOCK_DGRAM,0);
    assert(sockfd != -1);

    struct sockaddr_in ser_addr;
    memset(&ser_addr,0,sizeof(ser_addr));
    ser_addr.sin_family = AF_INET;
    ser_addr.sin_port = htons(6000); 
    ser_addr.sin_addr.s_addr = inet_addr("192.168.246.128");

    while(1)
    {
        printf("請輸入：");
        char buff[128] = {0};
        fgets(buff,127,stdin);

        if(strncmp(buff,"end",3) == 0)
        {
            break;
        }

        int n = sendto(sockfd,buff,strlen(buff),0,(struct sockaddr*)&ser_addr,sizeof(ser_addr));
        if(n <= 0)
        {
            break;
        }

        memset(buff,0,128);

        int m = recvfrom(sockfd,buff,127,0,NULL,NULL);//服務(wù)器地址信息已知，無需保存直接傳入NULL
        if(m <= 0)
        {
            break;
        }
        printf("%s\n",buff);
    }   

    close(sockfd); 

    exit(0);
}

兩個客戶端同時向服務(wù)器端發(fā)送信息