美文网首页
对IO几种模型的一点想法

对IO几种模型的一点想法

作者: 走过路过_97c2 | 来源:发表于2017-05-29 23:27 被阅读0次

最近看了好几本网络编程的书,是时候整理一下思路了。TCP头有20个字节,通过确认号和序列号保证了传输高可靠性,当然还有其他一些特性,比如滑动窗口机制,紧急指针等,但对于应用层的游戏开发者来说,了解即可,用得很少。关上书本来想想,不足之处望指正。
socket通信是同步阻塞的,在accept,read/write等操作时线程会阻塞。对于高并发的通信来说,IO性能是最大的瓶颈。这种模型更像是阻塞忙轮询。Select模型是一种非阻塞忙轮询,用起来也很爽。它采用一种事件机制。对于加入fd_set的fd,在发生stdin,stdout,等事件时select会返回。这种fd_set采用位操作来处理,将需要监听的fd加入集合中,fd_zero置0,可以相像现在所有fd都被记录为0,当发生IO事件时,内核会将其置为1,此时会调用回调,从而避免了CPU的空转。但是本质上来讲这也是一种同步阻塞,

define BUF_SIZE 1024

define ECHO_PORT 5566

void ErrorHanding(char* message);

int main()
{
WSADATA wsaData;
SOCKET hServSock,hClntSock;
SOCKADDR_IN servAdr,clntAdr;
TIMEVAL timeout;
fd_set reads,cpyReads;

int adrSz;
int srtLen,fdNum;
char buf[BUF_SIZE];

if(WSAStartup(MAKEWORD(2,2),&wsaData)!=0)
{
    ErrorHanding("wsastartup error!");
}

//创建
hServSock=socket(AF_INET,SOCK_STREAM,0);
//设置地址
memset(&servAdr,0,sizeof(servAdr));
servAdr.sin_family=AF_INET;
servAdr.sin_addr.s_addr=htonl(INADDR_ANY);
servAdr.sin_port=htons(ECHO_PORT);

//绑定
if(bind(hServSock,(SOCKADDR*)&servAdr,sizeof(servAdr)))
{
    ErrorHanding("bind error");
}

//监听
if(listen(hServSock,5)==SOCKET_ERROR)
{
    ErrorHanding("listen error");
}

//fd_set初始化
FD_ZERO(&reads);
//注册到fd_set
FD_SET(hServSock,&reads);

while (true)
{
    cpyReads=reads;
    timeout.tv_sec=5;
    timeout.tv_usec=5000;

    if((fdNum=select(0,&cpyReads,0,0,&timeout))==SOCKET_ERROR)
        break;

    if(fdNum==0)
        continue;

    //轮询
    for (UINT i=0;i<reads.fd_count;i++)
    {
        //连接监听符发生变化
        if(FD_ISSET(reads.fd_array[i],&cpyReads))
        {
            //是连接请求
            if(reads.fd_array[i]==hServSock)
            {
                adrSz=sizeof(clntAdr);
                hClntSock=accept(hServSock,(SOCKADDR*)&clntAdr,&adrSz);

                //将客户端连接的fd注册到fd_set
                FD_SET(hClntSock,&reads);
                cout<<"connected client:"<<hClntSock<<endl;
            }
            else
            {
                memset(buf,0,BUF_SIZE);
                //读取
                srtLen=recv(reads.fd_array[i],buf,BUF_SIZE-1,0);
                if (srtLen==0)
                {
                    FD_CLR(reads.fd_array[i],&reads);
                    closesocket(cpyReads.fd_array[i]);
                    cout<<"close client:"<<cpyReads.fd_array[i]<<endl;
                }
                else
                {
                    //strcat(buf,",from Server草泥马");
                    cout<<"客户端说:           "<<buf<<endl;

                    printf("发消息 :");   
                    scanf("%s", buf);
                    send(reads.fd_array[i],buf,strlen(buf),0); //echo
                }
            }
        }
    }
}

closesocket(hServSock);
WSACleanup();
return 0;

}

void ErrorHanding(char* message)
{
fputs(message,stderr);
fputc('\n',stderr);
exit(1);
}

select模型缺陷也很明显,每次轮询后都会重置fd_set,fd从内核态到用户态的拷贝,以及轮询对所有fd遍历都会造成可监听的Fd数量不可太多。对此改进,Linux上有epoll,windows有iocp,后续再说。

边缘触发需要一次性收完数据,内核不会再发通知,在read/write时会造成长时间阻塞。故而应当设置为非阻塞模式。相对于水平触发,对于接收的乱序消息处理更好。为啥呢?因为水平触发针对ABC包乱序的情况,epoll_wait会做延迟接收,会造成事件数累加,故而使用边缘触发可能效率更高。

相关文章

  • 对IO几种模型的一点想法

    最近看了好几本网络编程的书,是时候整理一下思路了。TCP头有20个字节,通过确认号和序列号保证了传输高可靠性,当然...

  • 网络IO模型

    网络IO的模型大致包括下面几种 同步模型(synchronous IO)阻塞IO(bloking IO)非阻塞IO...

  • 几种IO模型

    周日午后,刚刚放下手里的电话,正在给刚刚的面试者写评价。刚刚写到『对Linux的基本IO模型理解不深』这句的时候,...

  • Java:IO和NIO

    一、几种IO模型 1.阻塞IO模型(我就死等) 最传统的一种IO模型,即在读写数据过程中会发生阻塞现象。 当用户线...

  • 异步IO简析

    什么是异步IO 《UNIX网络编程卷1》中的IO多路复章节总结了几种典型IO模型,包括: 阻塞IO 非阻塞IO I...

  • 【转】IO模型及select、poll、epoll和kqueue

    【转】IO模型及select、poll、epoll和kqueue的区别 (一)首先,介绍几种常见的I/O模型及其区...

  • 几种IO模型与 NIO

    1. NIO是啥,为了解决什么问题? 新的输入/输出 (NIO) 库是在 JDK 1.4 中引入的,弥补了原来的 ...

  • 新架构第2天

    Q1、几种IO模型的原理 阻塞IO模型应用程序接收到用户一个请求,应用程序发起系统调用内核完成工作,内核从网络或者...

  • 0、常见的几种IO模型

    1、操作系统内核 2、BIO模型 BIO(blocking I/O)是阻塞IO模型,每个客户端连接上之后都会启用一...

  • 异步 IO 的好处

    上篇文章中,分析了几种任务处理模型:单线程阻塞 IO、多线程非阻塞 IO 和单线程非阻塞 IO 的性能,并画出了简...

网友评论

      本文标题:对IO几种模型的一点想法

      本文链接:https://www.haomeiwen.com/subject/ofulfxtx.html