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