POCO C++ライブラリを備えたマルチスレッドTCPサーバ

Question

私はPOCO C++ライブラリを使用してTCPサーバを開発しようとしています。 私はいくつかの例を見つけましたhere。 最初はAlexからの例を試しましたが、シャットダウンイベントは機能しませんでした。 EchoServerにも同じ問題があります。 それで、私はCesar Ortizの例を試してみたところ、異常な問題がありました。いくつかの時間の後にサーバーがエラーをスローする：

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

接続には接続タイムアウトエラーが発生し、新しい接続もあります。 イベントハンドラのセードの例が正しいですが、シャットダウンイベントを修正する方法がわかりません。

Answer 1

マルチスレッドTCPサーバーが必要な場合は、すぐにPoco::Net::TCPServerが実行されます。これは内部的にマルチスレッド化されています。接続を定義すると スタート、これはちょうどあなたがそれに送るものは何でもエコーバックします：

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

その後、サーバーを実行し、それをいくつかのデータを送信します。返信アレックスのため

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