将完成端口改为EPOLL（EPOLLONESHOT）模型后，处理消息效率没有之前高

helpstudy

如题，请大神们给点见意，折腾好几天了，没有思路

linux_c_py_php

1, 原本多高, 后来多高.
2, IOCP不需要用户线程做I/O, 所有CPU都可以拿来做逻辑, 如果和epoll相比我打赌是要高效的, 这是reactor和proactor最本质的差别, epoll想快, 比如半同步半异步或者领导者追随者来发挥多线程的能力. IOCP做领导者追随者比epoll做要高效, 也因为proactor>reactor, 并且IOCP是操作系统的异步IO, 不是一个档次.

helpstudy

是这样的，在windows下有一个测试工具，用机器人模拟玩家的发送消息，其中有一条消息是定时发送ping消息（当前发送时间），服务器接受到后原样返回该消息，客户端接受ping消息后，计算发送消息时和接收到消息之间的时间差值，一个机器人很正常，当100个机器人时，有的时间差值很大，相隔20秒左右，（没有消息丢失的情况），不知道有没有好的解决办法回复 2# linux_c_py_php


   

linux_c_py_php

helpstudy 发表于 2013-05-31 18:15
是这样的，在windows下有一个测试工具，用机器人模拟玩家的发送消息，其中有一条消息是定时发送ping消息（当 ...

啊, 20秒... 程序有错吗- -

helpstudy

呵呵，说错了，是毫秒，跟了一下程序流程，没发现错误的地方，跟踪消息的数据内容和window下都相同，机器发送消息量很大，而且很平繁，回复 4# linux_c_py_php


void * ServerWorkProc(LPVOID lpParameter)
{
        CConnection *  pConnection = NULL;       
        CNetServer * pCPS = (CNetServer * )lpParameter;
        int iEpollHandle = pCPS->GetServerEpollfd(0);
        struct epoll_event event;
        struct epoll_event evReg;
        int numEvents ;
       
        while (true)
        {
                if(pCPS->m_bWorkProcExiting)
                        return NULL;
                numEvents = epoll_wait(iEpollHandle, &event, 1, MAX_EPOLL_WAIT_TIME);
                if( numEvents <= 0)
                {
                        continue;
                }

                pConnection = (CConnection*)event.data.ptr;
                if(pConnection == NULL|| !pConnection->IsConnected())
                        continue;
                if(event.events & EPOLLOUT)
                {
                        if(SendToConnection( pConnection) == FALSE)
                        {
                                epoll_ctl(iEpollHandle, EPOLL_CTL_DEL, pConnection->Socket(), &evReg);
                                pConnection->DisConnected();
                                Log(stderr,"epoll_ctl***SendToConnection fail!\n");                                       
                                continue;
                        }
                }
                else if (event.events & EPOLLIN)
                {
                        if(RecvFromConnection(pConnection) == FALSE)
                        {
                                epoll_ctl(iEpollHandle, EPOLL_CTL_DEL, pConnection->Socket(), &evReg);
                                pConnection->DisConnected();
                                Log(stderr,"epoll_ctl***RecvFromConnection fail!\n");
                                continue;
                        }
                }

                evReg.events = EPOLLIN | EPOLLONESHOT;
                evReg.data.ptr = (void*)pConnection;
                if(epoll_ctl(iEpollHandle, EPOLL_CTL_MOD, pConnection->Socket(), &evReg) != 0)
                {
                        pConnection->DisConnected();
                        Log(stderr,"ServerWorkProc epoll_ctl  fail!\n");       
                }

        }

        return NULL;
}

   

helpstudy

由于代码量太大，无法全部贴出，服务器发送消息是每次发送 512个字节(手动触发的方式进行)，从发送队列中取，回复 3# helpstudy


   

adan830

楼主！！！
我有个问题想请教你
我看你加了EPOLLSHOT 那么可能你是多个线程使用同一个epfd进行epoll_wait,我的问题是在这种情况下我该在什么时候加EPOLLOUT呢 如果我在加EPOLLOUT的时候其他线程触发了epoll_wait怎么处理呢？