国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 操作系統 > 正文

使用select處理任意數目個客戶的單進程程序

2024-06-28 13:27:28
字體:
來源:轉載
供稿:網友
使用select處理任意數目個客戶的單進程程序

改寫http://www.CUOXin.com/nufangrensheng/p/3587962.html中的TCP回射服務器程序,把它重寫成使用select來處理任意數目個客戶的單進程程序,而不是為每個客戶派生一個子進程。

int main(int argc, char **argv){    int                   i, maxi, maxfd, listenfd, connfd, sockfd;    int                   nready, client[FD_SETSIZE];    ssize_t               n;    fd_set                rset, allset;    char                  buf[4096];    socklen_t             clilen;    struct sockaddr_in    cliaddr, servaddr;    listenfd = socket(AF_INET, SOCK_STREAM, 0);        bzero(&servaddr, sizeof(servaddr));    servaddr.sin_family = AF_INET;    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);    servaddr.sin_port = htons(9877);        bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));        listen(listenfd, 5);    maxfd = listenfd;    maxi = -1;    for(i = 0; i < FD_SETSIZE; i++)        client[i] = -1;        /* -1 indicates available entry */    FD_ZERO(&allset);    FD_SET(listenfd, &allset);    for(;;)    {        rset = allset;        nready = select(maxfd + 1, &rset, NULL, NULL, NULL);        if(FD_ISSET(listenfd, &rset))        {            clilen = sizeof(cliaddr);            connfd = accept(listenfd, (struct sockaddr *)&cliaddr, &clilen);                        for(i = 0; i < FD_SETSIZE; i++)            {                if(client[i] < 0)                {                    client[i] = connfd;    /* save descriptor */                    break;                }            }            if(i == FD_SETSIZE)            {                PRintf("too many clients/n");                exit(1);            }            FD_SET(connfd, &allset);    /* add new descriptor to set */            if(connfd > maxfd)                maxfd = connfd;            if(i > maxi)                maxi = i;            if(--nready <= 0)                continue;    /* no more readable descriptor */        }        for(i = 0; i <= maxi; i++)    /* check all clients for data */        {            if((sockfd = client[i]) < 0)                continue;            if(FD_ISSET(sockfd, &rset))            {                if((n = read(sockfd, buf, 4096)) == 0)    /* connection closed by client */                {                    close(sockfd);                    FD_CLR(sockfd, &rset);                    client[i] = -1;                }                else                {                    writen(sockfd, buf, n);                        }                                if(--nready <= 0)    /* no more readable descriptors */                    break;            }        }    }}

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 石河子市| 永嘉县| 射阳县| 南投县| 公安县| 瓦房店市| 台北市| 乾安县| 赣州市| 离岛区| 盱眙县| 崇州市| 蒲城县| 潜山县| 法库县| 虹口区| 两当县| 吴川市| 新巴尔虎右旗| 大连市| 灵台县| 株洲市| 太保市| 金山区| 珠海市| 育儿| 南昌市| 新宾| 台中县| 连江县| 姚安县| 安平县| 东兰县| 腾冲县| 横山县| 郧西县| 米脂县| 德安县| 博湖县| 水城县| 多伦县|