Poco：创建个非常简单web服务器

逃离我推掉我的手 2023-09-25 12:59 49阅读 0赞

C++ Poco创建个非常简单web服务器，需要先安装Poco库，配置好Poco头文件和库的路径，window和Linux下都可以编译运行，运行后在浏览器上输入网址：http://127.0.0.1:9980/

## 一、案例01 ##

Linux环境下G++编译代码

g++ main01.cpp -o main01.exe -L/usr/local/lib/   -lPocoUtil  -lPocoFoundation   -lPocoNet

在控制台执行：

./main01.exe

#include <Poco/Net/ServerSocket.h>
    #include <Poco/Net/HTTPServer.h>
    #include <Poco/Net/HTTPRequestHandler.h>
    #include <Poco/Net/HTTPRequestHandlerFactory.h>
    #include <Poco/Net/HTTPResponse.h>
    #include <Poco/Net/HTTPServerRequest.h>
    #include <Poco/Net/HTTPServerResponse.h>
    #include <Poco/Util/ServerApplication.h>
    #include <iostream>
    #include <string>
    #include <vector>
    
    using namespace std;
    using namespace Poco::Net;
    using namespace Poco::Util;
    
    // 页面处理器 链接到来的时候 直接打印html内容
    class MyRequestHandler : public HTTPRequestHandler {
    public:
        virtual void handleRequest(HTTPServerRequest& req, HTTPServerResponse& resp) {
            resp.setStatus(HTTPResponse::HTTP_OK);
            resp.setContentType("text/html");
            ostream& out = resp.send();
            out << "<font color='blue'>Hello World!</font>";
        }
    };
    
    // HTTP请求处理器工厂 
    class MyRequestHandlerFactory : public HTTPRequestHandlerFactory {
    public:
        virtual HTTPRequestHandler* createRequestHandler(const HTTPServerRequest&) {
            return new MyRequestHandler;
        }
    };
    
    // 网络应用程序的启动器 都是ServerApplication
    class MyServerApp :public ServerApplication {
    protected:
        int main(const vector<string>&) {
            HTTPServer s(new MyRequestHandlerFactory, ServerSocket(9980), new HTTPServerParams);
            s.start();
            cout << endl << "Server started" << endl;
            waitForTerminationRequest();  // wait for CTRL-C or kill
            cout << endl << "Shutting down..." << endl;
            s.stop();
            return Application::EXIT_OK;
        }
    };
    
    int main(int argc, char** argv) {
        MyServerApp app;
        return app.run(argc, argv);
    }

![3710f5e3eab5450f9922644172ce734d.png][]

## 二、案例02 ##

#include "Poco/Net/HTTPServer.h"   //继承自TCPServer 实现了一个完整的HTTP多线程服务器
    #include "Poco/Net/HTTPRequestHandler.h"   //抽象基类类 被HttpServer所创建 用来处理Http的请求
    #include "Poco/Net/HTTPRequestHandlerFactory.h" //HTTPRequestHandler的工厂 给予工厂设计模式 
    #include "Poco/Net/HTTPServerParams.h"    //被用来指定httpserver以及HTTPRequestHandler的参数
    #include "Poco/Net/HTTPServerRequest.h"  //ServerRequest的抽象子类用来指定 服务器端的 http请求
    #include "Poco/Net/HTTPServerResponse.h" //ServerResponse的抽象子类用来指定服务器端的http响应
    #include "Poco/Net/ServerSocket.h"  //提供了一个TCP服务器套接字接口
    #include "Poco/Net/WebSocket.h"  //这个类实现了RFC 6455 web套接字接口  专门针对web服务器用
    #include "Poco/Net/NetException.h"  //网络异常
    #include "Poco/Util/ServerApplication.h" //Application的子类 所有服务器程序 包括 Reactor FTP HTTP等都用到 算是服务器的启动类 
    #include "Poco/Util/Option.h"  //存储了命令行选项
    #include "Poco/Util/OptionSet.h"  //一个Opention对象的集合
    #include "Poco/Util/HelpFormatter.h" //从OptionSet格式化帮助信息
    #include "Poco/Format.h"  //格式化函数的实现类似于 C的 sprintf函数 具体看文档
    #include <iostream>
    
    
    using Poco::Net::ServerSocket;
    using Poco::Net::WebSocket;
    using Poco::Net::WebSocketException;
    using Poco::Net::HTTPRequestHandler;
    using Poco::Net::HTTPRequestHandlerFactory;
    using Poco::Net::HTTPServer;
    using Poco::Net::HTTPServerRequest;
    using Poco::Net::HTTPResponse;
    using Poco::Net::HTTPServerResponse;
    using Poco::Net::HTTPServerParams;
    using Poco::Timestamp;
    using Poco::ThreadPool;
    using Poco::Util::ServerApplication;
    using Poco::Util::Application;
    using Poco::Util::Option;
    using Poco::Util::OptionSet;
    using Poco::Util::HelpFormatter;
    
    // 页面处理器 链接到来的时候 直接打印html内容
    class PageRequestHandler : public HTTPRequestHandler {
        /// Return a HTML document with some JavaScript creating
        /// a WebSocket connection.
    public:
        void handleRequest(HTTPServerRequest& request, HTTPServerResponse& response)
        {
    
            response.setChunkedTransferEncoding(true);
            response.setContentType("text/html");
            std::ostream& ostr = response.send();
            ostr << "<html>";
            ostr << "<body>";
            ostr << "  <font color='red'>WebSocket Server</font>";
            ostr << "</body>";
            ostr << "</html>";
        }
    };
    
    // http请求处理器 1
    class WebSocketRequestHandler : public HTTPRequestHandler {
        /// Handle a WebSocket connection.
    public:
        void handleRequest(HTTPServerRequest& request, HTTPServerResponse& response)
        {
            Application& app = Application::instance();
            try
            {
                WebSocket ws(request, response);
                app.logger().information("WebSocket connection established.");
                char buffer[1024];
                int flags;
                int n;
                do
                {
                    n = ws.receiveFrame(buffer, sizeof(buffer), flags);
                    app.logger().information(Poco::format("Frame received (length=%d, flags=0x%x).", n, unsigned(flags)));
                    ws.sendFrame(buffer, n, flags);
                } while (n > 0 || (flags & WebSocket::FRAME_OP_BITMASK) != WebSocket::FRAME_OP_CLOSE);
                app.logger().information("WebSocket connection closed.");
            }
            catch (WebSocketException& exc)
            {
                app.logger().log(exc);
                switch (exc.code())
                {
                case WebSocket::WS_ERR_HANDSHAKE_UNSUPPORTED_VERSION:
                    response.set("Sec-WebSocket-Version", WebSocket::WEBSOCKET_VERSION);
                    // fallthrough
                case WebSocket::WS_ERR_NO_HANDSHAKE:
                case WebSocket::WS_ERR_HANDSHAKE_NO_VERSION:
                case WebSocket::WS_ERR_HANDSHAKE_NO_KEY:
                    response.setStatusAndReason(HTTPResponse::HTTP_BAD_REQUEST);
                    response.setContentLength(0);
                    response.send();
                    break;
                }
            }
        }
    };
    
    // HTTP请求处理器工厂 
    class RequestHandlerFactory : public HTTPRequestHandlerFactory {
    public:
        HTTPRequestHandler* createRequestHandler(const HTTPServerRequest& request) //覆盖方法 
        {
            Application& app = Application::instance();
            app.logger().information("Request from "
                + request.clientAddress().toString()
                + ": "
                + request.getMethod()
                + " "
                + request.getURI()
                + " "
                + request.getVersion());
            //打印所有链接请求
            for (HTTPServerRequest::ConstIterator it = request.begin(); it != request.end(); ++it)
            {
                app.logger().information(it->first + ": " + it->second);
            }
            //可以选择输出html页面 或者不输出  通过http请求参数
            if (request.find("Upgrade") != request.end() && request["Upgrade"] == "websocket")
                return new WebSocketRequestHandler;
            else
                return new PageRequestHandler;
        }
    };
    
    // 网络应用程序的启动器 都是ServerApplication
    class WebSocketServer : public Poco::Util::ServerApplication {
    public:
        WebSocketServer() : _helpRequested(false) {}
        ~WebSocketServer() {}
    
    protected:    ///再启动的时候先调用
        void initialize(Application& self) {
            loadConfiguration(); // load default configuration files, if present
            ServerApplication::initialize(self);
        }
        //在释放的时候调用    
        void uninitialize() {
            ServerApplication::uninitialize();
        }
        ///覆盖基类的函数 定义一些命令选项
        void defineOptions(OptionSet& options) {
            ServerApplication::defineOptions(options);
            options.addOption(
                Option("help", "h", "display help information on command line arguments")
                .required(false)
                .repeatable(false));
        }
        ///处理命令行选项 
        void handleOption(const std::string& name, const std::string& value) {
            ServerApplication::handleOption(name, value);
            if (name == "help")
                _helpRequested = true;
        }
        //打印帮助
        void displayHelp() {
            HelpFormatter helpFormatter(options());
            helpFormatter.setCommand(commandName());
            helpFormatter.setUsage("OPTIONS");
            helpFormatter.setHeader("A sample HTTP server supporting the WebSocket protocol.");
            helpFormatter.format(std::cout);
        }
        //在初始化完毕之后调用
        int main(const std::vector<std::string>& args) {
            if (_helpRequested) {
                displayHelp();
            }
            else {
                // get parameters from configuration file            //从配置文件中获取端口
                unsigned short port = (unsigned short)config().getInt("WebSocketServer.port", 9980);
                // 安装一个ServerSocket
                ServerSocket svs(port);
                // s安装一个HttpServer实例  并且传递 请求处理器工厂  和一个HttpServerParams对象
                HTTPServer srv(new RequestHandlerFactory, svs, new HTTPServerParams);
                // 启动服务器
                srv.start();
                // 等待kill 或者控制台CTRL+C
                waitForTerminationRequest();
                // 停止HTTP服务器
                srv.stop();
            }
            return Application::EXIT_OK;  //返回正常退出状态
        }
    
    private:
        bool _helpRequested;
    };
    
    //启动web 服务器
    POCO_SERVER_MAIN(WebSocketServer)

![c290158070cd42e684670449db5fb6dd.png][]

[C++Poco创建个非常简单web服务器\_c++搭建web服务器-C++文档类资源-CSDN下载][C_Poco_web_c_web_-C_-CSDN]

[3710f5e3eab5450f9922644172ce734d.png]: https://img-blog.csdnimg.cn/3710f5e3eab5450f9922644172ce734d.png
[c290158070cd42e684670449db5fb6dd.png]: https://img-blog.csdnimg.cn/c290158070cd42e684670449db5fb6dd.png
[C_Poco_web_c_web_-C_-CSDN]: https://download.csdn.net/download/arfu123/12529327?utm_medium=distribute.pc_aggpage_search_result.none-task-download-2~aggregatepage~first_rank_ecpm_v1~rank_v31_ecpm-3-12529327-null-null.pc_agg_new_rank&utm_term=c%2B%2Bpoco&spm=1000.2123.3001.4430