Multithread-TCP-Server mit POCO C++ - Bibliotheken

Question

Ich versuche, einen TCP-Server mit POCO C++ - Bibliotheken zu entwickeln. Ich fand einige Beispiele here. Zuerst versuchte ich Beispiel von Alex, aber Shutdown-Ereignis hat nicht funktioniert. EchoServer haben das gleiche Problem. Also, dann habe ich Cesar Ortiz Beispiel versucht und ein ungewöhnliches Problem bekommen. Nach einiger Zeit wirft Server einen Fehler:

Und Verbindungen bekam Verbindung Timeout-Fehler, neue Verbindungen sowie. Beispiel mit Eventhandler semeed mehr korrekt, aber ich weiß nicht, wie ich Shutdown-Ereignis beheben kann.

Answer 1

Wenn alles, was Sie wollen, Multithread-TCP-Server ist, dann wird "out of the box" Poco::Net::TCPServer tun - es ist intern Multithreading. Starten Sie die Verbindung mit der Definition, wird dies ein Echo nur zurück, was auch immer Sie es an:

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; } 
    } 
}; 

Dann den Server laufen und es einige Daten senden:

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();