4

我正在使用 POCO C++ lib 1.4.3 版来实现 HTTP 服务器。在我的用例中,只有两个或三个客户端,我希望有持久连接。客户端使用 put 请求发送数据,服务器使用“HTTP/1.1 201 Created”回答。客户端打开多个连接。其中一个客户端可以同时打开 20 个连接。

我使用 HTTPServerParams 和 Poco::Net::ServerSocket (myPort) 中的默认值,并且我使用的是 Poco::ThreadPool (16,48)。

客户端发送一个 http put 请求,服务器回答:

Server:
HTTP/1.1 201 Created
Connection: Close
Date: Thu, 31 Jan 2013 15:21:50 GMT

我在 WireShark 的 PCAP 文件中看到了这个结果。

如果我不希望服务器在 put 请求后关闭连接,我该怎么办?

--- 编辑和插入源代码:

HTTPServer::HTTPServer(uint16_t port, 
                       Poco::Net::HTTPRequestHandlerFactory* handlerFactory):
m_port(port),
m_wasStarted(false)
{
    // HTTPServer takes ownership
Poco::Net::HTTPServerParams*   options = new Poco::Net::HTTPServerParams; 

try
{
    m_threadPool.reset(new Poco::ThreadPool (16,48));

    std::cout << "HTTPServerParams.keepAlive: " 
                  << options->getKeepAlive() << std::endl;

    std::cout << "HTTPServerParams.keepAliveTimeout: " 
                  << options->getKeepAliveTimeout().totalSeconds() << std::endl;

    std::cout << "HTTPServerParams.MaxKeepAliveRequests: " 
                  << options->getMaxKeepAliveRequests()<< std::endl;

    std::cout << "HTTPServerParams.Timeout: " 
                  << options->getTimeout().totalSeconds() << std::endl;

    m_server.reset(new Poco::Net::HTTPServer(handlerFactory,  
                                                 *m_threadPool,
                                                 Poco::Net::ServerSocket(m_port),
                                                                         options)
                                                );
}
catch (const Poco::Exception& e)
{
       //some code ...
}
}

HTTPServer 类的私有成员:

 uint16_t                                m_port;
 bool                                    m_wasStarted;
 std::auto_ptr<Poco::ThreadPool>         m_threadPool;
 std::auto_ptr<Poco::Net::HTTPServer>    m_server;
4

1 回答 1

6

您是否尝试过对setKeepAlive(true);的实例使用成员函数调用?HTTPServerParams

顺便看看setKeepAliveTimeout()同一个类的成员函数。

更新

我发现了一些有趣的事情:如果该sendBuffer()函数用于发送响应,那么响应包含Connection: Keep-Alive值;但是当使用该send()函数时,响应包含该Connection: Close值。

所以,有趣的实现细节在这里:poco/Net/src/HTTPServerResponseImpl.cpp。请参阅实现send()sendBuffer()成员函数。

于 2013-01-31T17:38:28.463 回答