【项目】仿muduo库One Thread One Loop式主从Reactor模型实现高并发服务器（Http测试板块）

devtools/2024/11/15 8:23:21/
http://www.w3.org/2000/svg" style="display: none;">

【项目】仿muduo库One Thread One Loop式主从Reactor模型实现高并发服务器（Http测试板块）

  • 一、使用Http网页界面
    • 1、main.cc原码和index.html原码
    • 2、运行结果
      • （1）测试结果1：用index.html内部的代码
      • （2）测试结果2：用hello
      • （3）测试结果3：用login
      • （4）测试结果4:hello?username=jrh&password=123456
  • 二、长连接的测试一
    • 1、代码部分
    • 2、测试结果（错误结果）
      • （1）不是长连接，查看错误原因
      • （2）通过Close看是否进入
      • （3）Request中的Close函数打印调试
      • （4）去掉尾部\n
      • （5）去掉空格尝试1
      • （6）去掉空格尝试2（成功）
  • 三、长连接的测试二
    • 1、代码部分
    • 2、测试结果
  • 四、错误请求测试
    • 1、代码部分
      • （1）代码一
      • （2）代码二
    • 2、测试结果
      • （1）运行结果1
      • （2）运行结果2
  • 五、HTTP服务器业务处理超时测试
    • 1、代码部分修改
    • 2、代码部分
    • 3、测试结果
  • 六、HTTP服务器同时多条请求测试
    • 1、代码部分
    • 2、运行结果
  • 七、HTTP服务器大文件传输测试
    • 1、代码部分
    • 2、测试结果
  • 八、HTTP服务器大文件传输测试
    • 效果展示

一、使用Http网页界面

1、main.cc原码和index.html原码

#include "http.hpp"
#define WWWROOT "./wwwroot/"
std::string RequestStr(const HttpRequest& req)
{std::stringstream ss;ss << req._method << " " << req._path << " " << req._version << "\r\n";for (auto& it : req._params){ss << it.first << ": " << it.second << "\r\n";}for (auto& it : req._headers){ss << it.first << ": " << it.second << "\r\n";}ss << "\r\n";ss << req._body;return ss.str();
}
void Hello(const HttpRequest& req, HttpResponse* rsp)
{rsp->SetContent(RequestStr(req), "text/plain");
}
void Login(const HttpRequest& req, HttpResponse* rsp)
{rsp->SetContent(RequestStr(req), "text/plain");
}
void PutFile(const HttpRequest& req, HttpResponse* rsp)
{std::string pathname = WWWROOT + req._path;rsp->SetContent(RequestStr(req), "text/plain");
}
void DeleteFile(const HttpRequest& req, HttpResponse* rsp)
{rsp->SetContent(RequestStr(req), "text/plain");
}
int main()
{HttpServer server(8850);server.SetThreadCount(3);server.SetBaseDir(WWWROOT); // 设置静态资源根目录，告诉服务器有静态资源到来需要到哪里找资源文件server.Get("/hello", Hello);server.Post("/login", Login);server.Put("/xxx.txt", PutFile);server.Delete("/xxx.txt", DeleteFile);server.Listen(); // 直接开始启动了return 0;
}

// index.html
<html><head><meta charset="utf8"></head><body><form action="/login" method="post"><input type="text" name="username"><br/><input type="password" name="password"><br/><input type="submit" value="提交" name="submit"></form></body>
</html>

2、运行结果

运行前记得开放端口哦！

（1）测试结果1：用index.html内部的代码

https://img-blog.csdnimg.cn/direct/1b94db697ef842d1ae2f229cb1dc985e.png" alt="在这里插入图片描述" />
网页界面如下
https://img-blog.csdnimg.cn/direct/385696a96e1442d9b7d6739e246e57af.png" alt="在这里插入图片描述" />

（2）测试结果2：用hello

网页界面如下：
https://img-blog.csdnimg.cn/direct/6bdf6d0578a44736823d4adebed4e11c.png" alt="在这里插入图片描述" />

（3）测试结果3：用login

网页界面如下：
https://img-blog.csdnimg.cn/direct/72e82a8b5a454be1b476e44f85243131.png" alt="在这里插入图片描述" />
按一下提交：

https://img-blog.csdnimg.cn/direct/2d5ebe1509f341188f55b69d983b75b2.png" alt="在这里插入图片描述" />

（4）测试结果4:hello?username=jrh&password=123456

网页界面如下：
https://img-blog.csdnimg.cn/direct/6fdf7ed66940407bb56ec7d214cf08af.png" alt="在这里插入图片描述" />

二、长连接的测试一

1、代码部分

// client1.cc
// 长连接测试1：创建一个客户端，持续给客户端发消息，直到超过超时时间看是否正常
#include "../source/server.hpp"int main()
{Socket clent_socket;clent_socket.Client(8888, "127.0.0.1");std::string req = "GET /hello HTTP/1.1\r\nConnection: keep-alive\r\nContent-Length: 0\r\n\r\n";while(1){assert(clent_socket.Send(req.c_str(), req.size()) != -1);char buff[1024] = { 0 };assert(clent_socket.Recv(buff, 1023));DEBLOG("[%s]", buff);sleep(3);}clent_socket.Close();return 0;
}

// Makefile
all:client1
client1:client1.ccg++ -o $@ $^ -std=c++11 -lpthreadserver:server.ccg++ -o $@ $^ -std=c++11 -lpthread
Client:tcp_cli.ccg++ -o $@ $^ -std=c++11 -lpthread
Server:tcp_svr.ccg++ -o $@ $^ -std=c++11 -lpthread
.PHONY:clean
clean:rm -f Client Server server

2、测试结果（错误结果）

（1）不是长连接，查看错误原因

https://img-blog.csdnimg.cn/direct/0bbfa676d8dc4a55ba83eee32097528d.png" alt="在这里插入图片描述" />

（2）通过Close看是否进入

我们此时通过HttpServer中的Close函数进行打印看一下有没有进去！
https://img-blog.csdnimg.cn/direct/85c6cb300701470192e478f953651c6e.png" alt="在这里插入图片描述" />

https://img-blog.csdnimg.cn/direct/11f79f34c9824fe3b6f76dfb28527760.png" alt="在这里插入图片描述" />

（3）Request中的Close函数打印调试

我们此时直接去request中的Close中进行日志打印一下：
https://img-blog.csdnimg.cn/direct/8b19533d7b824e7b8221128b4130111d.png" alt="在这里插入图片描述" />
https://img-blog.csdnimg.cn/direct/03d51ffd2fbd44ffae645a73c33586e1.png" alt="在这里插入图片描述" />
发现，有头部这个Connection，但是进行相当的时候是错误的，我们看上面的[keep-alive]但是上面打印的完全不是这样的，所以我们接下来需要去HttpContext中进行修改，我们直接在后面加上末尾去掉换行字符和回车字符！

（4）去掉尾部\n

https://img-blog.csdnimg.cn/direct/6308230b47f547289b52177b4c830345.png" alt="在这里插入图片描述" />
https://img-blog.csdnimg.cn/direct/bd6fac588a8a42aa96af39232d34c04c.png" alt="在这里插入图片描述" />

（5）去掉空格尝试1

能好一点，但是还是不对，我起初的思路在于把前面一个空格给去掉，所以在前面用了substr/erase，我们先看一下结果吧：
https://img-blog.csdnimg.cn/direct/38bab25b0079455b987d1b551b5c7e67.png" alt="在这里插入图片描述" />

https://img-blog.csdnimg.cn/direct/3aa430829a7649e8abeeb5ea98c31f00.png" alt="在这里插入图片描述" />
发现什么都没有了，我的天，我理解了一遍代码发现它是从后面才开始拼接上去的，所以我们需要在后面进行理解，发现此时value需要到+2这个位置往后拼接才可，因为刚好+2是跳过一个空格了，我们看一下是不是了：

（6）去掉空格尝试2（成功）

https://img-blog.csdnimg.cn/direct/6db8581e4d1e48e1b243e07bd075abea.png" alt="在这里插入图片描述" />
https://img-blog.csdnimg.cn/direct/148087b5801a430c9c10e1e06e4f62e2.png" alt="在这里插入图片描述" />
成功！通过这次调试，发现理清代码逻辑和进行日志打印是很重要的！

三、长连接的测试二

1、代码部分

// client2.cc
// 长连接测试2：创建一个客户端，给服务器发送一次数据后，不动了，查看服务器是否会正常的超时关闭连接
#include "../source/server.hpp"int main()
{Socket clent_socket;clent_socket.Client(8888, "127.0.0.1");std::string req = "GET /hello HTTP/1.1\r\nConnection: keep-alive\r\nContent-Length: 0\r\n\r\n";while(1){assert(clent_socket.Send(req.c_str(), req.size()) != -1);char buff[1024] = { 0 };assert(clent_socket.Recv(buff, 1023));DEBLOG("[%s]", buff);sleep(15);}clent_socket.Close();return 0;
}

// Makefile
all:client2
client2:client2.ccg++ -o $@ $^ -std=c++11 -lpthread
client1:client1.ccg++ -o $@ $^ -std=c++11 -lpthreadserver:server.ccg++ -o $@ $^ -std=c++11 -lpthread
Client:tcp_cli.ccg++ -o $@ $^ -std=c++11 -lpthread
Server:tcp_svr.ccg++ -o $@ $^ -std=c++11 -lpthread
.PHONY:clean
clean:rm -f Client Server server

2、测试结果

https://img-blog.csdnimg.cn/direct/37eb2dc86bbe4282b16fd3b5f8ba70dd.png" alt="在这里插入图片描述" />

四、错误请求测试

1、代码部分

（1）代码一

// client3.cc
/*给服务器发送一个数据，告诉服务器要发送1024字节的数据，但是实际发送的数据不足1024，查看服务器处理结果*/
/*1. 如果数据只发送一次，服务器将得不到完整请求，就不会进行业务处理，客户端也就得不到响应，最终超时关闭连接2. 连着给服务器发送了多次小的请求,服务器会将后边的请求当作前边请求的正文进行处理，而后便处理的时候有可能就会因为处理错误而关闭连接
*/#include "../source/server.hpp"int main()
{Socket client_sock;client_sock.Client(8888, "127.0.0.1");std::string req = "GET /hello HTTP/1.1\r\nConnection: keep-alive\r\nContent-Length: 100\r\n\r\njiangrenhai"; // 不到100个字节while(1) {assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);char buf[1024] = {0};assert(client_sock.Recv(buf, 1023));DEBLOG("[%s]", buf);sleep(3);}client_sock.Close();return 0;
}

// Makefile
all:client3
client3:client3.ccg++ -o $@ $^ -std=c++11 -lpthread
client2:client2.ccg++ -o $@ $^ -std=c++11 -lpthread
client1:client1.ccg++ -o $@ $^ -std=c++11 -lpthreadserver:server.ccg++ -o $@ $^ -std=c++11 -lpthread
Client:tcp_cli.ccg++ -o $@ $^ -std=c++11 -lpthread
Server:tcp_svr.ccg++ -o $@ $^ -std=c++11 -lpthread
.PHONY:clean
clean:rm -f Client Server server

（2）代码二

// client3.cc
/*给服务器发送一个数据，告诉服务器要发送1024字节的数据，但是实际发送的数据不足1024，查看服务器处理结果*/
/*1. 如果数据只发送一次，服务器将得不到完整请求，就不会进行业务处理，客户端也就得不到响应，最终超时关闭连接2. 连着给服务器发送了多次小的请求,服务器会将后边的请求当作前边请求的正文进行处理，而后便处理的时候有可能就会因为处理错误而关闭连接
*/#include "../source/server.hpp"int main()
{Socket client_sock;client_sock.Client(8888, "127.0.0.1");std::string req = "GET /hello HTTP/1.1\r\nConnection: keep-alive\r\nContent-Length: 100\r\n\r\njiangrenhai"; // 不到100个字节while(1) {assert(client_sock.Send(req.c_str(), req.size()) != -1);assert(client_sock.Send(req.c_str(), req.size()) != -1);assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);//assert(client_sock.Send(req.c_str(), req.size()) != -1);char buf[1024] = {0};assert(client_sock.Recv(buf, 1023));DEBLOG("[%s]", buf);sleep(3);}client_sock.Close();return 0;
}

2、测试结果

（1）运行结果1

https://img-blog.csdnimg.cn/direct/19269570a7d4450fb78d382f2e1f9189.png" alt="在这里插入图片描述" />

我们的解决方法为：发现OnMessage的回调函数出问题了！
https://img-blog.csdnimg.cn/direct/8381b230fc90426582348ad793376b23.png" alt="在这里插入图片描述" />
当我们的请求数据很多的情况下，程序不退出，那么我们的OVER没有使用，所以我们加入我们注释的那几行代码：
https://img-blog.csdnimg.cn/direct/75b78e4979944976b7f5a2ea0ce71aad.png" alt="在这里插入图片描述" />
https://img-blog.csdnimg.cn/direct/9c52f80f8ad94e3388baf8de38b13ad7.png" alt="在这里插入图片描述" />
是预期结果！

（2）运行结果2

https://img-blog.csdnimg.cn/direct/2bba686fa2574feea2306c279b1972a3.png" alt="在这里插入图片描述" />

五、HTTP服务器业务处理超时测试

1、代码部分修改

https://img-blog.csdnimg.cn/direct/b6122a87dc434650be75333adb3cfb6b.png#pic_center" alt="在这里插入图片描述" />
https://img-blog.csdnimg.cn/direct/a6a0e27cf4cb49a2bf2e6ae72494a294.png#pic_center" alt="在这里插入图片描述" />

2、代码部分

// client4.cc
/* 业务处理超时，查看服务器的处理情况当服务器达到了一个性能瓶颈，在一次业务处理中花费了太长的时间（超过了服务器设置的非活跃超时时间）1. 在一次业务处理中耗费太长时间，导致其他的连接也被连累超时，其他的连接有可能会被拖累超时释放假设现在  12345描述符就绪了， 在处理1的时候花费了30s处理完，超时了，导致2345描述符因为长时间没有刷新活跃度1. 如果接下来的2345描述符都是通信连接描述符，如果都就绪了，则并不影响，因为接下来就会进行处理并刷新活跃度2. 如果接下来的2号描述符是定时器事件描述符，定时器触发超时，执行定时任务，就会将345描述符给释放掉这时候一旦345描述符对应的连接被释放，接下来在处理345事件的时候就会导致程序崩溃（内存访问错误）因此这时候，在本次事件处理中，并不能直接对连接进行释放，而应该将释放操作压入到任务池中，等到事件处理完了执行任务池中的任务的时候，再去释放
*/#include "../source/server.hpp"int main()
{signal(SIGCHLD, SIG_IGN);for (int i = 0; i < 10; i++) {pid_t pid = fork();if (pid < 0) {DEBLOG("FORK ERROR!!!");return -1;}else if (pid == 0) {Socket cli_sock;cli_sock.Client(8888, "127.0.0.1");std::string req = "GET /hello HTTP/1.1\r\nConnection: keep-alive\r\nContent-Length: 0\r\n\r\n";while(1) {assert(cli_sock.Send(req.c_str(), req.size()) != -1);char buf[1024] = {0};assert(cli_sock.Recv(buf, 1023));DEBLOG("[%s]", buf);}cli_sock.Close();exit(0);}}while(1) sleep(1);return 0;
}

3、测试结果

https://img-blog.csdnimg.cn/direct/3e17875d1ace41ec94dd6a7f6a2ce0c4.png#pic_center" alt="在这里插入图片描述" />

六、HTTP服务器同时多条请求测试

1、代码部分

https://img-blog.csdnimg.cn/direct/b47880605baa4edbb74dd30d5e71bd48.png" alt="在这里插入图片描述" />

// client5.cc
/*一次性给服务器发送多条数据，然后查看服务器的处理结果*/
/*每一条请求都应该得到正常处理*/#include "../source/server.hpp"int main()
{Socket cli_sock;cli_sock.Client(8888, "127.0.0.1");std::string req = "GET /hello HTTP/1.1\r\nConnection: keep-alive\r\nContent-Length: 0\r\n\r\n";req += "GET /hello HTTP/1.1\r\nConnection: keep-alive\r\nContent-Length: 0\r\n\r\n";req += "GET /hello HTTP/1.1\r\nConnection: keep-alive\r\nContent-Length: 0\r\n\r\n";while(1) {assert(cli_sock.Send(req.c_str(), req.size()) != -1);char buf[1024] = {0};assert(cli_sock.Recv(buf, 1023));DEBLOG("[%s]", buf);sleep(3);}cli_sock.Close();return 0;
}

2、运行结果

https://img-blog.csdnimg.cn/direct/721eb28f9eea41c690365f2ce0bf3257.png" alt="在这里插入图片描述" />

七、HTTP服务器大文件传输测试

1、代码部分

// client6.cc
/*大文件传输测试，给服务器上传一个大文件，服务器将文件保存下来，观察处理结果*/
/*上传的文件，和服务器保存的文件一致
*/
#include "../source/http/http.hpp"int main()
{Socket cli_sock;cli_sock.Client(8085, "127.0.0.1");std::string req = "PUT /1234.txt HTTP/1.1\r\nConnection: keep-alive\r\n";std::string body;Util::ReadFile("./hello.txt", &body);req += "Content-Length: " + std::to_string(body.size()) + "\r\n\r\n";assert(cli_sock.Send(req.c_str(), req.size()) != -1);assert(cli_sock.Send(body.c_str(), body.size()) != -1);char buf[1024] = {0};assert(cli_sock.Recv(buf, 1023));DEBLOG("[%s]", buf);sleep(3);cli_sock.Close();return 0;
}

2、测试结果

https://img-blog.csdnimg.cn/direct/b3b7d45000234917bba7fba20a62397b.png" alt="在这里插入图片描述" />

八、HTTP服务器大文件传输测试

效果展示

https://img-blog.csdnimg.cn/direct/f68aafc2f0b6459c90f7395d6bd832be.png" alt="在这里插入图片描述" />
https://img-blog.csdnimg.cn/direct/75142828b9de49ab93668915b1ceec4c.png" alt="在这里插入图片描述" />


http://www.ppmy.cn/devtools/24170.html

相关文章

Java面试题：解释垃圾回收中的标记-清除、复制、标记-压缩算法的工作原理

Java面试题：解释垃圾回收中的标记-清除、复制、标记-压缩算法的工作原理

垃圾回收&#xff08;Garbage Collection, GC&#xff09;是自动内存管理的关键部分&#xff0c;它负责识别并清除程序中不再使用的对象&#xff0c;从而避免内存泄漏和浪费。以下是垃圾回收中常见的几种算法的工作原理&#xff1a; 标记-清除&#xff08;Mark-Sweep&#xff…
阅读更多...
纯血鸿蒙APP实战开发——Navigation实现多设备适配案例

纯血鸿蒙APP实战开发——Navigation实现多设备适配案例

介绍 在应用开发时&#xff0c;一个应用需要适配多终端的设备&#xff0c;使用Navigation的mode属性来实现一套代码&#xff0c;多终端适配。 效果图预览 使用说明 将程序运行在折叠屏手机或者平板上观看适配效果。 实现思路 本例涉及的关键特性和实现方案如下&#xff1a…
阅读更多...
MySql 查询优化

MySql 查询优化

MySQL查询优化涉及多个方面&#xff0c;包括索引优化、查询优化、服务器配置优化等。以下是一些基本的查询优化技巧&#xff1a; 1.使用索引 确保你的查询利用了适当的索引。 SELECT * FROM table_name WHERE column_name value; 2.避免SELECT * 只选择需要的列&#xff…
阅读更多...
什么是RabbitMQ，RabbitMQ基本概念，RabbitMQ的使用场景

什么是RabbitMQ，RabbitMQ基本概念，RabbitMQ的使用场景

目录 面试官：什么是RabbitMQ，RabbitMQ的使用场景什么是RabbitMQ？RabbitMQ基本概念RabbitMQ的使用场景举例该文章专注于面试，面试只要回答关键点即可，不需要对框架有非常深入的回答，如果你想应付面试，是足够了，抓住关键点 面试官：什么是RabbitMQ，RabbitMQ的使用场景 …
阅读更多...
【文件上传与包含漏洞综合利用】DVWA-文件上传-难度：High

【文件上传与包含漏洞综合利用】DVWA-文件上传-难度：High

实验过程和结果 步骤1&#xff1a;尝试直接上传php木马&#xff0c;失败&#xff0c;截图如下&#xff1a; 步骤2&#xff1a;将php木马后缀改为jpeg尝试上传&#xff0c;依旧失败&#xff0c;截图如下&#xff1a; 步骤3&#xff1a;将真实的jpeg图片1.jpeg上传&#xff0c;成…
阅读更多...
CentOS命令大全

CentOS命令大全

系统信息查询命令 在CentOS系统中&#xff0c;了解如何查询系统信息对于系统管理和性能监控至关重要。以下是一些基本而强大的命令&#xff0c;用于获取关于您的系统的各种信息。 1. uname - 获取系统信息 uname命令用于打印系统信息&#xff0c;例如内核版本、主机名等。使…
阅读更多...
使用riscv-tests进行指令测试（二）

使用riscv-tests进行指令测试（二）

使用riscv-tests进行指令测试&#xff08;二&#xff09; 1 测试用例命名规则2 测试用例dump文件介绍 本文属于《 TinyEMU模拟器基础系列教程》之一&#xff0c;欢迎查看其它文章。 1 测试用例命名规则 用例名称 TVM Name “-” Target Environment Name “-” “指令”…
阅读更多...
react怎么做到点击传参

react怎么做到点击传参

在React中&#xff0c;点击事件传参通常涉及到在事件处理函数中访问和使用传递的参数。有几种不同的方法可以实现点击传参&#xff0c;这里列出两种常见的方式&#xff1a; 1. 直接在事件处理函数中接收参数 你可以直接在事件处理函数中接收参数&#xff0c;并在调用事件处理…
阅读更多...
最新文章

Copyright @ 2022~2023