使用 Poco 和 Boost C++ 的多个 Http 服务器

我正在尝试使用 Poco::Net 和 Boost 库创建多个 Http 服务器，但在 Poco 文件内部出现以下错误应用程序.cpp:

%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
Assertion violation: _pInstance == 0 [in file "src/Application.cpp", line 115]
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%

我正在使用下面的代码：

#include <Poco/Net/HTMLForm.h>
#include <Poco/Net/HTTPServerRequest.h>
#include <Poco/Net/HTTPServerResponse.h>
#include <boost/asio/io_service.hpp>

boost::asio::io_service service(100);

class RequestHandler : public Poco::Net::HTTPRequestHandler {
public:
    RequestHandler(){}
    void handleRequest(Poco::Net::HTTPServerRequest& request, Poco::Net::HTTPServerResponse& response){}
};

class RequestHandlerFactory : public Poco::Net::HTTPRequestHandlerFactory {
public:
    RequestHandlerFactory(){}
    Poco::Net::HTTPRequestHandler* createRequestHandler(const Poco::Net::HTTPServerRequest& request)
    {
        return new RequestHandler();
    }
};

class HttpServer :
        public Poco::Util::ServerApplication,
        public boost::enable_shared_from_this<HttpServer>{

    Poco::Net::ServerSocket svs;
    Poco::Net::HTTPServer srv;

public:
    HttpServer(std::string address_, Poco::UInt16 port_):
        svs(Poco::Net::SocketAddress(address_.empty() ? "127.0.0.1" : address_, port_)),
        srv(new RequestHandlerFactory(), svs, new Poco::Net::HTTPServerParams)
    {
        svs.setReuseAddress(true);
        svs.setReusePort(true);
    }

    virtual ~HttpServer(){}

    void start()
    {
        service.post(
            boost::bind(&HttpServer::exec, shared_from_this()));
    }

    void stop()
    {
        srv.stop();
    }

private:
    void exec()
    {
        srv.start();
        waitForTerminationRequest();
        srv.stop();
    }    
};

这是服务器的主要代码，例如我在 main 函数中创建服务器。 这服务.postcall，用于方法的异步调用exec以及建设服务(100)指的是大小为100的线程池。

服务器创建如下：

boost::shared_ptr<HttpServer> server(
        new HttpServer("", 8080));

boost::shared_ptr<HttpServer> server2(
        new HttpServer("", 8181));

server->start();
server2->start(); // Error occurs here

启动第二个服务器时会显示该错误。

HttpServerApplication不适合以这种方式使用。它被设计为单例。

http://pocoproject.org/docs/Poco.Util.ServerApplication.html http://pocoproject.org/docs/Poco.Util.ServerApplication.html

您可以通过不派生来修复该部分ServerApplication在你的HttpServer班级。毕竟，您需要多个服务器，而不是应用程序。

在我最简单的测试中，以下工作有效：

#include <Poco/Net/HTMLForm.h>
#include <Poco/Net/HTTPRequestHandler.h>
#include <Poco/Net/HTTPRequestHandlerFactory.h>
#include <Poco/Net/ServerSocket.h>
#include <Poco/Net/HTTPServer.h>
#include <Poco/Util/ServerApplication.h>
#include <Poco/Net/HTTPServerRequest.h>
#include <Poco/Net/HTTPServerResponse.h>
#include <boost/enable_shared_from_this.hpp>
#include <boost/asio/io_service.hpp>
#include <boost/make_shared.hpp>
#include <boost/bind.hpp>

boost::asio::io_service service(100);

class RequestHandler : public Poco::Net::HTTPRequestHandler {
public:
    RequestHandler(){}
    void handleRequest(Poco::Net::HTTPServerRequest& request, Poco::Net::HTTPServerResponse& response){}
};

class RequestHandlerFactory : public Poco::Net::HTTPRequestHandlerFactory {
public:
    RequestHandlerFactory(){}
    Poco::Net::HTTPRequestHandler* createRequestHandler(const Poco::Net::HTTPServerRequest& request)
    {
        return new RequestHandler();
    }
};

class HttpServer : public boost::enable_shared_from_this<HttpServer>{

    Poco::Net::ServerSocket svs;
    Poco::Net::HTTPServer srv;

public:
    HttpServer(std::string address_, Poco::UInt16 port_):
        svs(Poco::Net::SocketAddress(address_.empty() ? "127.0.0.1" : address_, port_)),
        srv(new RequestHandlerFactory(), svs, new Poco::Net::HTTPServerParams)
    {
        svs.setReuseAddress(true);
        svs.setReusePort(true);
    }

    virtual ~HttpServer(){}

    void start()
    {
        service.post(
            boost::bind(&HttpServer::exec, shared_from_this()));
    }

    void stop()
    {
        srv.stop();
    }

private:
    void exec()
    {
        srv.start();
    }    
};

In main，我创建了一个子类ServerApplication调用受保护方法的唯一原因waitForTerminationRequest()在 main 退出之前。如果需要参数解析，当然通过argc, argv to app.run。但目前我认为没有必要。

int main() {
    struct App : Poco::Util::ServerApplication {
        ~App() {
            waitForTerminationRequest();
        }
    } app;

    for (int i=0; i<2; ++i) {
        boost::make_shared<HttpServer>("", 8080+i)->start();
    }
}

旧答案文本

你如何实例化HttpServer物体？

1. 显然，你应该使用boost::make_shared<HttpServer>(host, port) (or shared_ptr<HttpServer>(new HttpServer(host, port))) for enable_shared_from_this被允许。不要忘记至少在服务启动之前保留共享 ptr（通过发布它exec()拨电至io_service).

   具体来说，这是非法的：

   for (int i=0; i<10; ++i) {
       HttpServer s("", 8080+i);
       s.start();
   }
   

   相反，使用例如

   for (int i=0; i<10; ++i) {
       boost::make_shared<HttpServer>("", 8080+i)->start();
   }
   

2. 另外，如果您要在 100 个线程的池上运行它，您need要么使用strand（对于执行的逻辑线程）or锁定HttpServer在任何线程上使用该对象之前。

   • 为什么使用 boost::asio 时每个连接都需要链？ https://stackoverflow.com/questions/12794107/why-do-i-need-strand-per-connection-when-using-boostasio/12801042#12801042