1. 程式人生 > >Linux UDP

Linux UDP

可能 bsp 修改內核 mage errno 一個 ech 服務端 bbb

UDP的特點

無連接 直接發發發

基於消息的數據傳輸服務 , 因此不存在TCP的粘包問題,但是存在丟包問題

不可靠。

一般情況下UDP更加高效

技術分享圖片

UDP註意點

UDP報文可能會丟失、重復

UDP報文可能會亂序

UDP缺乏流量控制

udp緩沖區寫滿以後,沒有流量控制機制,會覆蓋緩沖區。

UDP協議數據報文截斷

如果接收到的數據報,大於緩沖區;報文可以被截斷;後面的部分會丟失。

recvfrom返回0,不代表連接關閉,因為udp是無連接的。

sendto可以發送數據0包。。。只含有udp頭部。

一個小的DEMO

技術分享圖片
// server.c
#include <unistd.h>
#include 
<sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <stdlib.h> #include <stdio.h> #include <errno.h> #include <string.h> #define ERR_EXIT(m) do { perror(m); exit(EXIT_FAILURE); } while(0
) void echo_srv(int sock) { char recvbuf[1024] = {0}; struct sockaddr_in peeraddr; socklen_t peerlen; int n; while (1) { peerlen = sizeof(peeraddr); bzero(recvbuf, sizeof(recvbuf)); n = recvfrom(sock, recvbuf, sizeof(recvbuf), 0
, (struct sockaddr*)&peeraddr, &peerlen); if (n == -1) { if (errno == EINTR) continue; ERR_EXIT("recvfrom"); } else if (n > 0) { int ret = 0; fputs(recvbuf, stdout); //註意sendto需要指定對方的地址 ret = sendto(sock, recvbuf, n, 0, (struct sockaddr*)&peeraddr, peerlen); printf("ret :%d\n", ret); } } close(sock); } int main(void) { int sock; if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) < 0) ERR_EXIT("socket"); struct sockaddr_in servaddr; memset(&servaddr, 0, sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_port = htons(8001); servaddr.sin_addr.s_addr = htonl(INADDR_ANY); if (bind(sock, (struct sockaddr*)&servaddr, sizeof(servaddr)) < 0) ERR_EXIT("bind"); echo_srv(sock); return 0; }
View Code 技術分享圖片
// client.c
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>

#define ERR_EXIT(m)     do     {             perror(m);             exit(EXIT_FAILURE);     } while(0)

void echo_cli(int sock)
{
    struct sockaddr_in servaddr;
    memset(&servaddr, 0, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_port = htons(8001);
    servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");

    int ret;
    char sendbuf[1024] = {0};
    char recvbuf[1024] = {0};
    while (fgets(sendbuf, sizeof(sendbuf), stdin) != NULL)
    {        
        //sendto第一次發送的時候,會綁定地址
        sendto(sock, sendbuf, strlen(sendbuf), 0, (struct sockaddr*)&servaddr, sizeof(servaddr));
        /*sendto(sock, sendbuf, strlen(sendbuf), 0, NULL, 0);*/
        
        //send(sock, sendbuf, strlen(sendbuf), 0);
        ret = recvfrom(sock, recvbuf, sizeof(recvbuf), 0, NULL, NULL);
        if (ret == -1)    
        {
            if (errno == EINTR) 
                continue;
            ERR_EXIT("recvfrom");
        }

        fputs(recvbuf, stdout);
        memset(sendbuf, 0, sizeof(sendbuf));
        memset(recvbuf, 0, sizeof(recvbuf));
    }

    close(sock);


}

int main(void)
{
    int sock;
    if ((sock = socket(PF_INET, SOCK_DGRAM, 0)) < 0)
        ERR_EXIT("socket");

    echo_cli(sock);

    return 0;
}
View Code

UDP的發送端是發送到UDP的緩沖裏面了

UDP中的ICMP異步錯誤

關閉udp服務端,若啟動udp客戶端,從鍵盤接受數據後,再發送數據。udp客戶端阻塞在sendto位置; udp發送報文的時,只把數據copy到發送緩沖區。在服務器沒有起來的情況下,可以發送成功。 所謂ICMP異步錯誤是指:發送的報文的時候,沒有錯誤,接受報文recvfrom的時候,回收到ICMP應答。 異步的錯誤,是無法返回未連接的套接字。udp也可以調用connect。udp調用connet,並沒有三次握手,只是維護了一個狀態信息(和對等方的),包括對方的IP和端口等信息。一但調用connect,就可以使用send函數 就不會阻塞在recvfrom了,會收到一個ICMP的錯誤報文

客戶端調用connet和不調connet的區別。

udp也可以調用connet

udp客戶端調用了connect以後,不會阻塞在recvfrom函數這裏。

一但調用connect,就可以使用send函數

UDP協議數據報文截斷

如果接收到的數據報,大於緩沖區;報文可以被截斷;後面的部分會丟失。

SOCKET性能問題分析

客戶端連接服務器,打開的最大文件句柄是1024

如何突破1024?

FD_SETSIZE 是 內核中定義的一個宏,是1024, 如果使用select管理,最多也只能管理1024個

因此,僅僅修改ulimits這個也是不可以的。如果想要修改,可以修改內核,在重新進行編譯。

使用pool或者是epool可以突破這個機制。最大的性能提升還是在客戶端,客戶端如何快速的建立連接。

Linux UDP