#pragma once
#include "mongoose.h"
#include
#include
#include
#include
#include
// 定义http返回callback
typedef void OnRspCallback(mg_connection *c, std::string);
// 定义http请求handler
using ReqHandler = std::function;
class HttpServer
{
public:
HttpServer() {}
~HttpServer() {}
void Init(const std::string &port, const std::string &rootdir = ".wwwroot"); // åˆå§‹åŒ–设置
bool Start(); // å¯åŠ¨httpserver
bool Close(); // å…³é—
void AddHandler(const std::string &url, ReqHandler req_handler); // 注册事件处ç†å‡½æ•°
void RemoveHandler(const std::string &url); // 移除时间处ç†å‡½æ•°
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 s_websocket_session_set; // 缓å˜websocket连接
std::string m_port; // 端å£
mg_mgr m_mgr; // 连接管ç†å™¨
static mg_serve_http_opts mServerOptions;
static std::unordered_map<:string reqhandler> s_handler_map; // å›žè°ƒå‡½æ•°æ˜ å°„è¡¨
};