select函数配合阻塞io测试

 1、默认阻塞形式:

1.1没有客户端连接的时候

  

 select超时等待过程中不占用cpu.

1.2启用两个客户端程序

服务器程序

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<errno.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<unistd.h>
#include<pthread.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <fcntl.h>

int main()
{
    int lfd= -1,clifd =-1;
    fd_set rfd_set;
    struct timeval tv;
    struct sockaddr_in s_sockaddr,c_sockaddr;
    int c_sockaddr_len = sizeof(c_sockaddr);//必须赋值
    s_sockaddr.sin_family = AF_INET;
    s_sockaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    s_sockaddr.sin_port = htons(8888);
    lfd = socket(AF_INET,SOCK_STREAM,0);
    if(lfd<0)
    {
        perror("socket:");
        exit(-1);
    }
    int opt=1;
    setsockopt(lfd,SOL_SOCKET, SO_REUSEADDR,
               &opt, sizeof(opt));

    if((bind(lfd,(struct sockaddr*)&s_sockaddr,sizeof(s_sockaddr))<0))//
    {
        perror("bind:");
        close(lfd);
        exit(-1);
    }
    if(listen(lfd,2)<0)
    {
        perror("listen:");
        close(lfd);
        exit(-1);
    }
    int cfd[5];//5个客户端
    int maxfd = lfd;
    for(int i = 0;i<5;i++)
    {
        cfd[i]= -1;
    }
    while(1)
    {
        maxfd = lfd;
        FD_ZERO(&rfd_set);//清空
        FD_SET(lfd,&rfd_set);
        for(int i = 0;i<5;i++)
        {
            if(cfd[i]== -1)
                continue;
            FD_SET(cfd[i],&rfd_set);
            maxfd=(maxfd>=cfd[i])?maxfd:cfd[i];
        }

        tv = {5,0}; //设置超时时间
        int ret = select(maxfd+1,&rfd_set,NULL,NULL,&tv);
        if(ret<0)
        {
            perror("select");

        }else if(ret ==0){
            printf("select over time\n");
            continue;

        }else {
            if(FD_ISSET(lfd,&rfd_set))
            {
                if((clifd = accept(lfd,(struct sockaddr*)&c_sockaddr,(socklen_t*)&c_sockaddr_len))<0)
                {
                    perror("accept");

                }
                for(int i = 0;i<5;i++)
                {
                    if(cfd[i]== -1)
                    {
                         cfd[i]= clifd;
                         break;
                    }

                }
                printf("client link,ip=%s,port= %d,clifd =%d\n",inet_ntoa(c_sockaddr.sin_addr),
                       ntohs(c_sockaddr.sin_port),clifd);
            }
            for(int i=0;i<5;i++)
            {
                if(cfd[i]==-1)continue;
                if(FD_ISSET(cfd[i],&rfd_set))
                {
                    char buf[1024];
                    int nread = 0;

                    nread = read(cfd[i],buf,1024);
                    if(nread <=0)
                    {
                        printf("read:%s,errno=%d\n",strerror(errno),errno);
                        close(cfd[i]);
                        cfd[i] = -1;
                    }else{
                       printf("buf=%s,cfd=%d\n",buf,cfd[i]);
                    }

                }
            }
        }

    }
    return 0;
}

客服端程序:

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<errno.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<unistd.h>
#include<pthread.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/syscall.h>
int main()
{

    int cfd;
    int nwrite;
    char *sendbuf="abc";
    sockaddr_in s_sockaddr;
    s_sockaddr.sin_family = AF_INET;
    //字符类型转化为网络序(大端序)
    inet_aton("127.0.0.1",&s_sockaddr.sin_addr);
    s_sockaddr.sin_port = htons(8888);
    cfd = socket(AF_INET,SOCK_STREAM,0);
    if(cfd <0)
    {
        perror("socket:");
        exit(-1);
    }
    if(connect(cfd,(struct sockaddr*)&s_sockaddr,sizeof(s_sockaddr))<0)
    {
        perror("connect:");
        close(cfd);
        exit(-1);
    }
    while(1)
    {
        nwrite = write(cfd,sendbuf,sizeof(sendbuf));
        if(nwrite<=0)
        {
            perror("write:");
        }
        sleep(1);
    }


    return 0;
}

启动两个客户端,连接如下。,实现了多路复用。

 2、cfd采用阻塞的还是非阻塞形式

服务器端的连接的cfd都采用默认的阻塞形式。 

 

结论:虽然我们起了 两个客户端,但是第二个客户端程序也建立连接了,虽然不知道为什么没有打印信息,

 

 

我们将新生成的客户端程序设置为非阻塞,就可以避免这种情况。

服务器程序中修改如下:

for(int i = 0;i<5;i++)
                {
                    if(cfd[i]== -1)
                    {
                        cfd[i]= clifd;
                        int flags = fcntl(cfd[i], F_GETFL, 0);                       //获取文件的flags值。
                        fcntl(cfd[i], F_SETFL, flags | O_NONBLOCK);   //设置成非阻塞模式;
                        break;
                    }

                }

 

 结果如下: 

服务器程序中的第二个read函数在客户端没有写数据的时候,也自动返回了。 

这也是select函数一般与非阻塞socket连用的原因之一吧

猜你喜欢

转载自blog.csdn.net/modi000/article/details/125223300