UNIX网络编程：fcntl函数

运行结果：

huangcheng@ubuntu:~$ ./a.out
socket success!,sockfd=3  
bind success!  
listening....  
accept: Resource temporarily unavailable

可以看到，当accept的资源不可用时，程序会自动返回。

若将54--58行代码替换为：

if((flags=fcntl( sockfd, F_SETFL, 0))<0)    
    perror("fcntl F_SETFL");    
flags |= O_ASYNC;   
if(fcntl( sockfd, F_SETFL,flags)<0)    
    perror("fcntl");

运行结果如下：

huangcheng@ubuntu:~$ ./a.out
socket success!,sockfd=3  
bind success!  
listening....

可以看到，进程一直处于等待中，直到另一相关信号驱动它为止。

由select函数实现的，示例代码：

#include <sys/types.h>    
#include <sys/socket.h>    
#include <sys/wait.h>    
#include <stdio.h>    
#include <stdlib.h>    
#include <errno.h>    
#include <string.h>    
#include <sys/un.h>    
#include <sys/time.h>    
#include <sys/ioctl.h>    
#include <unistd.h>    
#include <netinet/in.h>    
#define SERVPORT 3333    
#define BACKLOG 10     
#define MAXDATASIZE 100    
int main()    
{    
    struct sockaddr_in server_sockaddr,client_sockaddr;    
    int sin_size,recvbytes;    
    fd_set readfd;    
    fd_set writefd;    
    int sockfd,client_fd;    
    char buf[MAXDATASIZE];    
/*创建socket*/
    if((sockfd = socket(AF_INET,SOCK_STREAM,0))==-1){    
        perror("socket");    
        exit(1);    
    }    
    printf("socket success!,sockfd=%dn",sockfd);    
/*设置sockaddr结构*/
    server_sockaddr.sin_family=AF_INET;    
    server_sockaddr.sin_port=htons(SERVPORT);    
    server_sockaddr.sin_addr.s_addr=INADDR_ANY;    
    bzero(&(server_sockaddr.sin_zero),8);    
/*将本地ip地址绑定端口号*/
    if(bind(sockfd,(struct sockaddr *)&server_sockaddr,sizeof(struct sockaddr))==-1){    
        perror("bind");    
        exit(1);    
    }    
    printf("bind success!n");    
/*监听*/
    if(listen(sockfd,BACKLOG)==-1){    
        perror("listen");    
        exit(1);    
    }    
    printf("listening....n");    
/*select*/
    FD_ZERO(&readfd);              // 将readfd 清空     
    FD_SET(sockfd,&readfd);         //将sockfd加入到readfd集合中    
    while(1){    
    sin_size=sizeof(struct sockaddr_in);  
    int max_fd = sockfd + 1;      
    if(select(max_fd,&readfd,NULL,NULL,(struct timeval *)0)>0){  //第一个参数是0和sockfd的最大值加1，第二个参数是读集，第三、四个参数是写集                                                                                //和异常集    
        if(FD_ISSET(sockfd,&readfd)>0){         // FD_ISSET 这个宏判断 sockfd 是否属于可读的文件描述符。从 sockfd 中读入, 输出到标准输出上去.    
            if((client_fd=accept(sockfd,(struct sockaddr *)&client_sockaddr,&sin_size))==-1){   //client_sockaddr：客户端地址    
                perror("accept");    
                exit(1);    
            }    
            if((recvbytes=recv(client_fd,buf,MAXDATASIZE,0))==-1){    
                perror("recv");    
                exit(1);    
            }    
            if(read(client_fd,buf,MAXDATASIZE)<0){    
                perror("read");    
                exit(1);    
            }    
            printf("received a connection :%s",buf);    
        }   
        close(client_fd);   
        close(sockfd);        
    }/*select*/
  }/*while*/
}

运行结果：

huangcheng@ubuntu:~$ ./a.out
socket success!,sockfd=3  
bind success!  
listening....

作者：csdn博客 ctthuangcheng

查看本栏目更多精彩内容：http://www.bianceng.cn/OS/unix/

（编辑：应用网_镇江站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!