10-11-12 IO复用及select例子
2017-02-21 10:58
369 查看
1. 阻塞式IO
2. 非阻塞式IO
3. IO复用Select / epoll
4. 信号驱动IO
5. 异步IO
6. select示例
#include "socket_includes.h"
int mz_ipv4_tcp_create_socket(void)
{
int listenfd, sockfd, opt = 1;
struct sockaddr_in server, client;
socklen_t len;
int timep;
int ret;
listenfd = socket(AF_INET, SOCK_STREAM, 0);
if(listenfd < 0){
perror("Create socket fail.");
return -1;
}
if((ret = setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt))) < 0){
perror("Error, set socket reuse addr failed");
return -1;
}
bzero(&server, sizeof(server));
server.sin_family = AF_INET;
server.sin_port = htons(SERV_PORT);
server.sin_addr.s_addr = htonl(INADDR_ANY);
len = sizeof(struct sockaddr);
if(bind(listenfd, (struct sockaddr *)&server, len)<0){
perror("bind error.");
return -1;
}
listen(listenfd, MAX_LISTEN_QUE);
return listenfd;
}
int main(int argc, char *argv[])
{
int listenfd, sockfd;
struct sockaddr_in server, client;
socklen_t len;
int bytes =0 ;
fd_set global_rdfs,current_rdfs;
int maxfd;
int i;
char buf[MAX_BUFFER_SIZE];
len = sizeof(struct sockaddr_in);
listenfd = mz_ipv4_tcp_create_socket();
FD_ZERO(&global_rdfs);
FD_SET(listenfd, &global_rdfs);
maxfd = listenfd;
while(1){
current_rdfs = global_rdfs;
if(select(maxfd + 1, ¤t_rdfs, NULL, NULL, NULL)<0){
perror("select error.\n");
return RT_ERR;
}
for(i = 0; i <= maxfd; i++){
if(FD_ISSET(i, ¤t_rdfs)){
if(listenfd == i){
if((sockfd = accept(listenfd, (struct sockaddr*)&client, (socklen_t*)&len))<0){
perror("accept error.\n");
return RT_ERR;
}
printf("sockfd:%d\n", sockfd);
FD_CLR(i, ¤t_rdfs);
maxfd = maxfd > sockfd ? maxfd :sockfd;
FD_SET(sockfd, &global_rdfs);
}else{
printf("read socket:%d\n", i);
bytes = recv(i, buf, MAX_BUFFER_SIZE, 0);
if(bytes < 0){
perror("recv error.\n");
return RT_ERR;
}
if(bytes == 0){
FD_CLR(i, &global_rdfs);
close(i);
continue;
}
printf("buf:%s\n", buf);
send(i, buf, strlen(buf), 0);
}
}
}
}
}
2. 非阻塞式IO
3. IO复用Select / epoll
4. 信号驱动IO
5. 异步IO
6. select示例
#include "socket_includes.h"
int mz_ipv4_tcp_create_socket(void)
{
int listenfd, sockfd, opt = 1;
struct sockaddr_in server, client;
socklen_t len;
int timep;
int ret;
listenfd = socket(AF_INET, SOCK_STREAM, 0);
if(listenfd < 0){
perror("Create socket fail.");
return -1;
}
if((ret = setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt))) < 0){
perror("Error, set socket reuse addr failed");
return -1;
}
bzero(&server, sizeof(server));
server.sin_family = AF_INET;
server.sin_port = htons(SERV_PORT);
server.sin_addr.s_addr = htonl(INADDR_ANY);
len = sizeof(struct sockaddr);
if(bind(listenfd, (struct sockaddr *)&server, len)<0){
perror("bind error.");
return -1;
}
listen(listenfd, MAX_LISTEN_QUE);
return listenfd;
}
int main(int argc, char *argv[])
{
int listenfd, sockfd;
struct sockaddr_in server, client;
socklen_t len;
int bytes =0 ;
fd_set global_rdfs,current_rdfs;
int maxfd;
int i;
char buf[MAX_BUFFER_SIZE];
len = sizeof(struct sockaddr_in);
listenfd = mz_ipv4_tcp_create_socket();
FD_ZERO(&global_rdfs);
FD_SET(listenfd, &global_rdfs);
maxfd = listenfd;
while(1){
current_rdfs = global_rdfs;
if(select(maxfd + 1, ¤t_rdfs, NULL, NULL, NULL)<0){
perror("select error.\n");
return RT_ERR;
}
for(i = 0; i <= maxfd; i++){
if(FD_ISSET(i, ¤t_rdfs)){
if(listenfd == i){
if((sockfd = accept(listenfd, (struct sockaddr*)&client, (socklen_t*)&len))<0){
perror("accept error.\n");
return RT_ERR;
}
printf("sockfd:%d\n", sockfd);
FD_CLR(i, ¤t_rdfs);
maxfd = maxfd > sockfd ? maxfd :sockfd;
FD_SET(sockfd, &global_rdfs);
}else{
printf("read socket:%d\n", i);
bytes = recv(i, buf, MAX_BUFFER_SIZE, 0);
if(bytes < 0){
perror("recv error.\n");
return RT_ERR;
}
if(bytes == 0){
FD_CLR(i, &global_rdfs);
close(i);
continue;
}
printf("buf:%s\n", buf);
send(i, buf, strlen(buf), 0);
}
}
}
}
}
相关文章推荐
- 现有杂乱无序的1-20二十个数,这二十个数为:1,18,4,13,6,10,15,2,17,3,19,7,16,8,11,14,9,12,5,20,试依次求出相邻四个数之和的最大和最小值
- TCP IO复用 select并发服务端 Linux socket编程入门(3)
- Jquery李炎恢——44,45,46日历UI【10】【11】【12】
- IO多路复用之select总结
- 网络通信 --> IO多路复用之select、poll、epoll详解
- Linux下多路复用IO接口epoll/select/poll的区别
- |1|2|3|4|5|6|7|8|9|10|11|12|13|14|15|16|17|18|19|20所有这些字符串,把它的数字一个个剥离??
- Linux下多路复用IO接口 epoll select poll 的区别
- IO复用,select、poll、epoll综述
- 利用线程的知识,要求打印的结果为:1 2 A 3 4 B 5 6 C 7 8 D 9 10 11 12 ... 52 E F G H I J K ... X Y Z
- 输入一个矩阵,按照从外向里以顺时针的顺序依次打印出每一个数字,例如,如果输入如下矩阵: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 则依次打印出数字1,2,3,4,8
- IO复用之——select
- 快速判断一个数能否被1、2、3、4、5、6、7、8、9、10、11、12、13、17、19、23等整除的规律总结
- python之旅九-1【第九篇】IO多路复用以及select
- java 输入一个矩阵,按照从外向里以顺时针的顺序依次打印出每一个数字,例如,如果输入如下矩阵: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 则依次打印出数字1,2,
- Linux IO复用--select()和poll()
- 聊聊IO多路复用之select、poll、epoll详解
- VMware Workstation 12安装 Solaris 10 / 11
- 聊聊IO多路复用之select、poll、epoll详解
- linux网络编程 IO多路复用 select epoll