Server TCP multithread con librerie POCO C++

Question

Sto provando a sviluppare un server TCP con librerie POCO C++. Ho trovato alcuni esempi here. All'inizio ho provato un esempio da Alex ma l'evento di chiusura non ha funzionato. EchoServer ha lo stesso problema. Quindi, ho provato l'esempio di Cesar Ortiz e ho avuto un problema insolito. Dopo un po 'time server genera un errore:

%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% 
["src/ErrorHandler.cpp", line 60] 
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% 

e collegamenti ottenuto l'errore di timeout di connessione, le nuove connessioni pure. Esempio con semeed Eventhandler più corretto, ma non so come posso risolvere l'evento di chiusura.

Answer 1

Se tutto ciò che si desidera è un server TCP multi-thread, allora "out of the box" lo farà Poco::Net::TCPServer - è multithreading internamente. Inizia con la definizione del collegamento, questo sarà solo l'eco di nuovo ciò che si invia ad esso:

class EchoConnection: public TCPServerConnection { 
public: 
    EchoConnection(const StreamSocket& s): TCPServerConnection(s) { } 

    void run() { 
    StreamSocket& ss = socket(); 
    try { 
     char buffer[256]; 
     int n = ss.receiveBytes(buffer, sizeof(buffer)); 
     while (n > 0) { 
     ss.sendBytes(buffer, n); 
     n = ss.receiveBytes(buffer, sizeof(buffer)); 
     } 
    } 
    catch (Poco::Exception& exc) 
    { std::cerr << "EchoConnection: " << exc.displayText() << std::endl; } 
    } 
}; 

Poi, eseguire il server e inviarlo alcuni dati:

TCPServer srv(new TCPServerConnectionFactoryImpl<EchoConnection>()); 
srv.start(); 

SocketAddress sa("localhost", srv.socket().address().port()); 
StreamSocket ss(sa); 
std::string data("hello, world"); 
ss.sendBytes(data.data(), (int) data.size()); 
char buffer[256] = {0}; 
int n = ss.receiveBytes(buffer, sizeof(buffer)); 
std::cout << std::string(buffer, n) << std::endl; 

srv.stop();