tcp/udp只發不接，會丟包還是send失敗？

這篇文章源於我看libevent的源碼時想到的問題，對於libevent的buffer機制，如果接受端一直不取數據的話，會怎樣？如果丟包，不現實，因為會導致數據丟失，如果不丟包，就會導致占用內存一直擴大。

由此我想到對於tcp/udp如果一直發，接收端不調用recv取數據會怎樣，是會導致send失敗，還是多余的數據丟棄？想再多還不如寫個代碼試一試，下面看代碼。

tcp：client端一直發，sever端接受連接后不調用recv

客戶端

/*
 * gcc -o tcpCli ./tcpCli.c
 */
#include <unistd.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>

const int PORT = 8080;

int main(int argc, char **argv)
{
    int fd = socket(AF_INET, SOCK_STREAM, 0);
    if (fd == -1)
    {
        perror("socket");
        return errno;
    }

    struct sockaddr_in addr;
    memset(&addr, 0, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = inet_addr("127.0.0.1");
    addr.sin_port = htons(PORT);

    if (connect(fd, (struct sockaddr*)&addr, sizeof(addr)) == -1)
    {
        perror("connect");
        return errno;
    }

    fcntl(fd, F_SETFL, O_NONBLOCK);

    char buf[65536] = "hello world!";
    while (1)
    {
        int iRet = send(fd, buf, 65536, 0); 
        if (iRet == -1)
        {
            perror("send");
        }
        else
        {
            printf("Send data len [%d]\n", iRet);
            printf("Send content [%s]\n", buf);
        }
        sleep(2);
    }
    close(fd);

    return 0;
}

服務端

/*
 * gcc -o tcpSvr ./tcpSvr.c
 */
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>

const int PORT = 8080;

int main(int argc, char **argv)
{
    int fd = socket(AF_INET, SOCK_STREAM, 0);
    if (fd == -1)
    {
        perror("socket");
        return errno;
    }

    struct sockaddr_in addr;
    memset(&addr, 0, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = INADDR_ANY;
    addr.sin_port = htons(PORT);

    if (-1 == bind(fd, (struct sockaddr*)&addr, sizeof(addr)))
    {
        perror("bind");
        return errno;
    }

    if (-1 == listen(fd, 5))
    {
        perror("listen");
        return errno;
    }

    struct sockaddr_in cli_addr;
    socklen_t len = sizeof(cli_addr);
    int client = accept(fd, (struct sockaddr*)&cli_addr, &len);
    if (client == -1)
    {
        perror("accept");
        return errno;
    }
    
    printf("accept an client\n");

    char buf[1024];
    while(1)
    {
        memset(buf, 0, 1024);
        //int iRet = recv(client, buf, 10, 0);
        int iRet = 0;
        printf("recv data len [%d]\n", iRet);
        printf("recv content [%s]\n", buf);
        sleep(2);
    }
    close(fd);

    return 0;
}

結果：

很明顯，會導致send發送失敗，所以需要注意的是，用send發送數據如果tcp緩沖區空間不足時，只會發送部分數據，這時就需要程序員自己來記錄發送位置，等到緩沖區可發送時再繼續發送。

但是獲取到的寫緩沖區大小和發送的數據大小不一致，不知道是什么原因，這個待后面繼續研究。

 

udp：client端一直發，一段時間后關閉，sever端等待客戶端關閉，再開始接受

客戶端

/*
 * gcc -o udpCli ./udpCli.c
 */
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>

const int PORT = 8080;

int main(int argc, char **argv)
{
    int fd = socket(AF_INET, SOCK_DGRAM, 0);
    if (fd == -1)
    {
        perror("socket");
        return errno;
    }

    struct sockaddr_in addr;
    memset(&addr, 0, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = inet_addr("127.0.0.1");
    addr.sin_port = htons(PORT);

    // get send buffer size
    int iWBufSize;
    socklen_t optLen = sizeof(iWBufSize);
    getsockopt(fd, SOL_SOCKET, SO_SNDBUF, &iWBufSize, &optLen);
    printf("Write buffer size = %d\n", iWBufSize);

    int iRBufSize;
    optLen = sizeof(iRBufSize);
    getsockopt(fd, SOL_SOCKET, SO_RCVBUF, &iRBufSize, &optLen);
    printf("Read buffer size = %d\n", iRBufSize);

    char buf[1500] = "hello world!";
    int iCount = 0;
    while (1)
    {
        sprintf(buf, "%d", iCount);
        int iRet = sendto(fd, buf, 1500, 0, (struct sockaddr*)&addr, sizeof(addr));
        if (iRet == -1)
        {
            perror("sendto");
            break;
        }
        else
        {
            // printf("Send data len [%d]\n", iRet);
            iCount++;
        }
        if (iCount % 100 == 0)
        {
            printf("Send package count %d\n", iCount);
            sleep(1);
        }
    }
    printf("Send package count %d\n", iCount);
    close(fd);

    return 0;
}

服務端

/*
 * gcc -o udpSvr ./udpSvr.c
 */
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>

const int PORT = 8080;

int main(int argc, char **argv)
{
    int fd = socket(AF_INET, SOCK_DGRAM, 0);
    if (fd == -1)
    {
        perror("socket");
        return errno;
    }

    struct sockaddr_in addr;
    memset(&addr, 0, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = INADDR_ANY;
    addr.sin_port = htons(PORT);

    if (-1 == bind(fd, (struct sockaddr*)&addr, sizeof(addr)))
    {
        perror("bind");
        return errno;
    }

    getchar();

    char buf[1500];
    int iCount = 0;
    while(1)
    {
        memset(buf, 0, 1024);
        int iRet = recv(fd, buf, 1500, 0);
        iCount++;
        // printf("recv data len [%d]\n", iRet);
        printf("Recv package count[%d]\t", iCount);
        printf("recv content [%s]\n", buf);
    }
    close(fd);

    return 0;
}

結果：

可以看到，客戶端一共發送1300個包，而服務端僅僅能收到前面69個包，后面的全被丟棄了。

根據收到的包的個數和每個包的大小，計算出換沖區的大小：103500，不知道這個值算的對不對。