如何搭建一个http服务器

小灰灰 2023-06-23 13:23 126阅读 0赞

https://blog.csdn.net/u012234115/article/details/79596826
注意他的回复里面有详细的result=0的说明

http://www.websocket-test.com/
这是一个websocket在线测试工具

http 用postman测试特别好下载下来就可以了
在这里插入图片描述
库下载下来以后，直接用这两个就可以了，取消预编译头

  1. /* Get form variables */
  2.         mg_get_http_var(&http_req->body, "n1", n1, sizeof(n1));
  3.         mg_get_http_var(&http_req->body, "n2", n2, sizeof(n2));
  5.         /*mg_get_http_var(&http_req->query_string, "n1", n1, sizeof(n1)); mg_get_http_var(&http_req->query_string, "n2", n2, sizeof(n2));*/

这些部分是通过地址或者body来传递参数的。

  1. http_server.h
  2. #pragma once
  4. #include <string>
  5. #include <string.h>
  6. #include <unordered_map>
  7. #include <unordered_set>
  8. #include <functional>
  9. #include "mongoose.h"
  11. // 定义http返回callback
  12. typedef void OnRspCallback(mg_connection *c, std::string);
  13. // 定义http请求handler
  14. using ReqHandler = std::function<bool(std::string, std::string, mg_connection *c, OnRspCallback)>;
  16. class HttpServer
  17. { 
  18. public:
  19.     HttpServer() { }
  20.     ~HttpServer() { }
  21.     void Init(const std::string &port); // 初始化设置
  22.     bool Start(); // 启动httpserver
  23.     bool Close(); // 关闭
  24.     void AddHandler(const std::string &url, ReqHandler req_handler); // 注册事件处理函数
  25.     void RemoveHandler(const std::string &url); // 移除时间处理函数
  26.     static std::string s_web_dir; // 网页根目录 
  27.     static mg_serve_http_opts s_server_option; // web服务器选项
  28.     static std::unordered_map<std::string, ReqHandler> s_handler_map; // 回调函数映射表
  30. private:
  31.     // 静态事件响应函数
  32.     static void OnHttpWebsocketEvent(mg_connection *connection, int event_type, void *event_data);
  34.     static void HandleHttpEvent(mg_connection *connection, http_message *http_req);
  35.     static void SendHttpRsp(mg_connection *connection, std::string rsp);
  37.     static int isWebsocket(const mg_connection *connection); // 判断是否是websoket类型连接
  38.     static void HandleWebsocketMessage(mg_connection *connection, int event_type, websocket_message *ws_msg);
  39.     static void SendWebsocketMsg(mg_connection *connection, std::string msg); // 发送消息到指定连接
  40.     static void BroadcastWebsocketMsg(std::string msg); // 给所有连接广播消息
  41.     static std::unordered_set<mg_connection *> s_websocket_session_set; // 缓存websocket连接
  43.     std::string m_port;    // 端口
  44.     mg_mgr m_mgr;          // 连接管理器
  45. };

http_server.cpp

  1. #include "stdafx.h"
  2. #include "http_server.h"
  3. #include <utility>
  4. #include "http_server.h"
  5. #include <string>
  7. extern char g_Pic[1024 * 10];
  9. using namespace cv;
  10. using namespace std;
  12. #pragma warning(disable:4996)
  15. void readpic(char* InImgName, char*OutImgName)
  16. { 
  17.     //保存输入图像文件名和输出图像文件名
  18.     /*char mInImgName[10]; char OutImgName[10];*/
  19.     //图像数据长度
  20.     int length;
  21.     //文件指针
  22.     FILE* fp;
  23.     //以二进制方式打开图像
  24.     if ((fp = fopen(InImgName, "rb")) == NULL)
  25.     { 
  26.         //cout << "Open image failed!" << endl;
  27.         exit(0);
  28.     }
  29.     //获取图像数据总长度
  30.     fseek(fp, 0, SEEK_END);
  31.     length = ftell(fp);
  32.     rewind(fp);
  33.     //根据图像数据长度分配内存buffer
  34.     char* ImgBuffer = (char*)malloc(length * sizeof(char));
  35.     //将图像数据读入buffer
  36.     fread(ImgBuffer, length, 1, fp);
  37.     memcpy(g_Pic, ImgBuffer, length);
  38.     fclose(fp);
  39.     //输入要保存的文件名
  40.     //cout << "Enter the name you wanna to save:";
  41.     //cin >> OutImgName;
  42.     //以二进制写入方式
  43.     if ((fp = fopen(OutImgName, "wb")) == NULL)
  44.     { 
  45.         //cout << "Open File failed!" << endl;
  46.         exit(0);
  47.     }
  48.     //从buffer中写数据到fp指向的文件中
  49.     fwrite(ImgBuffer, length, 1, fp);
  50.     //cout << "Done!" << endl;
  51.     //关闭文件指针，释放buffer内存
  52.     fclose(fp);
  53.     free(ImgBuffer);
  54. }
  58. void HttpServer::Init(const std::string &port)
  59. { 
  60.     m_port = port;
  61.     s_server_option.enable_directory_listing = "yes";
  62.     s_server_option.document_root = s_web_dir.c_str();
  64.     // 其他http设置
  66.     // 开启 CORS，本项只针对主页加载有效
  67.     // s_server_option.extra_headers = "Access-Control-Allow-Origin: *";
  68. }
  70. bool HttpServer::Start()
  71. { 
  72.     mg_mgr_init(&m_mgr, NULL);
  73.     mg_connection *connection = mg_bind(&m_mgr, m_port.c_str(), HttpServer::OnHttpWebsocketEvent);
  74.     if (connection == NULL)
  75.         return false;
  76.     // for both http and websocket
  77.     mg_set_protocol_http_websocket(connection);
  79.     printf("starting http server at port: %s\n", m_port.c_str());
  80.     // loop
  81.     while (true)
  82.         mg_mgr_poll(&m_mgr, 500); // ms
  84.     return true;
  85. }
  87. void HttpServer::OnHttpWebsocketEvent(mg_connection *connection, int event_type, void *event_data)
  88. { 
  89.     // 区分http和websocket
  90.     if (event_type == MG_EV_HTTP_REQUEST)
  91.     { 
  92.         http_message *http_req = (http_message *)event_data;
  93.         HandleHttpEvent(connection, http_req);
  94.     }
  95.     else if (event_type == MG_EV_WEBSOCKET_HANDSHAKE_DONE ||
  96.         event_type == MG_EV_WEBSOCKET_FRAME ||
  97.         event_type == MG_EV_CLOSE)
  98.     { 
  99.         websocket_message *ws_message = (struct websocket_message *)event_data;
  100.         HandleWebsocketMessage(connection, event_type, ws_message);
  101.     }
  102. }
  104. // ---- simple http ---- //
  105. static bool route_check(http_message *http_msg, char *route_prefix)
  106. { 
  107.     if (mg_vcmp(&http_msg->uri, route_prefix) == 0)
  108.         return true;
  109.     else
  110.         return false;
  112.     // TODO: 还可以判断 GET, POST, PUT, DELTE等方法
  113.     //mg_vcmp(&http_msg->method, "GET");
  114.     //mg_vcmp(&http_msg->method, "POST");
  115.     //mg_vcmp(&http_msg->method, "PUT");
  116.     //mg_vcmp(&http_msg->method, "DELETE");
  117. }
  119. void HttpServer::AddHandler(const string &url, ReqHandler req_handler)
  120. { 
  121.     if (s_handler_map.find(url) != s_handler_map.end())
  122.         return;
  124.     s_handler_map.insert(make_pair(url, req_handler));
  125. }
  127. void HttpServer::RemoveHandler(const std::string &url)
  128. { 
  129.     auto it = s_handler_map.find(url);
  130.     if (it != s_handler_map.end())
  131.         s_handler_map.erase(it);
  132. }
  134. void HttpServer::SendHttpRsp(mg_connection *connection, std::string rsp)
  135. { 
  136.     // --- 未开启CORS
  137.     // 必须先发送header, 暂时还不能用HTTP/2.0
  138.     mg_printf(connection, "%s", "HTTP/1.1 200 OK\r\nTransfer-Encoding: chunked\r\n\r\n");
  139.     // 以json形式返回
  140.     //mg_printf_http_chunk(connection, "{ \"data\": %s }", rsp.c_str());
  141.     mg_printf_http_chunk(connection,  rsp.c_str());
  142.     // 发送空白字符快，结束当前响应
  143.     mg_send_http_chunk(connection, "", 0);
  145.     // --- 开启CORS
  146.     /*mg_printf(connection, "HTTP/1.1 200 OK\r\n" "Content-Type: text/plain\n" "Cache-Control: no-cache\n" "Content-Length: %d\n" "Access-Control-Allow-Origin: *\n\n" "%s\n", rsp.length(), rsp.c_str()); */
  147. }
  149. void HttpServer::HandleHttpEvent(mg_connection *connection, http_message *http_req)
  150. { 
  151.     std::string req_str = std::string(http_req->message.p, http_req->message.len);
  152.     //printf("got request: %s\n", req_str.c_str());
  154.     // 先过滤是否已注册的函数回调
  156.     /*std::string url = std::string(http_req->uri.p, http_req->uri.len); std::string query = std::string(http_req->query_string.p, http_req->query_string.len);*/
  158.     //这里接收的是body内的数据
  159.     std::string url = std::string(http_req->uri.p, http_req->uri.len);
  160.     //std::string body = std::string(http_req->body.p, http_req->body.len);//收到的body
  161.     //如果接收的是图片则用char* 来接收
  162.     //---------------------------
  163.     const int ImageLenth = http_req->body.len;
  164.     char* ImageBody = (char*)malloc(sizeof(char)*ImageLenth);
  165.     memset(ImageBody, 0, ImageLenth);
  166.     memcpy(ImageBody, http_req->body.p, ImageLenth);
  167. //---------------------------
  168.     string body = ImageBody;
  169.     auto it = s_handler_map.find(url);
  170.     if (it != s_handler_map.end())
  171.     { 
  172.         ReqHandler handle_func = it->second;
  173.         handle_func(url, body, connection, &HttpServer::SendHttpRsp);
  174.         //handle_func(url, query, connection, &HttpServer::SendHttpRsp);
  175.     }
  176.     printf("recv body=%s\n\n", body.c_str());
  177.     Json::Reader jsReader;
  178.     Json::Value  jsRes;
  179.     jsRes.clear();
  181.     /*if (!jsReader.parse(body.c_str(), body.c_str() + ImageLenth, jsRes)) return ; if (!jsRes.isObject()) return ;*/
  182.     /*std::string raw_body; raw_body = jsRes["containerImg"].toStyledString(); cout<<"raw==================>>>>>>>>>>>>>>>>>>"<< raw_body<<endl;*/
  184.     /*if (ImageLenth<100) { SendHttpRsp(connection, "HELLO WORLD"); delete ImageBody; printf("send success...\n\n"); return; }*/
  186. #ifdef NORMAL
  187.     // 其他请求
  188.     if (route_check(http_req, "/")) // index page
  189.         mg_serve_http(connection, http_req, s_server_option);
  190.     else if (route_check(http_req, "/api/hello"))
  191.     { 
  192.         // 直接回传
  193.         SendHttpRsp(connection, "welcome to httpserver");
  194.     }
  195.     else if (route_check(http_req, "/api/sum"))
  196.     { 
  197.         // 简单post请求，加法运算测试
  198.         char n1[100], n2[100];
  199.         double result;
  201.         /* Get form variables */
  202.         mg_get_http_var(&http_req->body, "n1", n1, sizeof(n1));
  203.         mg_get_http_var(&http_req->body, "n2", n2, sizeof(n2));
  205.         /*mg_get_http_var(&http_req->query_string, "n1", n1, sizeof(n1)); mg_get_http_var(&http_req->query_string, "n2", n2, sizeof(n2));*/
  207.         printf("n1=%s,n2=%s\n\n", n1, n2);
  208.         /* Compute the result and send it back as a JSON object */
  209.         result = strtod(n1, NULL) + strtod(n2, NULL);
  211.         std::string resStr;
  212.         //resStr = to_string(result);
  214.         SendHttpRsp(connection, resStr);
  215.     }
  216.     else
  217.     { 
  218.         mg_printf(
  219.             connection,
  220.             "%s",
  221.             "HTTP/1.1 501 Not Implemented\r\n"
  222.             "Content-Length: 0\r\n\r\n");
  223.     }
  225. #else
  227. /* //模拟传递的图片 //----------------------------------------------------- //提前打开一个图片FILE* fp; //以二进制方式打开图像 FILE* fp; if ((fp = fopen("D:\\test\\2.jpg", "rb")) == NULL) { exit(0); } //获取图像数据总长度 fseek(fp, 0, SEEK_END); int length = ftell(fp); rewind(fp); //根据图像数据长度分配内存buffer char* ImgBuffer = (char*)malloc(length * sizeof(char)); //将图像数据读入buffer fread(ImgBuffer, length, 1, fp); fclose(fp); const int Max = length + 2; char tmp[1024*100] = { 0 }; memcpy(tmp, ImageBody, ImageLenth); printf("length=%d\nImage body=%4x\n\n", length, tmp); delete ImgBuffer; //----------------------------------------------------- */
  229.     //std::string resStr;
  230.     //std::string strJpgBaseContainer;
  231.     //int len = 0;
  232.     //
  233.     //strJpgBaseContainer = base64_decode(raw_body);
  234.     //len = strJpgBaseContainer.length();
  235.     //cout << "strJpgBaseContainer==================>>>>>>>>>>>>>>>>>>" << strJpgBaseContainer << endl;
  237.     show picture
  238.     //const char * pImg= strJpgBaseContainer .c_str();
  239.     //char dir[256]={0};
  240.     //sprintf(dir, "D:\\test\\saff%x.jpg", GetTickCount());
  241.     //FILE* pfile = fopen(dir, "wb");
  242.     //if (pfile)
  243.     //{ 
  244.     // fwrite(raw_body.c_str(), len, 1, pfile);///fwrite(ImageBody, ImageLenth, 1, pfile);
  245.     // fclose(pfile);
  246.     // printf("write success...\n");
  247.     //}
  249.     从文件中读入图像
  250.     //Mat img = imread(dir, 1);
  252.     如果读入图像失败
  253.     //if (img.empty())
  254.     //{ 
  255.     // fprintf(stderr, "Can not load image %s\n", dir);
  256.     // //return ;
  257.     //}
  258.     显示图像
  259.     //imshow("image", img);
  261.     此函数等待按键，按键盘任意键就返回
  262.     //waitKey();
  264.     //resStr = ImageBody;
  267. //-----------------------------------------------------
  269. /* {\\"code\":\"11111111\",\"success\":false,\"message\":\"璋冩暣瑙掑害广东海关欢迎你 开箱成功\",\"data\":{\"crosswiseAngleChange\":\"15550\",\"lengthwiseAngleChange\":\"-1280\",\"eventId\":\"20191210151529_JS001_OOCU7892445\"}} {\"code\":\"00000000\",\"success\":true,\"message\":\"鎴愬姛开箱成功\",\"data\":{\"eventId\":\"20191210151529_JS001_OOCU7892445\",\"crosswiseAngle\":\"15700\",\"lengthwiseAngle\":\"-1280\"}} {\"code\":\"1\",\"success\":false,\"message\":\"鏈哄櫒浜鸿嚜鍔ㄥ寲璇嗗埆灏佸織鍙峰け璐?锛屾湭鎵惧埌灏佽瘑鍙峰浘鐗囥€?,\"data\":null} */
  270.     string tmp;
  271.     tmp = "{\"code\": \"11111111\",\"success\": false,\"message\": \"\u5e7f\u4e1c\u6d77\u5173\u6b22\u8fce\u4f60\u0020\u0020\u5f00\u7bb1\u5931\u8d25\",\"data\": {\"crosswiseAngleChange\": \"15550\",\"lengthwiseAngleChange\": \"-1280\",\"eventId\": \"20191210151529_JS001_OOCU7892445\"}}";
  272.     //tmp = "{\"code\": \"00000000\",\"success\": true,\"message\": \"\u5f00\u7bb1\u6210\u529f\",\"data\": {\"eventId\": \"20191210151529_JS001_OOCU7892445\",\"crosswiseAngle\": \"15700\",\"lengthwiseAngle\": \"-1280\"}}";
  273.     //tmp = "{\"code\": \"1\",\"success\": false,\"message\": \"\u4e2d\u534e\u4eba\u6c11\u5171\u548c\u56fd\u4e07\u5c81\",\"data\": \"\"}";
  274.     Json::Value  jsRes1;
  278.     static int i = 0;
  279.     if (0==i)
  280.     { 
  281.         Sleep(5000);
  282.         //jsRes1.clear();
  283.         //jsRes1["data"]["eventId"] = "20191210151529_JS001_OOCU7892445";
  284.         //jsRes1["data"]["crosswiseAngle"] = "15550";
  285.         //jsRes1["data"]["lengthwiseAngle"] = "-1280";
  286.         //jsRes1["code"] = "11111111";//
  287.         //jsRes1["success"] = false;
  288.         jsRes1["message"] = "\u5e7f\u4e1c\u6d77\u5173\u6b22\u8fce\u4f60\u0020\u0020\u5f00\u7bb1\u5931\u8d25";
  289.         //jsRes1["message"] = "hello anzer,hello hello hello";
  291.         jsRes1.clear();
  293.         /*jsRes1["code"] = "11111111"; jsRes1["success"] = true; jsRes1["message"] = "hello anzer"; jsRes1["data"]["eventId"] = "20191210151529_JS001_OOCU7892445"; jsRes1["data"]["enlargerateChange"] = "4"; jsRes1["data"]["crosswiseAngle"] = "19222"; jsRes1["data"]["lengthwiseAngle"] = "-515"; jsRes1["data"]["pointX"] = "-515"; jsRes1["data"]["pointY"] = "-515";*/
  297.         /*jsRes1["data"]["crosswiseAngle"] = "22025"; jsRes1["data"]["lengthwiseAngle"] = "-419";*/
  300.         ++i;
  301.     }
  302.     else if(1==i)
  303.     { 
  304.         //Sleep(5000);
  306.         //jsRes1.clear();
  307.         //jsRes1["data"]["eventId"] = "20191210151529_JS001_OOCU7892445";
  308.         //jsRes1["data"]["crosswiseAngle"] = "15700";
  309.         //jsRes1["data"]["lengthwiseAngle"] = "-1280";
  310.         //jsRes1["data"] = "";
  311.         //jsRes1["code"] = "00000000";
  312.         //jsRes1["success"] = true;
  313.         //jsRes1["message"] = "hello anzer,hello hello hello";
  314.         jsRes1["message"] = "\u4e2d\u534e\u4eba\u6c11\u5171\u548c\u56fd\u4e07\u5c81";
  317.         jsRes1.clear();
  319.         jsRes1["code"] = "11111111";
  320.         jsRes1["success"] = false;
  321.         jsRes1["message"] = "hello anzer";
  323.         jsRes1["data"]["eventId"] = "20191225093046_JS001_PONU7505962";
  324.         /*jsRes1["data"]["crosswiseAngleChange"] = "21385"; jsRes1["data"]["lengthwiseAngleChange"] = "-198";*/
  326.         jsRes1["data"]["crosswiseAngleChange"] = "19535";
  327.         jsRes1["data"]["lengthwiseAngleChange"] = "-804";
  328.         jsRes1["data"]["enlargerateChange"] = "16";
  329.         jsRes1["data"]["pointX"] = "-515";
  330.         jsRes1["data"]["pointY"] = "-515";
  331.         ++i;
  332.     }
  334.     else if (2 == i)
  335.     { 
  336.         //Sleep(5000);
  338.         //jsRes1.clear();
  339.         //jsRes1["data"]["eventId"] = "20191210151529_JS001_OOCU7892445";
  340.         //jsRes1["data"]["crosswiseAngle"] = "15700";
  341.         //jsRes1["data"]["lengthwiseAngle"] = "-1280";
  342.         //jsRes1["data"] = "";
  343.         //jsRes1["code"] = "00000000";
  344.         //jsRes1["success"] = true;
  345.         //jsRes1["message"] = "hello anzer,hello hello hello";
  346.         jsRes1["message"] = "\u4e2d\u534e\u4eba\u6c11\u5171\u548c\u56fd\u4e07\u5c81";
  349.         jsRes1.clear();
  351.         jsRes1["code"] = "11111111";
  352.         jsRes1["success"] = false;
  353.         jsRes1["message"] = "hello anzer";
  355.         jsRes1["data"]["eventId"] = "20191225093046_JS001_PONU7505962";
  356.         /*jsRes1["data"]["crosswiseAngleChange"] = "21685"; jsRes1["data"]["lengthwiseAngleChange"] = "190";*/
  358.         jsRes1["data"]["crosswiseAngleChange"] = "19665";
  359.         jsRes1["data"]["lengthwiseAngleChange"] = "-870";
  360.         jsRes1["data"]["enlargerateChange"] = "30";
  361.         ++i;
  362.     }
  365.     else if(3==i)
  366.     { 
  367.         //Sleep(5000);
  368.         //jsRes1.clear();
  369.         //jsRes1["data"]["eventId"] = "20191210151529_JS001_OOCU7892445";
  370.         //jsRes1["data"]["crosswiseAngle"] = "-2280";
  371.         //jsRes1["data"]["lengthwiseAngle"] = "1280";
  372.         //jsRes1["code"] = "1";
  373.         //jsRes1["success"] = false;
  374.         jsRes1["message"] = "\u5e7f\u4e1c\u6d77\u5173\u6b22\u8fce\u4f60\u0020\u0020\u5f00\u7bb1\u5931\u8d25";
  375.         //jsRes1["message"] = "hello anzer,hello hello hello";
  378.         /*jsRes1.clear(); jsRes1["code"] = "1"; jsRes1["success"] = false; jsRes1["message"] = "hello anzer,hello hello hello";*/
  380.         jsRes1.clear();
  382.         jsRes1["code"] = "00000000";
  383.         jsRes1["success"] = true;
  384.         jsRes1["message"] = "hello anzer,open CSNU6393292";
  385.         jsRes1["data"]["openArea"] = "";
  386.         jsRes1["data"]["recogContainerNo"] = "CSNU6393292";
  387.         jsRes1["data"]["recogSealNo"] = "12227063";
  388.         jsRes1["data"]["containerNo"] = "CSNU6393292";
  389.         jsRes1["data"]["sealNo"] = "12227063";
  390.         jsRes1["data"]["canOpen"] = false;
  391.         jsRes1["data"]["comparisonInfo"] = "结束定点拍照任务";
  392.         jsRes1["data"]["eventId"] = "20191225093320_JS002_CSNU6393292";
  393.         i++;
  394.     }
  395.     else
  396.     { 
  397.         jsRes1.clear();
  398.         i = 0;
  399.     }
  401.     //--------------------------------------------------------
  402.     tmp = jsRes1.toStyledString();
  403.     SendHttpRsp(connection, tmp);
  405.     printf("send body=%s\n\n", tmp.c_str());
  406.     printf("------------------------------------------------------------------------------\n\n");
  407. //-----------------------------------------------------
  408.     //SendHttpRsp(connection, resStr);
  409.     delete ImageBody;
  410. #endif // 0
  411. }
  413. // ---- websocket ---- //
  414. int HttpServer::isWebsocket(const mg_connection *connection)
  415. { 
  416.     return connection->flags & MG_F_IS_WEBSOCKET;
  417. }
  419. void HttpServer::HandleWebsocketMessage(mg_connection *connection, int event_type, websocket_message *ws_msg)
  420. { 
  421.     if (event_type == MG_EV_WEBSOCKET_HANDSHAKE_DONE)
  422.     { 
  423.         printf("client websocket connected\n");
  424.         // 获取连接客户端的IP和端口
  425.         char addr[32];
  426.         mg_sock_addr_to_str(&connection->sa, addr, sizeof(addr), MG_SOCK_STRINGIFY_IP | MG_SOCK_STRINGIFY_PORT);
  427.         printf("client addr: %s\n", addr);
  429.         // 添加 session
  430.         s_websocket_session_set.insert(connection);
  431.         SendWebsocketMsg(connection, "client websocket connected");
  432.     }
  433.     else if (event_type == MG_EV_WEBSOCKET_FRAME)
  434.     { 
  435.         mg_str received_msg = { 
  436.             (char *)ws_msg->data, ws_msg->size
  437.         };
  439.         char buff[1024] = {  0 };
  440.         strncpy(buff, received_msg.p, received_msg.len); // must use strncpy, specifiy memory pointer and length
  442.                                                          // do sth to process request
  443.         printf("received msg: %s\n", buff);
  444.         SendWebsocketMsg(connection, "send your msg back: " + std::string(buff));
  445.         //BroadcastWebsocketMsg("broadcast msg: " + std::string(buff));
  446.     }
  447.     else if (event_type == MG_EV_CLOSE)
  448.     { 
  449.         if (isWebsocket(connection))
  450.         { 
  451.             printf("client websocket closed\n");
  452.             // 移除session
  453.             if (s_websocket_session_set.find(connection) != s_websocket_session_set.end())
  454.                 s_websocket_session_set.erase(connection);
  455.         }
  456.     }
  457. }
  459. void HttpServer::SendWebsocketMsg(mg_connection *connection, std::string msg)
  460. { 
  461.     mg_send_websocket_frame(connection, WEBSOCKET_OP_TEXT, msg.c_str(), strlen(msg.c_str()));
  462. }
  464. void HttpServer::BroadcastWebsocketMsg(std::string msg)
  465. { 
  466.     for (mg_connection *connection : s_websocket_session_set)
  467.         mg_send_websocket_frame(connection, WEBSOCKET_OP_TEXT, msg.c_str(), strlen(msg.c_str()));
  468. }
  470. bool HttpServer::Close()
  471. { 
  472.     mg_mgr_free(&m_mgr);
  473.     return true;
  474. }

主函数

  1. // httpserver.cpp : 定义控制台应用程序的入口点。
  2. //
  4. #include "stdafx.h"
  5. #include <iostream>
  6. #include <memory>
  7. #include "http_server.h"
  8. #pragma warning(disable:4996)
  10. using namespace std;
  14. // 初始化HttpServer静态类成员
  15. mg_serve_http_opts HttpServer::s_server_option;
  16. std::string HttpServer::s_web_dir = "./web";
  17. std::unordered_map<std::string, ReqHandler> HttpServer::s_handler_map;
  18. std::unordered_set<mg_connection *> HttpServer::s_websocket_session_set;
  22. char g_Pic[1024 * 10] = {  0 };
  24. bool handle_fun1(std::string url, std::string body, mg_connection *c, OnRspCallback rsp_callback)
  25. { 
  26.     // do sth
  27.     std::cout << "handle fun1" << std::endl;
  28.     std::cout << "url: " << url << std::endl;
  29.     std::cout << "body: " << body << std::endl;
  31.     rsp_callback(c, "rsp1");
  33.     return true;
  34. }
  36. bool handle_fun2(std::string url, std::string body, mg_connection *c, OnRspCallback rsp_callback)
  37. { 
  38.     // do sth
  39.     std::cout << "handle fun2" << std::endl;
  40.     std::cout << "url: " << url << std::endl;
  41.     std::cout << "body: " << body << std::endl;
  43.     rsp_callback(c, "rsp2");
  45.     return true;
  46. }
  51. int main(int argc, char *argv[])
  52. { 
  53.     std::string port = "18899";
  54.     auto http_server = std::shared_ptr<HttpServer>(new HttpServer);
  55.     http_server->Init(port);
  56.     // add handler
  57.     http_server->AddHandler("/api/fun1", handle_fun1);
  58.     http_server->AddHandler("/api/fun2", handle_fun2);
  60.     http_server->Start();
  64.     return 0;
  65. }

mongoose.h

mongoose.cpp

  1. 在这里插入代码片

发表评论

表情：
评论列表 （有 0 条评论，126人围观）

还没有评论，来说两句吧...

相关阅读

    相关 Http服务器搭建

    一、Nginx介绍 > Nginx是一个高性能的HTTP和方向代理服务，也是一个IMAP/POP3/SMTP服务。 > > 其特点是占用内存少，并发能力强，中国大陆使用

    悠悠悠悠/ 0 赞/ 278 阅读

    相关 如何搭建云服务器

    本文将介绍如何搭建服务器： 作为一个大学生，且作为一个编程者，拥有一个自己的服务器会对我们的学习带来极大的方便。而且很多服务器公司都对我们大学生有很大的优惠，毕业了就无法

    今天药忘吃喽~今天药忘吃喽~/ 0 赞/ 359 阅读