首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 开发语言 > C语言 >

selcect并发理解,该如何解决

2012-05-11 
selcect并发理解假设backlog10,selcet的并发是指什么呢?同时有10个用户请求连接,selcet之后,对有数据的描

selcect并发理解
假设backlog=10,selcet的并发是指什么呢?
同时有10个用户请求连接,selcet之后,对有数据的描述符进行统一的循环处理,不也会出现read write阻塞主循环的情形么?还是在一个个处理啊。如果没有selcet,也是在排队等待处理呀?
在accept之后得到新的fd,这个fd会一直保留么?还是超时了就把他清除掉了呢?
并发不应该是多线程来解决的事么
达人帮忙解惑啊,多谢了

C/C++ code
    while (1) {        // initialize file descriptor set        FD_ZERO(&fdsr);        FD_SET(sock_fd, &fdsr);        // timeout setting        tv.tv_sec = 30;        tv.tv_usec = 0;        // add active connection to fd set        for (i = 0; i < BACKLOG; i++) {            if (fd_A[i] != 0) {                FD_SET(fd_A[i], &fdsr);            }        }        ret = select(maxsock + 1, &fdsr, NULL, NULL, &tv);        if (ret < 0) {            perror("select");            break;        } else if (ret == 0) {            printf("timeout\n");            continue;        }        // check every fd in the set        for (i = 0; i < conn_amount; i++) {            if (FD_ISSET(fd_A[i], &fdsr)) {                ret = recv(fd_A[i], buf, sizeof(buf), 0);                if (ret <= 0) {        // client close                    printf("client[%d] close\n", i);                    close(fd_A[i]);                    FD_CLR(fd_A[i], &fdsr);                    fd_A[i] = 0;                } else {        // receive data                    if (ret < BUF_SIZE)                        memset(&buf[ret], '\0', 1);                    printf("client[%d] send:%s\n", i, buf);                }            }        }        // check whether a new connection comes        if (FD_ISSET(sock_fd, &fdsr)) {            new_fd = accept(sock_fd, (struct sockaddr *)&client_addr, &sin_size);            if (new_fd <= 0) {                perror("accept");                continue;            }            // add to fd queue            if (conn_amount < BACKLOG) {                fd_A[conn_amount++] = new_fd;                printf("new connection client[%d] %s:%d\n", conn_amount,                        inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));                if (new_fd > maxsock)                    maxsock = new_fd;            }            else {                printf("max connections arrive, exit\n");                send(new_fd, "bye", 4, 0);                close(new_fd);                break;            }        }        showclient();    }    // close other connections    for (i = 0; i < BACKLOG; i++) {        if (fd_A[i] != 0) {            close(fd_A[i]);        }    }    exit(0);}


[解决办法]
select并不是并发,而是IO多路转接

当你有多个socket或多个连接时,你不知道那个连接有数据到了,如果用纯阻塞时socket,一个一个等,没有数据的会阻塞有数据的,效率很低

如果用了select,select本身会阻塞,当有数据的时候select返回,就表示你可以接收数据了

select是个老api,传统unix就有,现在有一些新的加强api,比如Winsock的WSAEventSelect,和Select类似,但是能直接告诉你是“第几个socket有数据了”,这样你就不需要select后面的遍历循环了
[解决办法]
1、如果阻塞与用户输入,当有数据到达,read不到!所以用select,它也是阻塞,但是当有一个fd可读时候返回!

2、accept会保留fd,当收到客户端端口连接,或超时的时候,就可以清除。

3、并发可以用多种实现方式,select也可以,多进程也可以,多线程也可以。建议使用多线程。
[解决办法]
对select/poll这种老接口,写代码应该:
准备一个connection* *conns; ,顺序存放在线的conntions,方便用于select的遍历。

对epoll这种新接口,写代码应该:
准备一个connection* conns[65536],方便直接根据fd完成O(1)的映射。

热点排行