如何保持服务器运行(cpprestsdk - casablanca)
How to keep server running (cpprestsdk - casablanca)
我正在使用Microsoft的cpprestsdk(又名卡萨布兰卡(开发一个REST api,并且在执行代码时无法保持服务器运行。
在这里查看我的主要.cpp:
int main() {
cout << "Starting Server" << endl;
TransactionController server;
server.setEndpoint("http://0.0.0.0:4200/api");
server.initHandlers();
try {
server.openServer();
cout << "Server listening at: " << server.getEndpoint() << endl;
// figure out how to keep server running without this?
while (true);
}
catch(exception &e) {
cout << "--- ERROR DETECTED ---" << endl;
cout << e.what() << endl;
}
// this doesn't get reached bc of the while(true)
server.closeServer();
return 0;
}
此外,作为参考,这是我的主要实现或功能.cpp:
pplx::task<void> TransactionController::openServer() {
return listener.open();
}
pplx::task<void> TransactionController::closeServer() {
return listener.close();
}
std::string TransactionController::getEndpoint() const{
return listener.uri().to_string();
}
void TransactionController::initHandlers() {
listener.support(methods::GET, bind(&TransactionController::handleGet, this, std::placeholders::_1));
listener.support(methods::POST, bind(&TransactionController::handlePost, this, placeholders::_1));
}
void TransactionController::setEndpoint(const string& value) {
listener = http_listener(value);
}
我发现了一个不理想的解决方法,即添加一个
while(true);
保持服务器运行,直到我手动停止执行。
但是,我想以更优雅的方式实现此功能。我已经在网上浏览了文档,但未能找到正确的方法。
任何正确方向的提示或指示将不胜感激,因为我以前从未与卡萨布兰卡合作过。谢谢你的时间!
所以我设法使用此处提供的代码来弄清楚:
https://github.com/ivanmejiarocha/micro-service/blob/master/source/foundation/include/usr_interrupt_handler.hpp
这是我的新主.cpp:
int main() {
cout << "Starting Server" << endl;
InterruptHandler::hookSIGINT();
TransactionController server;
server.setEndpoint("http://0.0.0.0:4200/api");
server.initHandlers();
try {
server.openServer().wait();
cout << "Server listening at: " << server.getEndpoint() << endl;
InterruptHandler::waitForUserInterrupt();
server.closeServer().wait();
cout << "Shutting Down Server" << endl;
}
catch(exception &e) {
cout << "--- ERROR DETECTED ---" << endl;
cout << e.what() << endl;
}
return 0;
}
将 std::signal
与接受的 anwser 中表示的信号处理程序一起使用在这里并不是一个真正的选择,因为根据C++参考:
信号处理程序应具有 C 链接,并且通常只有使用 C 和 C++ 的公共子集中的功能。是的如果具有C++链接的函数可以用作信号处理程序。
然而,notify_{one,all}
不是信号安全的,因此不能在信号处理程序中使用。
或者,由于cpprestsdk依赖于升压asio,因此可以利用io_context进行信号处理。下面的代码片段演示了这个概念:
void handle_get(web::http::http_request request) {
//...
}
void interrupt_handler( const boost::system::error_code& error , int signal_number ) {
//...
}
int main() {
using web::http::experimental::listener::http_listener;
auto url = web::http::uri("http://127.0.0.1:8051");
http_listener listener(url);
listener.support(web::http::methods::GET, handle_get);
listener.open().then([]() { std::cout << "listening ..." << std::endl; }).wait();
boost::asio::io_context handler_context;
boost::asio::signal_set signals(handler_context, SIGINT );
signals.async_wait( interrupt_handler );
handler_context.run();
return 0;
}
我这样做的方式是在do-while循环中使用std::getline,该循环将仅通过正确的命令终止服务器。我发现这是一个快速解决方案,对资源的消耗较少。
http_listener listener(L"http://localhost:80");
try {
listener
.open()
.then([&listener]() {std::wcout << L"nstarting to listenn"; })
.wait();
} catch(exception const& e){
std::wcout << e.what() << std::endl;
}
std::string choice= "";
do {
std::getline(cin, choice);
} while (!(choice == "N" || choice == "n"));
return 0;
注意:普通 std::cin 会将字符串输入作为不同的字符处理,循环将执行直到字符串的长度,解决方法是忽略其余字符,但我决定充分利用输入(终止服务器的关键字(
其他方法是在主信号量等待中设置信号量等待并通过所需的信号释放它,同时以适当的方法(GET/PUT/POST/DELETE(处理HTTP请求以终止服务器。
如果你的http_listener是一个指针,你可以避免无限循环。创建一个http_listener的对象并等待,您应该能够删除无限循环,程序继续。
以下代码有效,
void initialize() {
http_listener *listener;
listener = new http_listener(L"http://127.0.0.1:1444/vessel");
listener->support(methods::GET, get_vessel_visitpositions);
try
{
listener->
open()
.then([&listener](){})
.wait();
//while (true);
}
catch (exception const & e)
{
wcout << e.what() << endl;
return;
}
cout<<"Listening started..";
}
- Casablanca/cpprestsdk listener.support接受函数,但不支持方法
- 使用 cpprest (Casablanca) 返回 PDF 响应
- Microsoft/CppRestSDK Casablanca, Visual Studio 2017
- CPPrestsdk (Casablanca) JSON 值到 std::vector<unsigned char>
- 如何保持服务器运行(cpprestsdk - casablanca)
- 使用 /clr 或 clr:pure (cpprestsdk aka casablanca) 编译时不支持互斥
- C REST SDK(Casablanca) - 如何获得HTTP代理设置
- 将编译器命令行转换为 CMakeLists.txt用于 Casablanca Rest SDK
- 400 Casablanca cpprestsdk的不良要求
- 使用C REST SDK(Casablanca)的HTTP_CLIENT POST请求
- Casablanca中的HTTP身份验证
- CPPRestSDK(casablanca)从传入的WebSocket消息中提取JSON(格式错误的令牌)
- 在 Firebase 中使用 Rest api(Casablanca c++) 添加子项时遇到问题
- C++ Casablanca POST request
- 如果我访问该页面,带有casablanca的http服务器将崩溃
- C++ REST SDK 中的 URI 编码 ( "Casablanca" )
- 通过casablanca库与github API交互
- C++ in the cloud. Casablanca REST Service on Microsoft Azure
- 使用 Casablanca REST SDK 将 JSON 字符串转换为C++对象
- 从CPPRest库(即casablanca)获得的结果中提取基本STL字符串