第oaptt搭建http服務(wù)的過(guò)程詳解Oat++介紹

Oat++主頁(yè)：https://oatpp.io

Oat++文檔：https://oatpp.io/docs/start

GitHub地址：/oatpp/oatpp

編譯Oat++

環(huán)境要求

Oat++的編譯過(guò)程很簡(jiǎn)單，只需要有基本的開(kāi)發(fā)環(huán)境就行了：

Git編譯器支持的C++版本=11MakeCMake版本=3.1

如果沒(méi)有的話(huà)，按照下述步驟安裝，以Ubuntu為例：

sudoaptinstallgit

sudoaptinstallcmake

sudoaptinstallbuild-essential

編譯安裝

下載Oat++源碼：

gitclone/oatpp/oatpp.git

隨后，執(zhí)行編譯安裝四部曲：

cdoatpp/

mkdirbuildcdbuild

cmake..

sudomakesudomakeinstall

hello示例程序

為了演示Oat++，我們從最簡(jiǎn)單的Hello,World！開(kāi)始！

創(chuàng)建一個(gè)CMake項(xiàng)目，CMakeLists.txt配置如下：

cmake_minimum_required(VERSION3.1)

project(helloworld)

set(CMAKE_CXX_STANDARD11)

set(SOURCE_FILESmain.cpphandler.h)

#查找oatpp依賴(lài)

find_package(oatppREQUIRED)

add_executable(${PROJECT_NAME}${SOURCE_FILES})

#將目標(biāo)文件與庫(kù)文件進(jìn)行鏈接

target_link_libraries(${PROJECT_NAME}oatpp::oatpp)

handler.h

//handler.h

#ifndefHANDLER_H

#defineHANDLER_H

#include"oatpp/web/server/HttpRequestHandler.hpp"

#defineO_UNUSED(x)(void)x;

//自定義請(qǐng)求處理程序

classHandler:publicoatpp::web::server::HttpRequestHandler

public:

//處理傳入的請(qǐng)求，并返回響應(yīng)

std::shared_ptrOutgoingResponsehandle(conststd::shared_ptrIncomingRequestrequest)override{

O_UNUSED(request);

returnResponseFactory::createResponse(Status::CODE_200,"Hello,World!");

#endif//HANDLER_H

main.cpp

//main.cpp

#include"oatpp/web/server/HttpConnectionHandler.hpp"

#include"oatpp/network/tcp/server/ConnectionProvider.hpp"

#include"oatpp/network/Server.hpp"

#include"handler.h"

voidrun()

//為HTTP請(qǐng)求創(chuàng)建路由器

autorouter=oatpp::web::server::HttpRouter::createShared();

//路由GET-"/hello"請(qǐng)求到處理程序

router-route("GET","/hello",std::make_sharedHandler

//創(chuàng)建HTTP連接處理程序

autoconnectionHandler=oatpp::web::server::HttpConnectionHandler::createShared(router);

//創(chuàng)建TCP連接提供者

autoconnectionProvider=oatpp::network::tcp::server::ConnectionProvider::createShared({"",8080,oatpp::network::Address::IP_4});

//創(chuàng)建服務(wù)器，它接受提供的TCP連接并將其傳遞給HTTP連接處理程序

oatpp::network::Serverserver(connectionProvider,connectionHandler);

//打印服務(wù)器端口

OATPP_LOGI("MyApp","Serverrunningonport%s",connectionProvider-getProperty("port").getData());

//運(yùn)行服務(wù)器

server.run();

intmain()

//初始化oatpp環(huán)境

oatpp::base::Environment::init();

//運(yùn)行應(yīng)用

run();

//銷(xiāo)毀oatpp環(huán)境

oatpp::base::Environment::destroy();

return0;

編譯helloworld程序

mkdirbuild

cdbuild

cmake..

./helloworld

運(yùn)行結(jié)果如下

HTTP模擬Onvif功能

啟動(dòng)HTTP服務(wù)器模擬Onvif服務(wù)端，接收Onvif客戶(hù)端發(fā)送過(guò)來(lái)的http請(qǐng)求并響應(yīng)xml數(shù)據(jù)

項(xiàng)目背景和解決方案點(diǎn)這里

CMakeList.txt

cmake_minimum_required(VERSION3.1)

project(helloworld)

set(CMAKE_CXX_STANDARD11)

set(SOURCE_FILESmain.cpphandler.h)

#查找oatpp依賴(lài)

find_package(oatppREQUIRED)

add_executable(${PROJECT_NAME}${SOURCE_FILES})

#將目標(biāo)文件與庫(kù)文件進(jìn)行鏈接

target_link_libraries(${PROJECT_NAME}oatpp::oatpp)

handler.h

//handler.h

#ifndefHANDLER_H

#defineHANDLER_H

#include"oatpp/web/server/HttpRequestHandler.hpp"

#include"oatpp/web/protocol/http/incoming/Response.hpp"

#includefcntl.h

#includeunistd.h

#includesys/stat.h

#includeunistd.h

#defineO_UNUSED(x)(void)x;

#defineXML_INFO"xmlversion=\"1.0\"encoding=\"utf-8\"standalone=\"yes\""

//自定義請(qǐng)求處理程序

classHandler:publicoatpp::web::server::HttpRequestHandler

public:

//處理傳入的請(qǐng)求，并返回響應(yīng)

std::shared_ptrOutgoingResponsehandle(conststd::shared_ptrIncomingRequestrequest)override{

//O_UNUSED(request);

OATPP_LOGI("MyApp","newconnect..");

//printf("method:%d");

intfileFd=open("../test.xml",O_RDONLY);

if(fileFd0)

return0;

//獲取文件大小

structstatfileStat;

fstat(fileFd,fileStat);

intfileSize=fileStat.st_size;

printf("fd:%d,filesize%d\n",fileFd,fileStat.st_size);

//申請(qǐng)空間存儲(chǔ)xml數(shù)據(jù)

charbuf[1024*5];

memset(buf,'\0',sizeof(buf));

read(fileFd,buf,sizeof(buf));

printf("newconnect..\n");

printf("buf:%s\n\n",buf);

//創(chuàng)建響應(yīng)并添加請(qǐng)求頭

std::shared_ptrOutgoingResponseresp=ResponseFactory::createResponse(Status::CODE_200,buf);

resp-putHeader("Content-Type","application/soap+xml;charset=utf-8;action=\"/ver20/media/wsdl/GetOSDs\"");

//resp-putHeader("charset","utf-8");

//resp-putHeader("action","\"/ver20/media/wsdl/GetOSDs\"");

resp-putHeader("X-Frame-Options","SAMEORIGIN");

close(fileFd);

returnresp;//響應(yīng)請(qǐng)求

#endif//HANDLER_H

main.cpp

//main.cpp

#include"oatpp/web/server/HttpConnectionHandler.hpp"

#include"oatpp/network/tcp/server/ConnectionProvider.hpp"

#include"oatpp/network/Server.hpp"

#include"handler.h"

voidrun()

//為HTTP請(qǐng)求創(chuàng)建路由器

autorouter=oatpp::web::server::HttpRouter::createShared();

//路由GET-"/hello"請(qǐng)求到處理程序

router-route("POST","/onvif/Media2",std::make_sharedHandler

//創(chuàng)建HTTP連接處理程序

autoconnectionHandler=oatpp::web::server::HttpConnectionHandler::createShared(router);

//創(chuàng)建TCP連接提供者

autoconnectionProvider=oatpp::network::tcp::server::ConnectionProvider::createShared({"",7681,oatpp::network::Address::IP_4});

//創(chuàng)建服務(wù)器，它接受提供的TCP連接并將其傳遞給HTTP連接處理程序

oatpp::network::Serverserver(connectionProvider,connectionHandler);

//打印服務(wù)器端口

OATPP_LOGI("MyApp","Serverrunningonport%s",connectionProvider-getProperty("port").getData());

//運(yùn)行服務(wù)器

server.run();

intmain()

//初始化oatpp環(huán)境

oatpp::base::Environment::init();

//運(yùn)行應(yīng)用

run();

//銷(xiāo)毀oatpp環(huán)境

oatpp::base: