• http发送和接收图片json文件

     一、http数据发送

    1、先将图片转换为base64格式

    1. std::string detectNet::Mat2Base64(const cv::Mat &image, std::string imgType){
    2.     std::vector buf;
    3.     cv::imencode(imgType, image, buf);
    4.     //uchar *enc_msg = reinterpret_cast(buf.data());
    5.     std::string img_data = base64_encode(buf.data(), buf.size(), false);
    6.     return img_data;
    7. }

    2、将数据以json格式进行发送

    1. void detectNet::send_json_people(cv::Mat img, std::string label, std::string level, std::string rtsp){
    2.     std::string out = Mat2Base64(img,".jpg");
    3.     //std::cout << out << std::endl;
    4.  
    5.     ImgInfo imgInfo(out, label, level, rtsp);
    6.     static auto client = httplib::Client("127.0.0.1", 18080);
    7.     auto result = client.Post("/uploadAlgorithmResult", imgInfo.to_json_people(), "application/json");
    8.     if (result != nullptr && result->status == 200) {
    9.         std::cout << result->body << std::endl;
    10.     }
    11. }

    其中 ImgInfo 类为：

    1. #ifndef HTTP_DEMO_IMGINFO_H
    2. #define HTTP_DEMO_IMGINFO_H
    3.  
    4. #include 
    5.  
    6. #include "cJSON.h"
    7. #include "base64.h"
    8.  
    9.  
    10. #define RTSP_URL "rtsp://admin:a123456789@192.168.8.31:554/h264/ch1/main/av_stream/1"
    11. #define AlgorithmType "hook_detection"
    12. #define AlgorithmType_people "danger_zone"
    13. #define AlgorithmType_crooked "crooked"
    14.  
    15. class ImgInfo {
    16. private:
    17.     std::string img;
    18.     std::string label;
    19.     std::string rtsp;
    20.     std::string level;
    21. public:
    22.     ImgInfo(std::string img, std::string label, 
    23.             std::string level, std::string rtsp) : img(std::move(img)), label(std::move(label)),
    24.                                  level(std::move(level)), rtsp(std::move(rtsp)) {}
    25.  
    26.     std::string to_json_people() {
    27.         auto *root = cJSON_CreateObject();
    28.         cJSON_AddStringToObject(root, "image", img.c_str());
    29.         cJSON_AddStringToObject(root, "level", level.c_str());
    30.         cJSON_AddStringToObject(root, "rtsp", rtsp.c_str());
    31.         cJSON_AddStringToObject(root, "type", AlgorithmType_people);
    32.         cJSON_AddStringToObject(root, "label", label.c_str());
    33.  
    34.  
    35.         /*
    36.         cJSON *label_array = cJSON_CreateArray();
    37.         for (auto &i: label) {
    38.             cJSON_AddItemToArray(label_array, cJSON_CreateString(i.c_str()));
    39.         }
    40.         cJSON_AddItemToObject(root, "label", label_array);
    41.         */
    42.         char *out = cJSON_Print(root);
    43.         std::string res = out;
    44.         free(out);
    45.         cJSON_Delete(root);
    46.         return res;
    47.     }
    48. };
    49.  
    50. #endif //HTTP_DEMO_IMGINFO_H

    上述代码中json数据有五个部分：image为图片数据，level是告警等级，rtsp为数据流地址，type是算法类型，label是算法标签等，所以数据发送为这五个内容。

    二、http数据接收

    HttpServer.cpp如下： 

    1. //#include 
    2. //#include 
    3. #include "HttpServer.h"
    4. #include 
    5. #include 
    6. //#include "QString"
    7. //#include "TimeUtils.hpp"
    8. //#include "AlgorithmCommon.h"
    9. //#include "QJsonObject"
    10. //#include "QJsonDocument"
    11. //#include "QJsonArray"
    12. //#include "httplib.h"
    13.  
    14. //#include "log.h"
    15. //#include "cJSON.h"
    16.  
    17. HttpServer::HttpServer(std::string ip, int port) : server_ip(ip), server_port(port) {
    18.  
    19.     //event_handler = new AlgorithmAlarmHandler();
    20.  
    21. }
    22.  
    23. HttpServer::~HttpServer() {
    24.     stopListen();
    25.     if (read_thd.joinable()) {
    26.         read_thd.join();
    27.     }
    28. }
    29.  
    30. void HttpServer::startListen() {
    31.     read_thd = std::thread([=]() {
    32.         serverListen();
    33.     });
    34.     //event_handler->startHandlerThread();
    35. }
    36.  
    37. void HttpServer::stopListen() {
    38.     if (server.is_running()) {
    39.         server.stop();
    40.     }
    41. }
    42.  
    43. void HttpServer::serverListen() {
    44.     if (!server.is_valid()) {
    45.         std::cout << "http server invalid" << std::endl;
    46.         return;
    47.     }
    48.  
    49.     // 服务器状态
    50.     server.Get("/server/status", [&](const Request &req, Response &res) {
    51.         onServerStatus(req, res);
    52.     });
    53.  
    54.     // 上传算法结果
    55.     server.Post("/uploadAlgorithmResult", [&](const Request &req, Response &res) {
    56.         onUploadAlgorithmResult(req, res);
    57.     });
    58.  
    59.  
    60.     // 错误处理
    61.     server.set_error_handler([&](const Request &req, Response &res) {
    62.         onErrorHandle(req, res);
    63.     });
    64.  
    65.     //qDebug() << "server start listen";
    66.     server.listen(server_ip.c_str(), server_port);
    67. }
    68.  
    69. void HttpServer::onServerStatus(const httplib::Request &req, httplib::Response &res) {
    70.     res.body = R"({"code": 200,"msg": "Server is already Running"})";
    71. }
    72.  
    73. void HttpServer::onUploadAlgorithmResult(const httplib::Request &req, httplib::Response &res) {
    74.     std::string content_type = httputillib::GetContentType(req.headers);
    75.     //if (content_type != "application/json") {
    76.    //     qDebug() << "contentType 异常, content_type:" << QString::fromStdString(content_type);
    77.     //}
    78.     bool parseRet = parseAlgorithmResult(req.body);
    79. 	//bool parseRet = true;
    80.     std::string rspMsg;
    81.     if (parseRet) {
    82.         rspMsg = std::string(R"({"msg":"Recv Success, Parse Success."})");
    83.     } else {
    84.         rspMsg = std::string(R"({"msg":"Recv Success, Parse Failed."})");
    85.     }
    86.     res.body = std::move(rspMsg);
    87. }
    88.  
    89.  
    90. // 错误请求处理
    91. void HttpServer::onErrorHandle(const httplib::Request &req, httplib::Response &res) {
    92.     const char *fmt = {"\"error\": \"服务器不支持该方法\""};
    93.     char buf[BUFSIZ] = {0};
    94.     snprintf(buf, sizeof(buf), fmt, res.status);
    95.  
    96.     res.set_content(buf, "application/json");
    97. }
    98.  
    99.  
    100. bool HttpServer::parseAlgorithmResult(const std::string &body) {
    101.  
    102.     //std::cout << "body:" << body << std::endl;
    103. 	Json::Reader reader;
    104. 	Json::Value root;
    105.     //std::ifstream in(body, std::ios::binary);
    106.     //if (!in.is_open()) {
    107.     //    std::cout << "open file failed" << std::endl;
    108.     //    return false;
    109.     //}
    110.     if (!reader.parse(body, root)) {
    111.         std::cout << "parse failed" << std::endl;
    112.         return false;
    113.     }
    114.     std::string rtsp = root["rtsp"].asString();
    115.     std::cout << "rtsp:" << rtsp << std::endl;
    116.     std::string level = root["level"].asString();
    117.     std::cout << "level:" << level << std::endl;
    118.     std::string type = root["type"].asString();
    119.     std::cout << "type:" << type << std::endl;
    120. 	std::string image = root["image"].asString();
    121.     //std::cout << "image:" << image << std::endl;
    122. 	std::string out = base64_decode(image);
    123.     std::string decoded_jpeg = std::move(out);
    124.     //std::cout << "decoded_jpeg: " << decoded_jpeg << std::endl;
    125.  
    126. 	cv::Mat mat2(1, decoded_jpeg.size(), CV_8U, (char*)decoded_jpeg.data());
    127.     cv::Mat dst = cv::imdecode(mat2, CV_LOAD_IMAGE_COLOR);
    128. 	cv::imwrite(rtsp.substr(1) + ".jpg", dst);  
    129.  
    130.     return true;
    131. }

     HttpServer.h如下：

    1. //#ifndef CPPHTTPSERVER_HTTPSERVER_H
    2. //#define CPPHTTPSERVER_HTTPSERVER_H
    3.  
    4. #include "httputillib.h"
    5. #include "httplib.h"
    6. #include "base64.h"
    7. //#include "thread"
    8. #include 
    9. #include 
    10.  
    11. #include 
    12.  
    13.  
    14. class HttpServer{
    15. public:
    16.     HttpServer(std::string ip, int port);
    17.     ~HttpServer();
    18.  
    19.     void startListen();
    20.  
    21.     void stopListen();
    22.  
    23. private:
    24.  
    25.     void serverListen();
    26.  
    27.     // 回调函数: 错误请求处理
    28.     void onErrorHandle(const httplib::Request &req, httplib::Response &res);
    29.  
    30.     // 回调函数: 获取服务器状态
    31.     void onServerStatus(const httplib::Request &req, httplib::Response &res);
    32.  
    33.     // 回调函数: 上传算法结果
    34.     void onUploadAlgorithmResult(const httplib::Request &req, httplib::Response &res);
    35.  
    36.     // 回调函数：处理算法数据
    37.     bool parseAlgorithmResult(const std::string &body);
    38.  
    39.     std::string server_ip;
    40.     int server_port;
    41.  
    42.     Server server;
    43.     std::thread read_thd;
    44.  
    45. };
    46.  
    47. //#endif //CPPHTTPLIB_HTTPLIB_H

    httputillib.h如下：

    1. #include 
    2.  
    3. using namespace httplib;
    4.  
    5.  
    6. namespace httputillib {
    7. // 打印请求头
    8. static std::string DumpHeaders(const Headers &headers) {
    9. 	std::string s;
    10. 	char buf[BUFSIZ] = {0};
    11.  
    12. 	for (auto it = headers.begin(); it != headers.end(); ++it) {
    13. 		const auto &x = *it;
    14. 		snprintf(buf, sizeof(buf), "%s: %s\n", x.first.c_str(), x.second.c_str());
    15. 		s += buf;
    16. 	}
    17.  
    18. 	return s;
    19. }
    20.  
    21. // 从请求同获取content type
    22. static std::string GetContentType(const httplib::Headers &headers) {
    23. 	auto iter = headers.find("Content-Type");
    24. 	if (iter == headers.end()) {
    25. 		return std::string();
    26. 	}
    27.  
    28. 	return iter->second;
    29. }
    30.  
    31. };

    上述完整代码可详见github或者百度网盘

  • 相关阅读:
    Hadoop如何启动HttpFS服务？
    程序员应该专注技术还是转管理？
    直线导轨在喷涂行业中的应用场景
    Spring学习(4) Spring依赖注入
    SpringBoot官方支持任务调度框架，轻量级用起来也挺香！
    短视频文案提取的简单实现
    C++ 新特性 | C++ 11 | 移动语义与右值引用
    UE4 通过按键切换不同的HUD
    只要做好充分准备，丢失的苹果设备多半可以找回来，包括AirPods
    从0到1开始运营你的开源产品
  • 原文地址：https://blog.csdn.net/zk_ken/article/details/133683687