基于 Linux 的轻量级多线程 HTTP 服务

      使用基本的Linux系统调用来创建一个TCP socket,监听端口8080,并在接受到客户端连接时创建一个新的线程来处理连接。每个连接处理函数都是一个独立的线程,读取客户端请求并发送固定的HTTP响应。

     代码:

#include <iostream>
#include <string>
#include <cstring>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <pthread.h>const int BUFFER_SIZE = 1024;void *connection_handler(void *socket_desc) {int sock = *(int *)socket_desc;char buffer[BUFFER_SIZE];std::string response = "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\n\r\nHello, World!";// 读取客户端请求ssize_t read_size = read(sock, buffer, BUFFER_SIZE - 1);if (read_size > 0) {buffer[read_size] = '\0';std::cout << "Received request:\n" << buffer << std::endl;// 发送响应write(sock, response.c_str(), response.length());}// 关闭连接close(sock);delete (int *)socket_desc;return NULL;
}int main() {int server_fd, client_sock;struct sockaddr_in server_addr, client_addr;socklen_t addr_len = sizeof(struct sockaddr_in);// 创建 socketserver_fd = socket(AF_INET, SOCK_STREAM, 0);if (server_fd == -1) {std::cerr << "Failed to create socket." << std::endl;return 1;}// 设置服务器地址和端口server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = INADDR_ANY;server_addr.sin_port = htons(8080);// 绑定地址和端口if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {std::cerr << "Failed to bind." << std::endl;return 1;}// 监听连接if (listen(server_fd, 10) < 0) {std::cerr << "Failed to listen." << std::endl;return 1;}std::cout << "Server started. Listening on port 8080..." << std::endl;while (true) {// 接受客户端连接client_sock = accept(server_fd, (struct sockaddr *)&client_addr, &addr_len);if (client_sock < 0) {std::cerr << "Failed to accept connection." << std::endl;continue;}std::cout << "New connection accepted." << std::endl;// 创建线程处理连接pthread_t thread;int *new_sock = new int;*new_sock = client_sock;if (pthread_create(&thread, NULL, connection_handler, (void *)new_sock) < 0) {std::cerr << "Failed to create thread." << std::endl;return 1;}// 分离线程,使其自行释放资源pthread_detach(thread);}// 关闭服务器 socketclose(server_fd);return 0;
}

代码解析:

这段代码实现了一个简单的基于Linux的轻量级多线程HTTP服务。它的主要逻辑如下:

  1. 引入所需的头文件和库:包括iostream(用于输入输出)、string(用于处理字符串)、cstring(用于字符串操作)、sys/socket.h和arpa/inet.h(用于socket编程)、unistd.h(用于关闭连接)和pthread.h(用于多线程编程)。

  2. 定义常量和变量:将缓冲区大小定义为BUFFER_SIZE,并声明服务器socket文件描述符(server_fd)和客户端socket文件描述符(client_sock),以及服务器地址(server_addr)和客户端地址(client_addr)。

  3. 创建连接处理函数:定义了一个名为connection_handler的函数,该函数作为每个连接的处理函数。它接受一个void*类型的参数,将其转换为int*类型,表示客户端socket文件描述符。在该函数中,首先从客户端读取请求并打印到控制台,然后向客户端发送固定的HTTP响应。最后关闭客户端socket连接,并释放分配的内存。

  4. 主函数:在主函数中,首先创建服务器socket(server_fd)。然后设置服务器地址和端口,并将其与socket绑定。接下来,开始监听连接请求。在一个无限循环中,使用accept函数接受客户端连接,并创建一个新的线程来处理连接。为了能够将客户端socket传递给新线程,使用new运算符动态分配了一个int类型的指针new_sock,并将客户端socket文件描述符赋值给它。然后,使用pthread_create函数创建一个新的线程,将新线程的执行函数设置为connection_handler,并将new_sock作为参数传递给新线程。最后,使用pthread_detach函数将新线程设置为分离状态,使其在完成后自动释放资源。

  5. 关闭服务器socket:在无限循环中无法达到的代码,当服务端结束时,关闭服务器socket(server_fd)。

这段代码使用了基本的Linux系统调用和pthread库来实现一个简单的多线程HTTP服务。它接受客户端连接,并为每个连接创建一个独立的线程来处理请求和发送响应。需要注意的是,这只是一个简化的示例,实际的HTTP服务器需要考虑更多的功能和错误处理,例如处理HTTP请求的各种方法、路径解析、错误处理等。

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

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

相关文章

简笔风和写实风的区别

现实主义和风格化 当我们谈论现实主义和风格化时&#xff0c;我们是什么意思&#xff1f;这看起来相当明显&#xff0c;现实主义指的是模仿逼真的逼真的图形。它不一定需要存在于现实世界中&#xff0c;但被传达为它属于我们的世界。10年前&#xff0c;我们认为现实的东西在今…

尝试-InsCode Stable Diffusion 美图活动一期

一、 Stable Diffusion 模型在线使用地址&#xff1a; https://inscode.csdn.net/inscode/Stable-Diffusion 二、模型相关版本和参数配置&#xff1a; 活动地址 三、图片生成提示词与反向提示词&#xff1a; 提示词&#xff1a;realistic portrait painting of a japanese…

Effective C++学习笔记(6)

目录 条款32. 确定你的public继承塑模出is-a关系条款33.避免遮掩继承而来的名称条款34.区分接口继承和实现继承条款35.考虑virtual函数以外的其他选择条款36.绝不重新定义继承而来的non-virtual函数条款37.绝不重新定义继承而来的缺省参数值条款38.通过复合塑模出has-a或“根据…

spring-boot-starter-parent 与 spring-boot-dependencies

Spring Boot的每个发布版本都会规划它所支持的依赖项。实际上&#xff0c;你不用指定这些依赖项的版本号&#xff0c;因为Spring Boot都为你管理好了。当更新Spring Boot时&#xff0c;会相应的更新依赖。 Maven管理依赖 Maven用户可以继承spring-boot-starter-parent项目&am…

OpenMP并行化傅里叶变换

设计思想 傅里叶变换&#xff0c;表示能将满足一定条件的某个函数表示成三角函数&#xff08;正弦和/或余弦函数&#xff09;或者它们的积分的线性组合。在不同的研究领域&#xff0c;傅里叶变换具有多种不同的变体形式&#xff0c;如连续傅里叶变换和离散傅里叶变换。 快速傅…

windows各种文件操作、系统相关的命令行脚本

目录 写在前面文件操作命令说明遍历文件并写进txt按行读取txt并文件计数文件重命名 参考完 写在前面 1、本文内容 windows各种文件操作、系统相关的命令行脚本 请保存为.bat运行 2、平台 windows10 3、转载请注明出处&#xff1a; https://blog.csdn.net/qq_41102371/article/…

《零基础入门学习Python》第047讲:魔法方法:定制序列

0. 请写下这一节课你学习到的内容&#xff1a;格式不限&#xff0c;回忆并复述是加强记忆的好方式&#xff01; 常言道&#xff1a;“无规矩不成方圆”&#xff0c;讲的是万事万物的发展都要在一定的规则下去运行&#xff0c;只有遵循一定的协议去做&#xff0c;事情才能够按照…

如何将一个目录下的所有md文件导出成pdf

要将一个目录下的所有Markdown&#xff08;.md&#xff09;文件导出为PDF&#xff0c;您可以使用Node.js进行编程来实现。以下是一种可能的方法&#xff1a; 首先&#xff0c;您需要设置Node.js环境并安装依赖项。在命令行中导航到您的项目目录&#xff0c;并运行以下命令&…

前端js防抖

一、原生js防抖 <!DOCTYPE html> <html> <head><title>防抖按钮示例</title> </head> <body><button id"immediateButton">立即触发</button><button id"waitButton">等候触发</button&g…

Stream实现List和Map互转总结

本文来说下Stream实现List和Map互转总结 文章目录 实体类Map转List代码List转Map代码 实体类 本篇介绍Stream流List和Map互转&#xff0c;同时在转换过程中遇到的问题分析。 package cn.wideth.collect;import lombok.AllArgsConstructor; import lombok.Data; import lombok.N…

GAMES101作业2

文章目录 作业内容Step 1. 创建三角形的2维bounding boxStep 2. 判断bBox中的像素中心点是否在三角形内Step 3. 比较插值深度和Depth BufferMSAA 作业内容 在屏幕上画出一个实心三角形&#xff0c; 换言之&#xff0c;栅格化一个三角形。上一次作业中&#xff0c;在视口变化之…

二次元少女-InsCode Stable Diffusion 美图活动一期

一、 Stable Diffusion 模型在线使用地址&#xff1a; https://inscode.csdn.net/inscode/Stable-Diffusion 二、模型相关版本和参数配置&#xff1a; 模型版本&#xff1a;chilloutmix_NiPrunedFp32Fix.safetensors 采样方法(Sampler)Sampling method&#xff1a;DPM SDE …

2023年经典【自动化面试题】附答案

一、请描述一下自动化测试流程&#xff1f; 自动化测试流程一般可以分为以下七步&#xff1a; 编写自动化测试计划&#xff1b; 设计自动化测试用例&#xff1b; 编写自动化测试框架和脚本&#xff1b; 调试并维护脚本&#xff1b; 无人值守测试&#xff1b; 后期脚本维…

C#如何控制IIS动态添加删除网站详解

目的是在Winform程序里面&#xff0c;可以直接启动一个HTTP服务端&#xff0c;给下游客户连接使用。 查找相关技术&#xff0c;有两种方法&#xff1a; 1.使用C#动态添加网站应用到IIS中&#xff0c;借用IIS的站群软件管理能力来提供HTTP接口。本文即对此做说明 2.在Winform…

【UE4 塔防游戏系列】07-子弹对敌人造成伤害

目录 效果 步骤 一、让子弹拥有不同伤害 二、敌人拥有不同血量 三、修改“BP_TowerBase”逻辑 四、发射的子弹对敌人造成伤害 效果 步骤 一、让子弹拥有不同伤害 为了让每一种子弹拥有不同的伤害值&#xff0c;打开“TotalBulletsCategory”&#xff08;所有子弹的父类…

【Spring Boot】Web开发 — Web开发简介

Web开发简介 首先介绍Spring Boot 提供的Web组件spring-boot-starter-web&#xff0c;然后介绍Controller和RestController注解&#xff0c;以及控制数据返回的ResponseBody注解&#xff0c;最后介绍Web配置&#xff0c;以便让读者对使用Spring Boot开发Web系统有初步的了解。…

linux下一个iic驱动(按键+点灯)-互斥

一、前提&#xff1a; 硬件部分&#xff1a; 1. rk3399开发板&#xff0c;其中的某一路iic&#xff0c;这个作为总线的主控制器 2. gd32单片机&#xff0c;其中的某一路iic&#xff0c;从设备。主要是按键上报和灯的亮灭控制。&#xff08;按键大约30个&#xff0c;灯在键的…

送呆萌的她一个皮卡丘(Python实现)

目录 1 呆萌的她 2 思维需要革新 3 送她的一个漂亮皮卡丘 4 Python完整代码奉上 1 呆萌的她 又是一季春风暖阳下, 你是一湾一湾羞涩的春波。 静静感受着&#xff0c; 你垂下的枝膊 在我的脸上轻轻抚摸 一对春燕,低低掠过 涟漪乍起&#xff0c;是你浅浅的笑窝...... 2 思…

(五)「消息队列」之 RabbitMQ 主题(使用 .NET 客户端)

0、引言 先决条件 本教程假设 RabbitMQ 已安装并且正在 本地主机 的标准端口&#xff08;5672&#xff09;上运行。如果您使用了不同的主机、端口或凭证&#xff0c;则要求调整连接设置。 获取帮助 如果您在阅读本教程时遇到问题&#xff0c;可以通过邮件列表或者 RabbitMQ 社区…

56 # 实现 pipe 方法进行拷贝

pipe 是异步的&#xff0c;可以实现读一点写一点&#xff0c;管道的优势&#xff1a;不会淹没可用内存&#xff0c;但是在导入的过程中无法获取到内容 const fs require("fs"); const path require("path");fs.createReadStream(path.resolve(__dirname…