【项目】仿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内部的代码
网页界面如下
(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服务器大文件传输测试
效果展示