如何搭建一个http服务器

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

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

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

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

/* Get form variables */
    		mg_get_http_var(&http_req->body, "n1", n1, sizeof(n1));
    		mg_get_http_var(&http_req->body, "n2", n2, sizeof(n2));
    
    		/*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来传递参数的。

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

http\_server.cpp

#include "stdafx.h"
    #include "http_server.h"
    #include <utility>
    #include "http_server.h"
    #include <string>
    
    extern char g_Pic[1024 * 10];
    
    using namespace cv;
    using namespace std;
    
    #pragma warning(disable:4996)
    
    
    void readpic(char* InImgName, char*OutImgName)
    { 
    	//保存输入图像文件名和输出图像文件名
    	/*char mInImgName[10]; char OutImgName[10];*/
    	//图像数据长度
    	int length;
    	//文件指针
    	FILE* fp;
    	//以二进制方式打开图像
    	if ((fp = fopen(InImgName, "rb")) == NULL)
    	{ 
    		//cout << "Open image failed!" << endl;
    		exit(0);
    	}
    	//获取图像数据总长度
    	fseek(fp, 0, SEEK_END);
    	length = ftell(fp);
    	rewind(fp);
    	//根据图像数据长度分配内存buffer
    	char* ImgBuffer = (char*)malloc(length * sizeof(char));
    	//将图像数据读入buffer
    	fread(ImgBuffer, length, 1, fp);
    	memcpy(g_Pic, ImgBuffer, length);
    	fclose(fp);
    	//输入要保存的文件名
    	//cout << "Enter the name you wanna to save:";
    	//cin >> OutImgName;
    	//以二进制写入方式
    	if ((fp = fopen(OutImgName, "wb")) == NULL)
    	{ 
    		//cout << "Open File failed!" << endl;
    		exit(0);
    	}
    	//从buffer中写数据到fp指向的文件中
    	fwrite(ImgBuffer, length, 1, fp);
    	//cout << "Done!" << endl;
    	//关闭文件指针，释放buffer内存
    	fclose(fp);
    	free(ImgBuffer);
    }
    
    
    
    void HttpServer::Init(const std::string &port)
    { 
    	m_port = port;
    	s_server_option.enable_directory_listing = "yes";
    	s_server_option.document_root = s_web_dir.c_str();
    
    	// 其他http设置
    
    	// 开启 CORS，本项只针对主页加载有效
    	// s_server_option.extra_headers = "Access-Control-Allow-Origin: *";
    }
    
    bool HttpServer::Start()
    { 
    	mg_mgr_init(&m_mgr, NULL);
    	mg_connection *connection = mg_bind(&m_mgr, m_port.c_str(), HttpServer::OnHttpWebsocketEvent);
    	if (connection == NULL)
    		return false;
    	// for both http and websocket
    	mg_set_protocol_http_websocket(connection);
    
    	printf("starting http server at port: %s\n", m_port.c_str());
    	// loop
    	while (true)
    		mg_mgr_poll(&m_mgr, 500); // ms
    
    	return true;
    }
    
    void HttpServer::OnHttpWebsocketEvent(mg_connection *connection, int event_type, void *event_data)
    { 
    	// 区分http和websocket
    	if (event_type == MG_EV_HTTP_REQUEST)
    	{ 
    		http_message *http_req = (http_message *)event_data;
    		HandleHttpEvent(connection, http_req);
    	}
    	else if (event_type == MG_EV_WEBSOCKET_HANDSHAKE_DONE ||
    		event_type == MG_EV_WEBSOCKET_FRAME ||
    		event_type == MG_EV_CLOSE)
    	{ 
    		websocket_message *ws_message = (struct websocket_message *)event_data;
    		HandleWebsocketMessage(connection, event_type, ws_message);
    	}
    }
    
    // ---- simple http ---- //
    static bool route_check(http_message *http_msg, char *route_prefix)
    { 
    	if (mg_vcmp(&http_msg->uri, route_prefix) == 0)
    		return true;
    	else
    		return false;
    
    	// TODO: 还可以判断 GET, POST, PUT, DELTE等方法
    	//mg_vcmp(&http_msg->method, "GET");
    	//mg_vcmp(&http_msg->method, "POST");
    	//mg_vcmp(&http_msg->method, "PUT");
    	//mg_vcmp(&http_msg->method, "DELETE");
    }
    
    void HttpServer::AddHandler(const string &url, ReqHandler req_handler)
    { 
    	if (s_handler_map.find(url) != s_handler_map.end())
    		return;
    
    	s_handler_map.insert(make_pair(url, req_handler));
    }
    
    void HttpServer::RemoveHandler(const std::string &url)
    { 
    	auto it = s_handler_map.find(url);
    	if (it != s_handler_map.end())
    		s_handler_map.erase(it);
    }
    
    void HttpServer::SendHttpRsp(mg_connection *connection, std::string rsp)
    { 
    	// --- 未开启CORS
    	// 必须先发送header, 暂时还不能用HTTP/2.0
    	mg_printf(connection, "%s", "HTTP/1.1 200 OK\r\nTransfer-Encoding: chunked\r\n\r\n");
    	// 以json形式返回
    	//mg_printf_http_chunk(connection, "{ \"data\": %s }", rsp.c_str());
    	mg_printf_http_chunk(connection,  rsp.c_str());
    	// 发送空白字符快，结束当前响应
    	mg_send_http_chunk(connection, "", 0);
    
    	// --- 开启CORS
    	/*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()); */
    }
    
    void HttpServer::HandleHttpEvent(mg_connection *connection, http_message *http_req)
    { 
    	std::string req_str = std::string(http_req->message.p, http_req->message.len);
    	//printf("got request: %s\n", req_str.c_str());
    
    	// 先过滤是否已注册的函数回调
    
    	/*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);*/
    
    	//这里接收的是body内的数据
    	std::string url = std::string(http_req->uri.p, http_req->uri.len);
    	//std::string body = std::string(http_req->body.p, http_req->body.len);//收到的body
    	//如果接收的是图片则用char* 来接收
    	//---------------------------
    	const int ImageLenth = http_req->body.len;
    	char* ImageBody = (char*)malloc(sizeof(char)*ImageLenth);
    	memset(ImageBody, 0, ImageLenth);
    	memcpy(ImageBody, http_req->body.p, ImageLenth);
    //---------------------------
    	string body = ImageBody;
    	auto it = s_handler_map.find(url);
    	if (it != s_handler_map.end())
    	{ 
    		ReqHandler handle_func = it->second;
    		handle_func(url, body, connection, &HttpServer::SendHttpRsp);
    		//handle_func(url, query, connection, &HttpServer::SendHttpRsp);
    	}
    	printf("recv body=%s\n\n", body.c_str());
    	Json::Reader jsReader;
    	Json::Value  jsRes;
    	jsRes.clear();
    
    	/*if (!jsReader.parse(body.c_str(), body.c_str() + ImageLenth, jsRes)) return ; if (!jsRes.isObject()) return ;*/
    	/*std::string raw_body; raw_body = jsRes["containerImg"].toStyledString(); cout<<"raw==================>>>>>>>>>>>>>>>>>>"<< raw_body<<endl;*/
    
    	/*if (ImageLenth<100) { SendHttpRsp(connection, "HELLO WORLD"); delete ImageBody; printf("send success...\n\n"); return; }*/
    
    #ifdef NORMAL
    	// 其他请求
    	if (route_check(http_req, "/")) // index page
    		mg_serve_http(connection, http_req, s_server_option);
    	else if (route_check(http_req, "/api/hello"))
    	{ 
    		// 直接回传
    		SendHttpRsp(connection, "welcome to httpserver");
    	}
    	else if (route_check(http_req, "/api/sum"))
    	{ 
    		// 简单post请求，加法运算测试
    		char n1[100], n2[100];
    		double result;
    
    		/* Get form variables */
    		mg_get_http_var(&http_req->body, "n1", n1, sizeof(n1));
    		mg_get_http_var(&http_req->body, "n2", n2, sizeof(n2));
    
    		/*mg_get_http_var(&http_req->query_string, "n1", n1, sizeof(n1)); mg_get_http_var(&http_req->query_string, "n2", n2, sizeof(n2));*/
    
    		printf("n1=%s,n2=%s\n\n", n1, n2);
    		/* Compute the result and send it back as a JSON object */
    		result = strtod(n1, NULL) + strtod(n2, NULL);
    
    		std::string resStr;
    		//resStr = to_string(result);
    
    		SendHttpRsp(connection, resStr);
    	}
    	else
    	{ 
    		mg_printf(
    			connection,
    			"%s",
    			"HTTP/1.1 501 Not Implemented\r\n"
    			"Content-Length: 0\r\n\r\n");
    	}
    
    #else
    
    /* //模拟传递的图片 //----------------------------------------------------- //提前打开一个图片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; //----------------------------------------------------- */
    
    	//std::string resStr;
    	//std::string strJpgBaseContainer;
    	//int len = 0;
    	//
    	//strJpgBaseContainer = base64_decode(raw_body);
    	//len = strJpgBaseContainer.length();
    	//cout << "strJpgBaseContainer==================>>>>>>>>>>>>>>>>>>" << strJpgBaseContainer << endl;
    
    	show picture
    	//const char * pImg= strJpgBaseContainer .c_str();
    	//char dir[256]={0};
    	//sprintf(dir, "D:\\test\\saff%x.jpg", GetTickCount());
    	//FILE* pfile = fopen(dir, "wb");
    	//if (pfile)
    	//{ 
    	// fwrite(raw_body.c_str(), len, 1, pfile);///fwrite(ImageBody, ImageLenth, 1, pfile);
    	// fclose(pfile);
    	// printf("write success...\n");
    	//}
    
    	从文件中读入图像
    	//Mat img = imread(dir, 1);
    
    	如果读入图像失败
    	//if (img.empty())
    	//{ 
    	// fprintf(stderr, "Can not load image %s\n", dir);
    	// //return ;
    	//}
    	显示图像
    	//imshow("image", img);
    
    	此函数等待按键，按键盘任意键就返回
    	//waitKey();
    	
    	//resStr = ImageBody;
    
    
    //-----------------------------------------------------
    
    /* {\\"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} */
    	string tmp;
    	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\"}}";
    	//tmp = "{\"code\": \"00000000\",\"success\": true,\"message\": \"\u5f00\u7bb1\u6210\u529f\",\"data\": {\"eventId\": \"20191210151529_JS001_OOCU7892445\",\"crosswiseAngle\": \"15700\",\"lengthwiseAngle\": \"-1280\"}}";
    	//tmp = "{\"code\": \"1\",\"success\": false,\"message\": \"\u4e2d\u534e\u4eba\u6c11\u5171\u548c\u56fd\u4e07\u5c81\",\"data\": \"\"}";
    	Json::Value  jsRes1;
    
    
    
    	static int i = 0;
    	if (0==i)
    	{ 
    		Sleep(5000);
    		//jsRes1.clear();
    		//jsRes1["data"]["eventId"] = "20191210151529_JS001_OOCU7892445";
    		//jsRes1["data"]["crosswiseAngle"] = "15550";
    		//jsRes1["data"]["lengthwiseAngle"] = "-1280";
    		//jsRes1["code"] = "11111111";//
    		//jsRes1["success"] = false;
    		jsRes1["message"] = "\u5e7f\u4e1c\u6d77\u5173\u6b22\u8fce\u4f60\u0020\u0020\u5f00\u7bb1\u5931\u8d25";
    		//jsRes1["message"] = "hello anzer,hello hello hello";
    
    		jsRes1.clear();
    
    		/*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";*/
    
    
    
    		/*jsRes1["data"]["crosswiseAngle"] = "22025"; jsRes1["data"]["lengthwiseAngle"] = "-419";*/
    		
    	
    		++i;
    	}
    	else if(1==i)
    	{ 
    		//Sleep(5000);
    		
    		//jsRes1.clear();
    		//jsRes1["data"]["eventId"] = "20191210151529_JS001_OOCU7892445";
    		//jsRes1["data"]["crosswiseAngle"] = "15700";
    		//jsRes1["data"]["lengthwiseAngle"] = "-1280";
    		//jsRes1["data"] = "";
    		//jsRes1["code"] = "00000000";
    		//jsRes1["success"] = true;
    		//jsRes1["message"] = "hello anzer,hello hello hello";
    		jsRes1["message"] = "\u4e2d\u534e\u4eba\u6c11\u5171\u548c\u56fd\u4e07\u5c81";
    
    
    		jsRes1.clear();
    
    		jsRes1["code"] = "11111111";
    		jsRes1["success"] = false;
    		jsRes1["message"] = "hello anzer";
    
    		jsRes1["data"]["eventId"] = "20191225093046_JS001_PONU7505962";
    		/*jsRes1["data"]["crosswiseAngleChange"] = "21385"; jsRes1["data"]["lengthwiseAngleChange"] = "-198";*/
    
    		jsRes1["data"]["crosswiseAngleChange"] = "19535";
    		jsRes1["data"]["lengthwiseAngleChange"] = "-804";
    		jsRes1["data"]["enlargerateChange"] = "16";
    		jsRes1["data"]["pointX"] = "-515";
    		jsRes1["data"]["pointY"] = "-515";
    		++i;
    	}
    	
    	else if (2 == i)
    	{ 
    		//Sleep(5000);
    
    		//jsRes1.clear();
    		//jsRes1["data"]["eventId"] = "20191210151529_JS001_OOCU7892445";
    		//jsRes1["data"]["crosswiseAngle"] = "15700";
    		//jsRes1["data"]["lengthwiseAngle"] = "-1280";
    		//jsRes1["data"] = "";
    		//jsRes1["code"] = "00000000";
    		//jsRes1["success"] = true;
    		//jsRes1["message"] = "hello anzer,hello hello hello";
    		jsRes1["message"] = "\u4e2d\u534e\u4eba\u6c11\u5171\u548c\u56fd\u4e07\u5c81";
    
    
    		jsRes1.clear();
    
    		jsRes1["code"] = "11111111";
    		jsRes1["success"] = false;
    		jsRes1["message"] = "hello anzer";
    
    		jsRes1["data"]["eventId"] = "20191225093046_JS001_PONU7505962";
    		/*jsRes1["data"]["crosswiseAngleChange"] = "21685"; jsRes1["data"]["lengthwiseAngleChange"] = "190";*/
    
    		jsRes1["data"]["crosswiseAngleChange"] = "19665";
    		jsRes1["data"]["lengthwiseAngleChange"] = "-870";
    		jsRes1["data"]["enlargerateChange"] = "30";
    		++i;
    	}
    	
    
    	else if(3==i)
    	{ 
    		//Sleep(5000);
    		//jsRes1.clear();
    		//jsRes1["data"]["eventId"] = "20191210151529_JS001_OOCU7892445";
    		//jsRes1["data"]["crosswiseAngle"] = "-2280";
    		//jsRes1["data"]["lengthwiseAngle"] = "1280";
    		//jsRes1["code"] = "1";
    		//jsRes1["success"] = false;
    		jsRes1["message"] = "\u5e7f\u4e1c\u6d77\u5173\u6b22\u8fce\u4f60\u0020\u0020\u5f00\u7bb1\u5931\u8d25";
    		//jsRes1["message"] = "hello anzer,hello hello hello";
    
    
    		/*jsRes1.clear(); jsRes1["code"] = "1"; jsRes1["success"] = false; jsRes1["message"] = "hello anzer,hello hello hello";*/
    
    		jsRes1.clear();
    
    		jsRes1["code"] = "00000000";
    		jsRes1["success"] = true;
    		jsRes1["message"] = "hello anzer,open CSNU6393292";
    		jsRes1["data"]["openArea"] = "";
    		jsRes1["data"]["recogContainerNo"] = "CSNU6393292";
    		jsRes1["data"]["recogSealNo"] = "12227063";
    		jsRes1["data"]["containerNo"] = "CSNU6393292";
    		jsRes1["data"]["sealNo"] = "12227063";
    		jsRes1["data"]["canOpen"] = false;
    		jsRes1["data"]["comparisonInfo"] = "结束定点拍照任务";
    		jsRes1["data"]["eventId"] = "20191225093320_JS002_CSNU6393292";
    		i++;
    	}
    	else
    	{ 
    		jsRes1.clear();
    		i = 0;
    	}
    	
    	//--------------------------------------------------------
    	tmp = jsRes1.toStyledString();
    	SendHttpRsp(connection, tmp);
    	
    	printf("send body=%s\n\n", tmp.c_str());
    	printf("------------------------------------------------------------------------------\n\n");
    //-----------------------------------------------------
    	//SendHttpRsp(connection, resStr);
    	delete ImageBody;
    #endif // 0
    }
    
    // ---- websocket ---- //
    int HttpServer::isWebsocket(const mg_connection *connection)
    { 
    	return connection->flags & MG_F_IS_WEBSOCKET;
    }
    
    void HttpServer::HandleWebsocketMessage(mg_connection *connection, int event_type, websocket_message *ws_msg)
    { 
    	if (event_type == MG_EV_WEBSOCKET_HANDSHAKE_DONE)
    	{ 
    		printf("client websocket connected\n");
    		// 获取连接客户端的IP和端口
    		char addr[32];
    		mg_sock_addr_to_str(&connection->sa, addr, sizeof(addr), MG_SOCK_STRINGIFY_IP | MG_SOCK_STRINGIFY_PORT);
    		printf("client addr: %s\n", addr);
    
    		// 添加 session
    		s_websocket_session_set.insert(connection);
    		SendWebsocketMsg(connection, "client websocket connected");
    	}
    	else if (event_type == MG_EV_WEBSOCKET_FRAME)
    	{ 
    		mg_str received_msg = { 
    			(char *)ws_msg->data, ws_msg->size
    		};
    
    		char buff[1024] = {  0 };
    		strncpy(buff, received_msg.p, received_msg.len); // must use strncpy, specifiy memory pointer and length
    
    														 // do sth to process request
    		printf("received msg: %s\n", buff);
    		SendWebsocketMsg(connection, "send your msg back: " + std::string(buff));
    		//BroadcastWebsocketMsg("broadcast msg: " + std::string(buff));
    	}
    	else if (event_type == MG_EV_CLOSE)
    	{ 
    		if (isWebsocket(connection))
    		{ 
    			printf("client websocket closed\n");
    			// 移除session
    			if (s_websocket_session_set.find(connection) != s_websocket_session_set.end())
    				s_websocket_session_set.erase(connection);
    		}
    	}
    }
    
    void HttpServer::SendWebsocketMsg(mg_connection *connection, std::string msg)
    { 
    	mg_send_websocket_frame(connection, WEBSOCKET_OP_TEXT, msg.c_str(), strlen(msg.c_str()));
    }
    
    void HttpServer::BroadcastWebsocketMsg(std::string msg)
    { 
    	for (mg_connection *connection : s_websocket_session_set)
    		mg_send_websocket_frame(connection, WEBSOCKET_OP_TEXT, msg.c_str(), strlen(msg.c_str()));
    }
    
    bool HttpServer::Close()
    { 
    	mg_mgr_free(&m_mgr);
    	return true;
    }

主函数

// httpserver.cpp : 定义控制台应用程序的入口点。
    //
    
    #include "stdafx.h"
    #include <iostream>
    #include <memory>
    #include "http_server.h"
    #pragma warning(disable:4996)
    
    using namespace std;
    
    
    
    // 初始化HttpServer静态类成员
    mg_serve_http_opts HttpServer::s_server_option;
    std::string HttpServer::s_web_dir = "./web";
    std::unordered_map<std::string, ReqHandler> HttpServer::s_handler_map;
    std::unordered_set<mg_connection *> HttpServer::s_websocket_session_set;
    
    
    
    char g_Pic[1024 * 10] = {  0 };
    
    bool handle_fun1(std::string url, std::string body, mg_connection *c, OnRspCallback rsp_callback)
    { 
    	// do sth
    	std::cout << "handle fun1" << std::endl;
    	std::cout << "url: " << url << std::endl;
    	std::cout << "body: " << body << std::endl;
    
    	rsp_callback(c, "rsp1");
    
    	return true;
    }
    
    bool handle_fun2(std::string url, std::string body, mg_connection *c, OnRspCallback rsp_callback)
    { 
    	// do sth
    	std::cout << "handle fun2" << std::endl;
    	std::cout << "url: " << url << std::endl;
    	std::cout << "body: " << body << std::endl;
    
    	rsp_callback(c, "rsp2");
    
    	return true;
    }
    
    
    
    
    int main(int argc, char *argv[])
    { 
    	std::string port = "18899";
    	auto http_server = std::shared_ptr<HttpServer>(new HttpServer);
    	http_server->Init(port);
    	// add handler
    	http_server->AddHandler("/api/fun1", handle_fun1);
    	http_server->AddHandler("/api/fun2", handle_fun2);
    	
    	http_server->Start();
    
    
    
    	return 0;
    }

mongoose.h

mongoose.cpp

在这里插入代码片

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzM2MDcwNw_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191219155450640.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzM2MDcwNw==,size_16,color_FFFFFF,t_70