select(101+1, &reads, NULL, NULL, NULL);	//第一個(gè)參數(shù)，需要檢測的文件描述符+1	--(+1才能遍歷到101，因?yàn)槭菑?開始的)

//客戶端
#include <stdio.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
int main() {
    // 創(chuàng)建socket
    int fd = socket(PF_INET, SOCK_STREAM, 0);
    if(fd == -1) {
        perror("socket");
        return -1;
    }
    struct sockaddr_in seraddr;
    inet_pton(AF_INET, "127.0.0.1", &seraddr.sin_addr.s_addr);
    seraddr.sin_family = AF_INET;
    seraddr.sin_port = htons(9999);
    // 連接服務(wù)器
    int ret = connect(fd, (struct sockaddr *)&seraddr, sizeof(seraddr));
    if(ret == -1){
        perror("connect");
        return -1;
    }
    int num = 0;
    while(1) {
        char sendBuf[1024] = {0};
        sprintf(sendBuf, "send data %d", num++);
        write(fd, sendBuf, strlen(sendBuf) + 1);
        // 接收
        int len = read(fd, sendBuf, sizeof(sendBuf));
        if(len == -1) {
            perror("read");
            return -1;
        }else if(len > 0) {
            printf("read buf = %s\n", sendBuf);
        } else {
            printf("服務(wù)器已經(jīng)斷開連接...\n");
            break;
        }
        // sleep(1);
        usleep(1000);
    }
    close(fd);
    return 0;
}

//服務(wù)端
#include <stdio.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <sys/select.h>
int main() {
    // 創(chuàng)建socket
    int lfd = socket(PF_INET, SOCK_STREAM, 0);
    struct sockaddr_in saddr;
    saddr.sin_port = htons(9999);
    saddr.sin_family = AF_INET;
    saddr.sin_addr.s_addr = INADDR_ANY;
    // 綁定
    bind(lfd, (struct sockaddr *)&saddr, sizeof(saddr));
    // 監(jiān)聽
    listen(lfd, 8);
    // 創(chuàng)建一個(gè)fd_set的集合，存放的是需要檢測的文件描述符
    fd_set rdset, tmp;	//fd_set底層可以表示1024個(gè)文件描述符
    FD_ZERO(&rdset);	//初始化
    FD_SET(lfd, &rdset);	//添加需要監(jiān)聽的文件描述符
    int maxfd = lfd;	//定義最大文件描述符，作為參數(shù)傳入select函數(shù)中
    while(1) {
        tmp = rdset;	//rdset這個(gè)不能變，因?yàn)閮?nèi)核再檢測時(shí)，如果沒有數(shù)據(jù)，就會將其變?yōu)?，因此，我們需要復(fù)制一份。
        // 調(diào)用select系統(tǒng)函數(shù)，讓內(nèi)核幫檢測哪些文件描述符有數(shù)據(jù)
        int ret = select(maxfd + 1, &tmp, NULL, NULL, NULL);
        if(ret == -1) {
            perror("select");
            exit(-1);
        } else if(ret == 0) {	//這里不可能為0，因?yàn)樵O(shè)置了永久阻塞NULL，直到檢測到文件描述符有數(shù)據(jù)變化
            continue;	
        } else if(ret > 0) {	//ret只會返回文件描述符發(fā)生變化的個(gè)數(shù)，不知道具體哪個(gè)發(fā)生了變化，需要遍歷查找
            // 說明檢測到了有文件描述符的對應(yīng)的緩沖區(qū)的數(shù)據(jù)發(fā)生了改變
            if(FD_ISSET(lfd, &tmp)) {	//lfd為監(jiān)聽文件描述符
                // 表示有新的客戶端連接進(jìn)來了
                struct sockaddr_in cliaddr;
                int len = sizeof(cliaddr);
                int cfd = accept(lfd, (struct sockaddr *)&cliaddr, &len);
                // 將新的文件描述符加入到集合中，下一次select檢測時(shí)，需要檢測這些通信的文件描述符有沒有數(shù)據(jù)
                FD_SET(cfd, &rdset);
                // 更新最大的文件描述符
                maxfd = maxfd > cfd ? maxfd : cfd;
            }
            //檢測剩余文件描述符有沒有數(shù)據(jù)變化，從lfd+1開始即可
            for(int i = lfd + 1; i <= maxfd; i++) {
                if(FD_ISSET(i, &tmp)) {
                    // 說明這個(gè)文件描述符對應(yīng)的客戶端發(fā)來了數(shù)據(jù)
                    char buf[1024] = {0};
                    int len = read(i, buf, sizeof(buf));
                    if(len == -1) {
                        perror("read");
                        exit(-1);
                    } else if(len == 0) {	//說明客戶端斷開連接
                        printf("client closed...\n");
                        close(i);	//關(guān)閉文件描述符
                        FD_CLR(i, &rdset);	//fd_set中不在監(jiān)測這個(gè)文件描述符
                    } else if(len > 0) {
                        printf("read buf = %s\n", buf);
                        write(i, buf, strlen(buf) + 1);
                    }
                }
            }
        }
    }
    close(lfd);
    return 0;
}