Дизайн сервера чата «основного» цикла - PullRequest
Новая
       82

Дизайн сервера чата «основного» цикла

0 голосов
/ 07 сентября 2010

Я пишу на маленьком tcp-сервере чата, но у меня возникают некоторые проблемы, которые я не могу понять, как решить «элегантно».

Ниже приведен код для моего основного цикла: он выполняет:
1. Инициирует вектор базовым событием, которое отмечается при создании нового соединения tcp.
2. получает это соединение и возвращает его обратно в вектор.Затем с помощью сокета он создает объект CSingleConnection и передает в него сокет.
2.1.получает событие из CSingleConnection, которое помечается, когда соединение получает данные ...
3. когда оно получает данные.ожидание заполнено и возвращает номер дескриптора в массиве ... со всеми этими другими векторами кажется, что я могу определить, какой из них отправляет сейчас ...

, но, как все видят, эта методологияочень плохо ... Я не могу понять, как сделать все это лучше, с получением сокета соединения, созданием одного соединения и так далее: /...

Любые предложения, улучшения и т.д? ...

void CServer::MainLoop()
{
    DWORD dwResult = 0;
    bool bMainLoop = true;
    std::vector<std::string> vecData;
    std::vector<HANDLE> vecEvents;              //Contains the handles to wait on
    std::vector<SOCKET> vecSocks;               //contains the sockets
    enum
    {
        ACCEPTOR = 0,           //First element: sequence is mandatory

        EVENTSIZE                   //Keep as the last element!
    };

    //initiate the vector with the basic handles
    vecEvents.clear();
    GetBasicEvents(vecEvents);

    while(bMainLoop)
    {
        //wait for event handle(s)
        dwResult = WaitForMultipleObjects(vecEvents.size(), &vecEvents[0], true, INFINITE);

        //New connection(s) made
        if(dwResult == (int)ACCEPTOR)
        {
            //Get the sockets for the new connections
            m_pAcceptor->GetOutData(vecSocks);

            //Create new connections
            for(unsigned int i = 0; i < vecSocks.size(); i++)
            {
                //Add a new connection
                CClientConnection Conn(vecSocks[i]);
                m_vecConnections.push_back(Conn);
                //Add event
                vecEvents.push_back(Conn.GetOutEvent());
            }
        }

        //Data from one of the connections
        if(dwResult >= (int)EVENTSIZE)
        {
            Inc::MSG Msg;
            //get received string data
            m_vecConnections[dwResult].GetOutData(vecData);

            //handle the data
            for(unsigned int i = 0; i < vecData.size(); i++)
            {
                //convert data into message
                if(Inc::StringToMessage(vecData[i], Msg) != Inc::SOK)
                    continue;
                //Add the socket to the sender information
                Msg.Sender.sock = vecSocks[dwResult];
                //Evaluate and delegate data and task
                EvaluateMessage(Msg);
            }
        }
    }
}

1 Ответ

1 голос
/ 07 сентября 2010

Не изобретайте велосипед заново, используйте Boost.ASIO . Он хорошо оптимизирован с использованием особенностей ядра различных операционных систем и разработан так, чтобы упростить архитектуру клиентского кода. Существует множество примеров и документации, поэтому вы просто не поймете неправильно.

...