如何獲取已經排隊的資料量:

（1）、獲取套接字當中的資料量的目的是為了避免讀操作而堵塞在核心中（這樣會堵塞整個程式的進行）， 為了解決這個問題， 我們可以使用非堵塞IO

（2）、在recv、recvfrom、recvnsg函式當中的flags引數標誌，我們可以使用MSG_PEEK標誌，僅僅讀取該套接字當中緩衝區當中的資料量，但是並不真真的讀取該資料，也可以使用MSG_DONTWAIT | MSG_PEEK相結合。但是我們需要注意的是，（針對tcp）可能兩次呼叫recv函式返回的值不同，因為兩次呼叫函式之間可能會資料到來。就針對UDP套接字而言，前一次呼叫recvfrom函式加上MSG_PEEK標誌檢視接收對列的資料量，後一次不加該標誌呼叫recvfrom函式讀取資料，那麼兩次的返回值（資料報大小、內容、發報者地址）將會是完全相同。

（3）、一些支援ioctl的FIONREAD命令。改命令第三個值-結果引數也會指向某個整數的一個指標，核心通過該整數返回的值就是套接字接收對列裡面當前所有資料的位元組數；而對於UDP而言，就是所有的已排隊資料報的總和的位元組數大小。因為針對UDP中返回值包括Ip地址和埠號（IPv4是16位元組，IPv6是24位元組）。

TCP連線的條件下 程式碼如下

客戶端核心程式碼片段如下:

#include "unp.h"

void str_cli(FILE *fp, int sockfd)
{
    int maxfdp, stdineof = 0;
    char sendbuf[MAXLINE], recvbuf[MAXLINE];
    fd_set rset;
    FD_ZERO(&rset);
    int num;
    for(;;){
        if(stdineof == 0) FD_SET(fileno(fp), &rset);
        FD_SET(sockfd, &rset);
        maxfdp = fileno(fp);
        if((num = Select(maxfdp + 1, &rset, NULL, NULL, NULL)) < 0){
            if(errno == EINTR) {
                fprintf(stdout, "semaphore lead to system call\n");
                continue;
            }else{
                fprintf(stdout, "select error\n");
            }
        }

        if(FD_ISSET(sockfd, &rset)){
            if(Readline(sockfd, recvbuf, MAXLINE) <= 0){
                if(stdineof == 1){
                    return;
                }
                if(errno == EINTR){
                    fprintf(stdout, "system call interrupted\n");
                    continue;
                }else{
                    fprintf(stdout, "read error\n");
                }
            }
            fprintf(stdout, "read error\n");

            Fputs(recvbuf, stdout);
        }
        if(FD_ISSET(fileno(fp), &rset)){
            if(Fgets(sendbuf, MAXLINE, fp) == NULL){
                FD_CLR(fileno(fp), &rset);
                Shutdown(sockfd, SHUT_WR);
                stdineof = 1;
                continue;
            }
            Writen(sockfd, sendbuf, strlen(sendbuf));
        }
    }
}
 

tcp伺服器端核心程式碼如下

#include "unp.h"

void _str_echo(int sockfd)
{
    char recvbuf[MAXLINE];
    int n;
    for(;;){
        n = Recv(sockfd, recvbuf, MAXLINE, MSG_PEEK);
        if(0 == n) break;       //server close connect
        else{
            int npend;
            sleep(1);
            Ioctl(sockfd, FIONREAD, &npend);
            fprintf(stdout, "%d bytes from PEEK, %d bytes pending\n", n,npend);
            n = Read(sockfd, recvbuf, MAXLINE);
            recvbuf[n] = 0;
            Fputs(recvbuf, stdout);
        }
    }
}
 

1、MSG_PEEK會把資料讀到緩衝區，但是並不會清理套接字中的資料，還可以供其他程序讀取。

2、ioctl的FIONREAD也可以讀取套接字中緩衝區的資料。

執行結果如下: