C++ 手撸简易服务器(完善版本)
创始人
2025-05-30 08:17:16

本文没有带反射部分内容,可以看我之前发的

Server.h

#pragma once#include 
#include 
#include 
#include 
using namespace std;
#ifndef _SERVER_
#define _SERVER_#include 
#include "Net.h"
#include "Util.h"
#pragma comment(lib,"ws2_32.lib")NAME_SPACE_START(myUtil)#define SERVER_ADDR "127.0.0.1"
#define SERVER_PORT 8080class Server {
public:Server();Server(const std::string& addr = SERVER_ADDR, const int& port = SERVER_PORT);~Server() {}
public:bool listen(const int& maxConnect = 1);void setRoute(const string& url, const string& className, const string& classFunName);void runRoute(const Request& req, Response* resp);void setInterceptor(const string& url, const string& InterceptorName);void close();
protected:bool Init();void threadFunc(SOCKET m_server);int sendTelegram(const SOCKET& accept, const string& info, int flags);
private:SOCKET m_server;SOCKADDR_IN m_add_in;//thread listenThread;int connectCount{ 0 };unordered_map> routeMap;unordered_map interceptorMap;IniHelper iniHelper;
};NAME_SPACE_END()
#endif //!_SERVER_

Server.cpp

#include "Server.h"
#include 
#include 
#include 
#include 
#include 
#include 
#include "Net.h"
#include "Util.h"
#include "Reflex.h"
#include "CController.h"
#include "Interceptor.h"
using namespace std;NAME_SPACE_START(myUtil)Server::Server()
{m_add_in.sin_family = AF_INET;m_add_in.sin_addr.S_un.S_addr = htonl(INADDR_ANY);m_add_in.sin_port = htons(SERVER_PORT);
}Server::Server(const std::string& addr, const int& port)
{m_add_in.sin_family = AF_INET;m_add_in.sin_addr.S_un.S_addr = inet_addr(addr.c_str());m_add_in.sin_port = htons(port);
}bool Server::listen(const int& maxConnect)
{if (!Init()) {return false;}m_server = socket(AF_INET, SOCK_STREAM, 0);if (::bind(m_server, (sockaddr*)&m_add_in, sizeof(SOCKADDR)) == SOCKET_ERROR) {WSACleanup();return false;}if (::listen(m_server, maxConnect) < 0) {WSACleanup();return false;}thread listenThread(&Server::threadFunc, this, m_server);listenThread.join();return true;
}void Server::setRoute(const string& url, const string& className, const string& classFunName)
{routeMap.insert(pair>(url, pair(className, classFunName)));
}void Server::runRoute(const Request& req, Response* resp)
{string url = req.getRequestStatus().Url;Reflex* factory = myUtil::Singleton::Instance();string interceptorName = "";string res = "";string content = "";//拦截器//先去拦截器映射表中寻找类名,没有的话默认使用基类auto interceptorIt = interceptorMap.find(url);if (interceptorIt != interceptorMap.end()) interceptorName = interceptorIt->second;Interceptor* inter = (Interceptor*)factory->createClass(interceptorName);if (inter == nullptr) inter = new Interceptor();if (inter->preHandle(req, *resp)) {//反射auto it = routeMap.find(url);if (it != routeMap.end()) {CController* cont = (CController*)factory->createClass(it->second.first);res = cont->Call(it->second.second, req, resp);}//反射结束}else {resp->setResponseStatus("HTTP", 1, 1, 404, "Forbidden");}if (url.find("favicon.ico") != string::npos) {content = getFile(iniHelper.getIniConfig("staticResource", "favicon_path", "./favicon.ico"));resp->setResponseHead("content-type", "image/x-icon");}else if(res != "") {try {content = getFile(res);}catch(exception ex){content = ex.what();}}resp->setResponseContent(content);auto list = resp->getCookie();for (auto item : list) {resp->setResponseHead("Set-Cookie", item.toString());}resp->setResponseHead("content-length", to_string(content.size()));resp->setResponseHead("Server", "C++MVC");inter->postHandle(req, *resp);
}void Server::setInterceptor(const string& url, const string& InterceptorName)
{interceptorMap.insert(pair(url, InterceptorName));
}void Server::close()
{closesocket(m_server);WSACleanup();
}bool Server::Init()
{WORD ver = MAKEWORD(2, 2);WSADATA wsadata;int errFlag = -1;errFlag = WSAStartup(ver, &wsadata);if (errFlag != 0) return false;//检测版本号if (LOBYTE(wsadata.wVersion) != 2 || HIBYTE(wsadata.wHighVersion) != 2) {WSACleanup();return false;}return true;}
void Server::threadFunc(SOCKET m_server)
{while (1) {SOCKADDR_IN m_acc_in;int len = sizeof(SOCKADDR);SOCKET m_accept = accept(m_server, (sockaddr*)&m_acc_in, &len);if (m_accept == SOCKET_ERROR) {continue;}int recv_len = 0;char recv_buf[10000];recv_len = recv(m_accept, recv_buf, 10000, 0);//char 转 wcharint  unicodeLen = ::MultiByteToWideChar(CP_UTF8, 0, recv_buf, -1, NULL, 0);wchar_t* pUnicode = new  wchar_t[unicodeLen];memset(pUnicode, 0, unicodeLen * sizeof(wchar_t));::MultiByteToWideChar(CP_UTF8, 0, recv_buf, -1, (LPWSTR)pUnicode, unicodeLen);wstring  rt = pUnicode;//重设大小char* pAscii = new char[recv_len];memset(pAscii, 0, sizeof(char) * recv_len);strncpy(pAscii, recv_buf, recv_len);string lrt(pAscii);//解析请求Request req(lrt);Response resp;runRoute(req, &resp);cout << "请求地址:" << req.getRequestStatus().Url << endl;sendTelegram(m_accept, resp.toString(), 0);closesocket(m_accept);}
}int Server::sendTelegram(const SOCKET& accept, const string& info, int flags)
{int res = send(accept, info.c_str(), info.size(), flags);return res;
}NAME_SPACE_END()

Interceptor.h

#pragma once
#include "Net.h"
#include "Reflex.h"
using namespace myUtil;
#ifndef _INTERCEPTOR_
#define _INTERCEPTOR_class Interceptor : public RObject {
public:virtual bool preHandle(const Request& request, const Response& response) { return true; }virtual void postHandle(const Request& request, const Response& response) {}virtual void afterCompletion(const Request& request, const Response& response) {}
};#endif //!_INTERCEPTOR_

indexInterceptor.h

#pragma once
#include "Interceptor.h"
class IndexInterceptor : public Interceptor {
public:bool preHandle(const Request& request, const Response& response) override {return false;}void postHandle(const Request& request, const Response& response) override {}void afterCompletion(const Request& request, const Response& response) override {}
};

InterceptorMacro.h

#pragma once
#include "Reflex.h"
#include "indexInterceptor.h"
#define REFLEX_INPERCEPTOR_DECLARE \
REGISTER_REFLEX(IndexInterceptor)

Cookie.h

#pragma once
#ifndef _COOKIE_
#define _COOKIE_
#include 
using namespace std;
class Cookie
{
public:Cookie() {}Cookie(const string& name, const string& value) :_name(name), _value(value) {_comment = "";_path = "";_domain = "";_version = "";_maxAge = 0;}string getNameValue() const;void setNameValue(const string& name, const string& value);void setComment(const string& comment);void setPath(const string& path);void setDomain(const string& domain);void setVersion(const string& version);void setMaxAge(const int& maxAge);string getComment() const;string getPath() const;string getDomain() const;string getVersion() const;int getMaxAge() const;string toString() const;
private:string _name;string _value;//注释string _comment;//路径,若要访问的url startwith(path)此cookie携带string _path;//网站域名string _domain;string _version;//生存时间int _maxAge{ 0 };
};#endif //!_COOKIE_

Cookie.cpp

#include "Cookie.h"string Cookie::getNameValue() const
{return _name + "=" + _value;
}void Cookie::setNameValue(const string& name, const string& value)
{_name = name;_value = value;
}void Cookie::setComment(const string& comment)
{_comment = comment;
}void Cookie::setPath(const string& path)
{_path = path;
}void Cookie::setDomain(const string& domain)
{_domain = domain;
}void Cookie::setVersion(const string& version)
{_version = version;
}void Cookie::setMaxAge(const int& maxAge)
{_maxAge = maxAge;
}string Cookie::getComment() const
{return _comment;
}string Cookie::getPath() const
{return _path;
}string Cookie::getDomain() const
{return _domain;
}string Cookie::getVersion() const
{return _version;
}int Cookie::getMaxAge() const
{return _maxAge;
}string Cookie::toString() const
{string res = getNameValue();if (_comment != "") res += ";comment=" + _comment;if (_path != "") res += ";Path=" + _path;if (_domain != "") res += ";Domain=" + _domain;if (_version != "") res += ";Version=" + _version;res += ";Max-Age=" + _maxAge;return res;
}

CController.h

#pragma once
#ifndef _CCONTROLLER_
#define _CCONTROLLER_
#include "Reflex.h"
using namespace myUtil;
class CController : public RObject
{
};
#endif //!_CCONTROLLER_

indexController.h

#pragma once
#include "CController.h"
#include "Net.h"
#include "Reflex.h"
using namespace myUtil;
class indexController : public CController
{
public:indexController() {}~indexController() {}string index(const Request& req, Response* resp);string test(const Request& req, Response* resp);
};

indexController.cpp

#include "indexController.h"
#include 
using namespace std;string indexController::index(const Request& req, Response* resp)
{resp->setResponseStatus("HTTP", 1, 1, 200, "OK");resp->setResponseHead("Content-Type", "text/html,charset=UTF-8");return "index.html";
}string indexController::test(const Request& req, Response* resp)
{resp->setResponseStatus("HTTP", 1, 1, 200, "OK");resp->setResponseHead("Content-Type", "text/html,charset=UTF-8");Cookie cookie("test", "test");cookie.setDomain("localhost");cookie.setMaxAge(10);cookie.setPath("/test");resp->setCookie(cookie);return "test.html";
}

ControllerMacro.h

#pragma once
#include "indexController.h"
#define REFLEX_DECLARE \
REGISTER_REFLEX(indexController)\
REGISTER_REFLEX_METHOD_ARGS(indexController, index, string, Request&, Response*)\
REGISTER_REFLEX_METHOD_ARGS(indexController, test, string, Request&, Response*)

Net.h

#pragma once
#ifndef _NET_
#define _NET_#include 
#include 
#include 
#include "Util.h"
#include "Cookie.h"
using namespace std;NAME_SPACE_START(myUtil)#define BLACK "\r\n"
#define SPACE " "class Net {
public:virtual string toString() = 0;virtual vector getCookie() const = 0;virtual void setCookie(const Cookie& cookie) = 0;Net() {}
protected:vector _cookie;
};struct RequestStatus
{string RMethod;string Url;string ProName;short verHigh;short verLow;
};struct ResponseStatus
{string ProName;short verHigh;short verLow;short status;string statusWord;
};//请求
class Request : public Net {
public:Request();Request(const string& sourceStr);void setRequestStatus(const string& method = "GET", const string& url = "/", const string& _proName = "HTTP", const short& _verHigh = 1, const short& _verLow = 1);void setRequestHead(const string& headKey, const string& headValue);void setRequestContent(const string& content);RequestStatus getRequestStatus() const;string getRequestContent(const string& headKey) const;vector getCookie() const override;void setCookie(const Cookie& cookie) override;string toString() override;~Request() {}
private:RequestStatus _status;unordered_map _RequestHead;string _RequestContent{ "" };
};//响应
//结构 状态行, 响应头部, 空行, 响应正文
class Response : public Net {
public:Response();void setResponseStatus(const string& _proName = "HTTP", const short& _verHigh = 1, const short& _verLow = 1, const short& status = 200, const string& word = "");void setResponseHead(const string& headKey, const string& headValue);void setResponseContent(const string& content);ResponseStatus getResponseStatus() const;string getResponseHeadByKey(const string& headKey) const;vector getCookie() const override;void setCookie(const Cookie& cookie) override;string toString() override;~Response();
private:ResponseStatus _status;unordered_map _ResponseHead;string _ResponseContent{ "" };
};class Analyse {
public:static vector getVectorBySplit(const string& source, const char& ch);static unordered_map getMapBySplit(const string& source, const char& ch1,const char& ch2);static string makeVectorByChar(const vector& v, const char& ch);static string makeMapByChars(const unordered_map& m, const char& ch1, const char& ch2);
};NAME_SPACE_END()
#endif //!_NET_

Net.cpp

#include "Net.h"
NAME_SPACE_START(myUtil)Response::Response()
{_status.ProName = "HTTP";_status.verHigh = 1;_status.verLow = 1;_status.status = 200;_status.statusWord = "OK";
}void Response::setResponseStatus(const string& _proName, const short& _verHigh, const short& _verLow, const short& status, const string& word)
{_status.ProName = _proName;_status.verHigh = _verHigh;_status.verLow = _verLow;_status.status = status;_status.statusWord = word;
}void Response::setResponseHead(const string& headKey, const string& headValue)
{_ResponseHead.insert(pair(headKey, headValue));
}void Response::setResponseContent(const string& content)
{_ResponseContent = content;
}ResponseStatus Response::getResponseStatus() const
{return _status;
}string Response::getResponseHeadByKey(const string& headKey) const
{auto it = _ResponseHead.find(headKey);if (it == _ResponseHead.end()) return "";return (*it).second;
}vector Response::getCookie() const
{return _cookie;
}void Response::setCookie(const Cookie& cookie)
{_cookie.push_back(cookie);
}string Response::toString()
{string res = "";res += _status.ProName + "/" + to_string(_status.verHigh) + "." + to_string(_status.verLow)+ SPACE + to_string(_status.status) + SPACE + _status.statusWord + BLACK;for (auto it = _ResponseHead.begin(); it != _ResponseHead.end(); it++) {res += (*it).first + ":" + SPACE + (*it).second + BLACK;}res += BLACK;res += _ResponseContent;return res;
}Response::~Response()
{
}Request::Request(const string& sourceStr)
{int i = 0;vector reqGroup = Analyse::getVectorBySplit(sourceStr, '\n');//解析状态行vector statuses = Analyse::getVectorBySplit(reqGroup[0], ' ');_status.RMethod = statuses.at(0);_status.Url = statuses.at(1);statuses.at(2).pop_back();vector verInfo = Analyse::getVectorBySplit(statuses.at(2), '/');_status.ProName = verInfo.at(0);_status.verHigh = Analyse::getVectorBySplit(verInfo.at(1), '.').at(0).at(0) - '0';_status.verLow = Analyse::getVectorBySplit(verInfo.at(1), '.').at(1).at(0) - '0';//解析请求头for (i = 1; i < reqGroup.size(); i++) {if (reqGroup[i] == "\r")break;reqGroup[i].pop_back();vector temp = Analyse::getVectorBySplit(reqGroup[i], ':');_RequestHead.insert(pair(temp.at(0), temp.at(1)));}i++;for (i; i < reqGroup.size(); i++) {_RequestContent += reqGroup.at(i) + "\n";}
}void Request::setRequestStatus(const string& method, const string& url, const string& _proName, const short& _verHigh, const short& _verLow)
{_status.RMethod = method;_status.Url = url;_status.ProName = _proName;_status.verHigh = _verHigh;_status.verLow = _verLow;
}void Request::setRequestHead(const string& headKey, const string& headValue)
{_RequestHead.insert(pair(headKey, headValue));
}void Request::setRequestContent(const string& content)
{_RequestContent = content;
}RequestStatus Request::getRequestStatus() const
{return _status;
}string Request::getRequestContent(const string& headKey) const
{return _RequestContent;
}string Request::toString()
{string res = "";res += _status.RMethod + SPACE + _status.Url + SPACE + _status.ProName + "/"+ to_string(_status.verHigh) + "." + to_string(_status.verLow) + BLACK;for (auto it = _RequestHead.begin(); it != _RequestHead.end(); it++) {res += (*it).first + ":" + SPACE + (*it).second + BLACK;}res += BLACK;res += _RequestContent;return res;
}vector Request::getCookie() const
{return _cookie;
}void Request::setCookie(const Cookie& cookie)
{_cookie.push_back(cookie);
}vector Analyse::getVectorBySplit(const string& source, const char& ch)
{vector res;string temp = "";for (int i = 0; i < source.size(); i++) {if (source[i] == ch) {res.push_back(temp);temp = "";}else {char ch = source[i];temp.push_back(ch);}}if (temp != "") res.push_back(temp);return res;
}unordered_map Analyse::getMapBySplit(const string& source, const char& ch1, const char& ch2)
{unordered_map res;vector temp = getVectorBySplit(source, ch1);for (string str : temp) {vector t = getVectorBySplit(str, ch2);if (t.size() != 2) continue;res.insert(pair(t.at(0), t.at(1)));}return res;
}string Analyse::makeVectorByChar(const vector& v, const char& ch)
{string res = "";for (auto str : v) {res += str + ch;}res.pop_back();return res;
}string Analyse::makeMapByChars(const unordered_map& m, const char& ch1, const char& ch2)
{string res = "";for (auto it = m.begin(); it != m.end(); it++) {res += it->first + ch2 + it->second + ch1;}res.pop_back();return res;
}
NAME_SPACE_END()

config.ini

[staticResource]
favicon_path=./ico/favicon.ico

使用方式如下

通过setRoute设置路由规则,类似于springboot中的注释部分
通过setInterceptor设置拦截器规则,如果没有设置的话,会默认找基类
以上两个设置之后还要再两个macro文件中设置宏展开,否则反射找不到对应的类,关于反射如何使用请看这个
https://blog.csdn.net/weixin_43891802/article/details/129411364

#include 
#include 
#include "ControllerMacro.h"
#include "InterceptorMacro.h"
#include "Server.h"
using namespace std;
using namespace myUtil;REFLEX_DECLARE
REFLEX_INPERCEPTOR_DECLAREint main() {Server server("127.0.0.1", 8080);server.setRoute("/", "indexController", "index");server.setRoute("/test", "indexController", "test");//server.setInterceptor("/test", "IndexInterceptor");server.listen(2);return 0;
}

相关内容

热门资讯

李樱,已履新 李樱,已履新 李... 中国华能集团有限公司网站“公司领导”一栏最新信息显示,李樱已任中国华能集团有限公司总会计师、党组成员...
2025小红书教育营销答案之书 2025小红书教育营销答案之书 报告共计:18页 《2025小红书教育营销答案之书》指出,小红书正重...
央企控股上市公司密集发声 央企... 今年以来,国务院国资委多次部署提高央企控股上市公司质量,加强市值管理,传递信心、稳定预期。近期多家央...
本周外盘看点丨中美将举行经贸磋... 上周国际市场风云变幻,欧央行继续降息,美国总统特朗普与特斯拉CEO马斯克隔空喊话震惊市场。上周美股全...
一条视频涨粉2000万,韦神凭... 韦东奕为何要开抖音号?01 三句话,涨粉2000万好家伙,还得是韦神。韦东奕最近在抖音上再次创造了一...
新质生产力培育见效 资本市场向... 图虫创意/供图 证券时报记者 陈见南 在2025年《政府工作报告》中,“新质生产力”被赋予核心地位...
接棒淄博、尔滨,苏超凭啥能接住... 记得我们之前就专门分析过淄博烧烤、尔滨走红,对于整个事件背后的操盘可谓是叹服不已,然而就在最近这一轮...
惨不忍睹!5月合资新能源暴跌:... 合资新能源,最近有点烦在国内的新能源汽车市场,合资新源是一个非常有意思的存在。这一类的新能源汽车,最...
3万美元“产品”,说归零就归零... 投资小红书-第240期 过面尘土、伤痕累累,但我们依然且必须相信时如果不是翻开历史,投资者很难想象:...
全球化遭遇空前挑战,中美双核驱... 界面新闻记者 | 刘婷 在6月7日的“中国宏观经济论坛”(CMF)上,与会专家表示,短期内,特朗普...
饶毅拍案而起:科伦老板光膀子卖... 文 | 张佳儒等你到了75岁,肌肉紧实有型,胸肌、臂肌线条清晰,你敢想吗?梦想还是要有的,因为真的有...
金陵体育笑傲苏超 金陵体育笑傲... 富凯摘要:金陵体育表示,正积极探索2C业务增长点,以打造城镇体育为支点孵化体育消费品牌矩阵。作者|辛...
央企控股上市公司密集发声,多措... 今年以来,国务院国资委多次部署提高央企控股上市公司质量,加强市值管理,传递信心、稳定预期。近期多家央...
上交所:将推动上市公司进一步加... 上海6月6日电 (高志苗)上海证券交易所6日发布消息称,上交所近日召开高分红重回报暨上市公司价值提升...
特斯拉“跌下神坛”? 6月5日,马斯克与特朗普反目互怼后不久,特斯拉股价当日一度暴跌16%,截至当天收盘,特斯拉股价较开盘...
汉武帝都点赞的一次复仇 汉武帝... 上文讲到齐景公复霸,复哪个霸呢?春秋五霸之首,齐桓公。不过今天我们不讲著名的齐桓公,而是讲他的哥哥,...
“普五”破价到了756元,五粮... 随着“618”大促的到来,白酒企业的价格体系,再次遭受强烈冲击。去年,各大电商平台以“百亿补贴”为主...
比买黄金还赚钱!“塑料茅台”L... 年轻人的“茅台”竟然是个“娃娃”?泡泡玛特旗下的Labubu,正借着爆火的流量红利,身价一路飙升。据...
聚焦“两高四着力” 人大代表在... 河南日报客户端记者 陈小平 “今年,我们将采取‘建租结合’的方式,在北京、上海、武汉、沈阳、西安、成...
原创 促... 周末,市场没有利空,大家的情绪慢慢平静了,上证指数再次临近3400点,已经是物是人非了。银行分化,白...
江西“首富”李德仙,财富缩水超... 光伏行业分化,已成大趋势。今年一季度如果说哪家光伏巨头的表现最让外界大跌眼镜,那么晶科能源一定“榜上...
福莱新材推“三维力”电子皮肤 ... 21世纪经济报道记者 赵云帆 上海报道从未来终局角度思考,柔性多模态电子皮肤无疑是通用型人形机器人的...
2025年6月7日比特币与以太... 特朗普马斯克公开决裂引发市场巨震,比特币反弹至104,472美元,以太坊大幅反弹至2,474美元 一...
广州首批配售型保障房摇出选房序... 6月7日上午,广州今年首批配售型保障房迎来了第二次摇号确定选房序号的关键环节。在前期经过递交申请、第...
贬低业绩可以忍,贬低颜值不能忍... 6月7日,金石杂谈近期太关注公募了,不曾想对私募圈消息闭塞了。在6月5日深夜,私募小魔女李蓓开通个人...
热搜!“全智贤老公炒币亏了15... 6月7日午后,“全智贤老公炒币亏了150亿韩元”相关话题一度登上微博热搜。据观察者网援引韩媒报道,随...
中信建投:持续看好创新药产业技... 人民财讯6月7日电,中信建投研报表示,美国临床肿瘤学会(ASCO)年会是世界上规模最大、学术水平最高...
特斯拉“擎天柱”人形机器人项目... 来源:中国新闻网中新网6月7日电(吴家驹)综合外媒报道,特斯拉“擎天柱”(Optimus)人形机器人...
周鸿祎:准备干掉360整个市场... 周鸿祎称准备干掉360整个市场部。360集团创始人、董事长兼首席执行官周鸿祎发视频称,“我准备干掉3...