POCO C++ ライブラリ – 初心者でも簡単にできるサーバー構築

cmake .. && cmake --build .

cmake --build . --target install

cmake-gui .

#include <iostream>

#include "Poco/Net/HTTPServer.h"
#include "Poco/Net/HTTPRequestHandler.h"
#include "Poco/Net/HTTPRequestHandlerFactory.h"
#include "Poco/Net/HTTPServerParams.h"
#include "Poco/Net/HTTPServerRequest.h"
#include "Poco/Net/HTTPServerResponse.h"
#include "Poco/Net/HTTPServerParams.h"
#include "Poco/Net/ServerSocket.h"
#include "Poco/Util/ServerApplication.h"
#include "Poco/JSON/JSON.h"
#include "Poco/JSON/Object.h"
#include "Poco/JSON/Stringifier.h"


// httpのリクエストでEndpointが"/test2"と指定された場合に実行される関数
class Test2RequestHandler : public Poco::Net::HTTPRequestHandler {
public:

    void handleRequest(Poco::Net::HTTPServerRequest& request, Poco::Net::HTTPServerResponse& response) {
        std::cout << "Test2RequestHandler" << std::endl;

        // HTTP レスポンスの設定
        response.setStatus(Poco::Net::HTTPResponse::HTTP_OK);

        // HTTP レスポンスの送信
        std::ostream& out = response.send();
    
    }
};


// httpのリクエストでEndpointが"/test1"と指定された場合に実行される関数（Jsonデータを返却する）
class Test1RequestHandler : public Poco::Net::HTTPRequestHandler {
public:

    void handleRequest(Poco::Net::HTTPServerRequest& request, Poco::Net::HTTPServerResponse& response) {
        std::cout << "Test1RequestHandler" << std::endl;

        // JSON オブジェクトを作成
        Poco::JSON::Object json;
        json.set("key1", "value1");
        json.set("key2", "value2");

        // JSON オブジェクト を文字列に変換
        std::ostringstream jsonStream;
        Poco::JSON::Stringifier::stringify(json, jsonStream);

        // HTTP レスポンスの設定
        response.setStatus(Poco::Net::HTTPResponse::HTTP_OK);
        response.setContentType("application/json");
        response.setContentLength(jsonStream.str().length());

        // JSON データをレスポンスに書き込む
        std::ostream& out = response.send();
        out << jsonStream.str();
    }
};


// 作成したサーバーがhttpリクエストを受けたときに実行される関数
class TestRequestHandlerFactory : public Poco::Net::HTTPRequestHandlerFactory
{
public:

    Poco::Net::HTTPRequestHandler* createRequestHandler(const Poco::Net::HTTPServerRequest& request) {
        std::cout << "TestRequestHandlerFactory" << std::endl;

        // Endpointの判断
        if (request.getURI() == "/test1") {
            return new Test1RequestHandler();
        }
        else if (request.getURI() == "/test2") {
            return new Test2RequestHandler();
        }
        else {
            // その他のリクエストは処理しない
            return nullptr;
        }
    }
};


// サーバーを構築する関数
class TestServer : public Poco::Util::ServerApplication
{
protected:

    int main(const std::vector<std::string>& args)
    {
        int maxThreads = 5;                            // クライアント最大同時接続数

        // 接続スレッド数設定
        Poco::ThreadPool::defaultPool().addCapacity(maxThreads);

        // 設定値クラス
        Poco::Net::HTTPServerParams* params = new Poco::Net::HTTPServerParams;

        params->setMaxQueued(100);                    // 接続要求ソケット最大数
        params->setMaxThreads(maxThreads);
        Poco::Net::ServerSocket svs(8080);            // 8080ポート使用

        // HTTPサーバクラスのインスタンス
        Poco::Net::HTTPServer    srv(new TestRequestHandlerFactory(), svs, params);

        // サーバ動作開始
        srv.start();
        std::cout << "Server Start" << std::endl;

        // CTRL-C が押されるまで、
        // またはプロセスが強制終了されるまで待機
        waitForTerminationRequest();

        // サーバ動作ストップ
        srv.stop();

        return Application::EXIT_OK;
    }
};


int main(int argc, char** argv) {
    TestServer app;
    return app.run(argc, argv);
}

curl -verbose -X POST http://localhost:8080/test1

curl -verbose -X POST http://localhost:8080/test2