阅读量:0
【项目】仿muduo库One Thread One Loop式主从Reactor模型实现高并发服务器（Http测试板块）
- 一、使用Http网页界面
- 二、长连接的测试一
- 三、长连接的测试二
- 四、错误请求测试
- 五、HTTP服务器业务处理超时测试
- 六、HTTP服务器同时多条请求测试
- 七、HTTP服务器大文件传输测试
- 八、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内部的代码
网页界面如下
（2）测试结果2：用hello
网页界面如下：
（3）测试结果3：用login
网页界面如下：
按一下提交：
（4）测试结果4:hello?username=jrh&password=123456
网页界面如下：
二、长连接的测试一
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.cc g++ -o $@ $^ -std=c++11 -lpthread server:server.cc g++ -o $@ $^ -std=c++11 -lpthread Client:tcp_cli.cc g++ -o $@ $^ -std=c++11 -lpthread Server:tcp_svr.cc g++ -o $@ $^ -std=c++11 -lpthread .PHONY:clean clean: rm -f Client Server server 2、测试结果（错误结果）
（1）不是长连接，查看错误原因
（2）通过Close看是否进入
我们此时通过HttpServer中的Close函数进行打印看一下有没有进去！
（3）Request中的Close函数打印调试
我们此时直接去request中的Close中进行日志打印一下：
发现，有头部这个Connection，但是进行相当的时候是错误的，我们看上面的[keep-alive]但是上面打印的完全不是这样的，所以我们接下来需要去HttpContext中进行修改，我们直接在后面加上末尾去掉换行字符和回车字符！
（4）去掉尾部\n
（5）去掉空格尝试1
能好一点，但是还是不对，我起初的思路在于把前面一个空格给去掉，所以在前面用了substr/erase，我们先看一下结果吧：
发现什么都没有了，我的天，我理解了一遍代码发现它是从后面才开始拼接上去的，所以我们需要在后面进行理解，发现此时value需要到+2这个位置往后拼接才可，因为刚好+2是跳过一个空格了，我们看一下是不是了：
（6）去掉空格尝试2（成功）
成功！通过这次调试，发现理清代码逻辑和进行日志打印是很重要的！
三、长连接的测试二
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.cc g++ -o $@ $^ -std=c++11 -lpthread client1:client1.cc g++ -o $@ $^ -std=c++11 -lpthread server:server.cc g++ -o $@ $^ -std=c++11 -lpthread Client:tcp_cli.cc g++ -o $@ $^ -std=c++11 -lpthread Server:tcp_svr.cc g++ -o $@ $^ -std=c++11 -lpthread .PHONY:clean clean: rm -f Client Server server 2、测试结果
四、错误请求测试
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.cc g++ -o $@ $^ -std=c++11 -lpthread client2:client2.cc g++ -o $@ $^ -std=c++11 -lpthread client1:client1.cc g++ -o $@ $^ -std=c++11 -lpthread server:server.cc g++ -o $@ $^ -std=c++11 -lpthread Client:tcp_cli.cc g++ -o $@ $^ -std=c++11 -lpthread Server:tcp_svr.cc g++ -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
我们的解决方法为：发现OnMessage的回调函数出问题了！
当我们的请求数据很多的情况下，程序不退出，那么我们的OVER没有使用，所以我们加入我们注释的那几行代码：
是预期结果！
（2）运行结果2
五、HTTP服务器业务处理超时测试
1、代码部分修改
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、测试结果
六、HTTP服务器同时多条请求测试
1、代码部分
// 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、运行结果
七、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、测试结果
八、HTTP服务器大文件传输测试
效果展示
