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

【项目】仿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.mfbz.cn/a/583840.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

《HelloGitHub》第 97 期

兴趣是最好的老师&#xff0c;HelloGitHub 让你对编程感兴趣&#xff01; 简介 HelloGitHub 分享 GitHub 上有趣、入门级的开源项目。 github.com/521xueweihan/HelloGitHub 这里有实战项目、入门教程、黑科技、开源书籍、大厂开源项目等&#xff0c;涵盖多种编程语言 Python、…

win下vscode的vim切换模式的中英文切换

问题描述 在vscode中安装vim插件后&#xff0c;如果insert模式下完成输入后&#xff0c;在中文输入方式下按esc会发生无效输入&#xff0c;需要手动切换到英文。 解决方法 下载完成vscode并在其中配置vim插件下载github—im-select.exe插件&#xff08;注意很多博文中的gitcod…

Microsoft Threat Modeling Tool 使用(二)

主界面 翻译 详细描述 选择了 “SDL TM Knowledge Base (Core)” 模板并打开了一个新的威胁模型。这个界面主要用于绘制数据流图&#xff08;Data Flow Diagram, DFD&#xff09;&#xff0c;它帮助您可视化系统的组成部分和它们之间的交互。以下是界面中各个部分的功能介绍&a…

软件设计师-重点的行为型设计模式

一、命令模式&#xff08;Command&#xff09;&#xff1a; 意图&#xff1a;&#xff08;上午题&#xff09; 将一个请求封装为一个对象&#xff0c;从而使得可以用不同的请求对客户进行参数化&#xff1b;对请求排队或记录请求日志&#xff0c;以及支持可撤销的操作。 结构…

Django-基础篇

Django是一个开放源代码的Web应用框架&#xff0c;由Python语言编写。它遵循MVC&#xff08;Model-View-Controller&#xff09;的软件设计模式&#xff0c;使开发者能够以高效、可扩展和安全的方式构建Web应用程序。 Django具有以下特点和优势&#xff1a; 强大的功能&#x…

[技术小技巧] 可视化分析:在jupyter中使用d3可视化树形结构

首先在python中定义一个字符串&#xff0c;记录d3.js绘制属性图的js脚本代码模版。其中{{data}}就是将来要被替换的内容。 d3_code_template """ // 创建树状结构数据 var treeData {{data}};// 创建d3树布局 var margin { top: 20, right: 90, bottom: 30,…

行业推荐:数据防泄漏软件首先解决方案

随着信息时代的快速发展&#xff0c;数据安全已成为企业经营的关键之一。然而&#xff0c;数据泄漏事件时有发生&#xff0c;不仅可能导致巨大的经济损失&#xff0c;更会损害企业的声誉和客户信任。 为了帮助企业有效地保护数据安全&#xff0c;Ping32 数据防泄漏系统应运而生…

【跟我学RISC-V】认识RISC-V指令集并搭建实验环境

写在前面 现在计算机的体系架构正是发展得如火如荼的时候&#xff0c;占领桌面端市场的x86架构、占领移动端市场的arm架构、在服务器市场仍有一定地位的mips架构、国产自研的指令集loongarch架构、还有我现在要讲到的新型开源开放的RISC-V指令集架构。 我先说一说我的学习经历…

Facebook的语言学:社交媒体如何影响我们的沟通方式

1. 引言 社交媒体已经成为人们日常生活中不可或缺的一部分&#xff0c;而Facebook作为其中最具影响力的平台之一&#xff0c;不仅改变了人们之间的社交方式&#xff0c;也对我们的语言学产生了深远的影响。本文将深入探讨Facebook的语言学特点&#xff0c;以及它如何塑造和改变…

【C++题解】1608. 三位数运算

问题&#xff1a;1608. 三位数运算 类型&#xff1a;基本运算、拆位求解 题目描述&#xff1a; 小丽在编程课上学会了拆位运算&#xff0c;她已经可以拆出一个三位整数的百位、十位和个位了&#xff0c;她想知道这个整数的&#xff08;百位 十位&#xff09; / &#xff08;…

Web3与智能合约:科技革新下的新金融时代

在当今数字化时代&#xff0c;Web3和智能合约正在共同塑造着金融领域的未来。Web3作为下一代互联网的重要组成部分&#xff0c;以其去中心化、安全性和透明性为核心特点&#xff0c;正推动着金融行业向着数字化和去中心化的方向发展。而智能合约作为Web3技术的关键应用之一&…

虚拟机网络桥接模式无法通信,获取到的ip为169.254.X.X

原因&#xff1a;VMware自动选择的网卡可能不对 解决&#xff1a;编辑-虚拟网络编辑器-更改桥接模式-选择宿主机物理网卡&#xff0c;断开虚拟机网络连接后重新连接即可

Docker(Docker的安装和介绍,常用命令,镜像制作,服务编排,docker私服)

目录 一、简介 1. docker简介 1 什么是docker 2 容器和虚拟机对比 2. 安装docker 1 docker相关概念 2 安装docker 1 安装docker 2 设置注册中心(仓库) 3. 小结 二、常用命令【重点】 1. 服务管理 2. 镜像管理 1 语法说明 2 使用练习 3. 容器管理 1 容器介绍 2…

2024.4.25 LoadRunner 测试工具详解 —— Controller Analysis

目录 Controller 的使用 创建场景 Controller 快捷方式创建场景 VUG 针对写好脚本创建场景 场景设计 设计初始化 设计启动机制 设计性能测试脚本的执行时间 设计虚拟用户退出机制 场景运行 添加监控指标至图标格区域 Analysis 的使用 汇总报告 测试报表 吞吐量图 …

Dockerfile实战---构建SSH、Tomcat、MySQL、Nginx镜像

目录 引言 一、安装docker程序 二、构建SSH镜像 1.创建镜像 2.基于sshd镜像创建容器 三、构建tomcat镜像 1.创建镜像 2.基于tomcat镜像创建容器 四、构建MySQL镜像 1.创建镜像 2.基于mysqld镜像创建容器 五、构建nginx镜像 1.创建镜像 2.基于nginx镜像创建容器 引…

用Stream流方式合并两个list集合(部分对象属性重合)

一、合并出共有部分 package com.xu.demo.test;import java.util.Arrays; import java.util.List; import java.util.stream.Collectors;public class ListMergeTest1 {public static void main(String[] args) {List<User> list1 Arrays.asList(new User(1, "Alic…

Linux学习之Tcp与Udp

目录 UDP Udp协议的格式 UDP的传输特性 UDP的缓冲区 基于UDP的应用层协议 TCP协议 TCP的报文格式 1.ACK确认应答机制 2.超时重传 3.TCP的链接管理机制 为什么要三次握手呢&#xff1f; 理解TIME_WAIT状态 流量控制&#xff08;可靠性效率&#xff09; 滑动窗口 拥塞…

Java8中的Stream流相关用法学习

目录 一、Stream是什么 二、创建Stream 三、中间操作 3.1 filter() 3.2 map() 3.3 flatMap() 3.4 distinct() 3.5 limit() 四、终端操作 4.1 findAny(), 和 orElse() 4.2 sorted() 4.3 forEach() 4.4 count() 4.5 collect() 4.6 groupingBy() 4.7 average() 4…

RAG-Driver: 多模态大语言模型中具有检索增强上下文学习的通用驱动解释

RAG-Driver: 多模态大语言模型中具有检索增强上下文学习的通用驱动解释 摘要Introduction RAG-Driver: Generalisable Driving Explanations with Retrieval-Augmented In-Context Learning in Multi-Modal Large Language Model. 摘要 由“黑箱”模型驱动的机器人需要提供人类…

Java对接高德api搜索POI 2.0 关键字搜索

目录 一、注册账号 二、搜索小demo 1.首先要引入依赖 2. 然后查看打印结果即可 三、搜索接口代码 1.引入依赖 2.yml配置 2.Controller 3.静态工具类 四、运行测试 一、注册账号 高德开放平台 | 高德地图API 注册高德开发者&#xff1b;去控制台创建应用&#xff…
最新文章