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

news2024/12/23 13:48:14

【项目】仿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服务器大文件传输测试

效果展示

在这里插入图片描述
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1633682.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

JSON.toJSONString() 输出 “$ref“:“$[0]“问题解决及原因分析

一、背景 在构建一个公共的批处理方法类的时候&#xff0c;在测试输出的时候&#xff0c;打印了" r e f " : " ref":" ref":"[0][0]"的内容&#xff0c;这让我比较疑惑。不由得继续了下去… 二、问题分析 首先&#xff0c;我们需要…

MySQL Binlog 闪回与分析

文章目录 前言1. 修改 event 实现闪回1.1 binlog 结构1.2 闪回案例1.3 方法总结 2. 解析文本闪回2.1 mysqlbinlog2.2 闪回案例2.3 方法总结 3. 在线订阅闪回3.1 mysql-replication3.2 binlog2sql3.3 方法总结 4. Binlog 分析方法4.1 分析场景4.2 辅助定位事务4.3 方法总结 5. 平…

性能监控之prometheus+grafana搭建

前言 Prometheus和Grafana是两个流行的开源工具&#xff0c;用于监控和可视化系统和应用程序的性能指标。它们通常一起使用&#xff0c;提供了强大的监控和数据可视化功能。 Prometheus Prometheus是一种开源的系统监控和警报工具包。它最初由SoundCloud开发&#xff0c;并于…

基于SSM+Jsp+Mysql的汽车租赁系统的设计与实现

开发语言&#xff1a;Java框架&#xff1a;ssm技术&#xff1a;JSPJDK版本&#xff1a;JDK1.8服务器&#xff1a;tomcat7数据库&#xff1a;mysql 5.7&#xff08;一定要5.7版本&#xff09;数据库工具&#xff1a;Navicat11开发软件&#xff1a;eclipse/myeclipse/ideaMaven包…

Python爬虫(入门版)

1、爬虫是什么 简单的来说&#xff1a;就是用程序获取网络上数据。 2、爬虫的原理 如果要获取网络上数据&#xff0c;我们要给爬虫一个网址&#xff08;程序中通常叫URL&#xff09;&#xff0c;爬虫发送一个HTTP请求给目标网页的服务器&#xff0c;服务器返回数据给客户端&am…

Linux详解:进程等待

文章目录 进程等待等待的必要性进程等待的方法waitwaitpid获取子进程status阻塞等待 与 非阻塞等待 进程等待 等待的必要性 子进程退出&#xff0c;父进程不进行回收的话&#xff0c;就可能造成僵尸进程&#xff0c;进而造成内存泄露 如果进程进入了僵尸状态&#xff0c;kill…

宝塔面板安装教程(linux)

宝塔官网地址 宝塔官网linux安装地址 针对Ubuntu系统的安装命令&#xff1a; wget -O install.sh https://download.bt.cn/install/install-ubuntu_6.0.sh && sudo bash install.sh ed8484bec 安装过程中&#xff0c;中途会出现一个 Y&N ? 的选项&#xf…

李沐62_序列到序列学习seq2seq——自学笔记

"英&#xff0d;法”数据集来训练这个机器翻译模型。 !pip install --upgrade d2l0.17.5 #d2l需要更新import collections import math import torch from torch import nn from d2l import torch as d2l循环神经网络编码器。 我们使用了嵌入层&#xff08;embedding l…

【笔记1】从零开始做一个男头的流程(超级详细)

目录 大体 眼窝 鼻子 脖子 耳朵 嘴巴1 颧骨 嘴巴2 眼睛 头 开始细化 大体 眼窝 嘴巴 鼻子 大体 注意&#xff01;&#xff01;先整体后局部&#xff0c;一开始不要加太多的线&#xff0c;尽量先用最少的线调整出一个大体的结构。 1.准备好参考图&#xff0c;在…

2024年的Java版本选择?java 17 安装

文章目录 2024年的Java版本选择&#xff1f;java 1.8 和 java17 什么区别&#xff1f;java 17 安装windows 11安装java 17C:\Program Files\Common Files\Oracle\Java\javapath是什么 2024年的Java版本选择&#xff1f; 3年前&#xff0c;java 1.8是市场主流&#xff08;还有一…

Acrobat Pro DC 2023:专业PDF编辑软件,引领高效办公新时代

Acrobat Pro DC 2023是一款专为Mac和Windows用户设计的专业PDF编辑软件&#xff0c;凭借其强大的功能和卓越的性能&#xff0c;成为现代职场人士不可或缺的得力助手。 这款软件拥有出色的PDF编辑能力。用户不仅可以轻松地对PDF文档中的文字、图片和布局进行编辑和调整&#xf…

PyAudio安装!!解决使用pip install PyAudio安装报错问题

如果使用pip install PyAudio安装报错 一般建议选择本地安装 但是本人也是从网上找了很多资料&#xff0c;发现本地的wheel的网址打开没有文件了 然后我就用了这个方法&#xff0c;对于我的电脑是非常有效果的&#xff01;&#xff01; 如果指令装不上的话 PyAudio PyPI …

linux中git的使用

为什么要有git git相当于一个仓库可以让我们更好的去管理我们的代码&#xff0c;实现版本的控制&#xff0c;上传到云端仓库。有了git,就可以实现多人同时开发一个项目&#xff08;每个负责一部分代码&#xff0c;最后都上传到同一个仓库&#xff09;。 git github/gitee 的区…

Burp 指纹识别+OA弱口令爆破-BurpFingerPrint

简介 攻击过程中&#xff0c;我们通常会用浏览器访问一些资产&#xff0c;该BurpSuite插件实现被动指纹识别网站提取链接OA爆破&#xff0c;可帮助我们发现更多资产。 功能如下 下述功能会在2024年5月底完成&#xff0c;如果有更好的建议都可以提&#xff0c;然后再麻烦点个…

linux磁盘原理

在linux系统中&#xff0c;对磁盘进行管理与windows系统类似&#xff0c;都要先分区&#xff0c;格式化&#xff0c;创建文件系统&#xff0c;挂载目录&#xff0c;数据写入

【Unity动画系统】Animator组件的属性

介绍Animator组件的全部属性 Controller&#xff1a;动画控制器 Avatar&#xff1a;人物骨骼 Apply Root Motion&#xff1a;有一些动画片段自带位移&#xff0c;如果希望自带的位移应用在游戏对象上&#xff0c;那么就勾选&#xff1b;如果自己编写脚本&#xff0c;那么就不…

Milvus Cloud 向量数据库Reranker成本比较和使用场景

成本比较:向量检索 v.s. Cross-encoder Reranker v.s. 大模型生成 虽然 Reranker 的使用成本远高于单纯使用向量检索的成本,但它仍然比使用 LLM 为同等数量文档生成答案的成本要低。在 RAG 架构中,Reranker 可以筛选向量搜索的初步结果,丢弃掉与查询相关性低的文档,从而有…

使用webpack给大屏自适应插件autofit.js增加umd打包方式

最近有个大屏自适应的需求&#xff0c;而且想直接通过script标签来引入自适应的插件js&#xff0c;搜索相中了autofit.js&#xff0c;可惜不支持umd格式的引入&#xff0c;虽然也能直接copy源码&#xff0c;但是还是折腾下给它打包成umd格式的代码。 fork源码&#xff0c;克隆…

第10章 项目管理基础知识

一、项目概述 &#xff08;一&#xff09;项目 在既定的项目资源要求和约束下&#xff0c;为实现特定目标而相互联系的一次性活动&#xff08;资源任务&#xff09;。世界上没有两个完全相同的项目项目有资源约束&#xff0c;一定的目的&#xff0c;是一次性。 &#xff08;…

面试官:Docker和传统虚拟机有什么区别?

我有一个程序员朋友&#xff0c;他每年情人节都要送女朋友一台服务器。 他说&#xff1a;“谁不想在过节当天收到一台 4核8g 的服务器呢&#xff1f;” “万一对方不要&#xff0c;我还能留着自己用。” 给他一次过节的机会&#xff0c;他能把浪漫玩的明明白白。 所以今年情人…