高并发服务器

2024/4/12 22:44:22
高并发服务器之泄峰

高并发服务器之泄峰

文章目录 背景前言解决方案泄峰 泄峰结果总结代码示例 背景 行业： 车联网机器配置：阿里云服务 8核 16G内存 3M带宽 阿里云操作系统单台server接入设备：5w终端产品：GPS定位设备终端与平台通信方式：TCP长链 前言 近期…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）主线程给子线程添加任务以及如何处理该任务

基于多反应堆的高并发服务器【C/C++/Reactor】（中）主线程给子线程添加任务以及如何处理该任务

在看此篇文章，建议先看我的往期文章： 基于多反应堆的高并发服务器【C/C/Reactor】（中）在EventLoop的任务队列中添加新任务-CSDN博客https://blog.csdn.net/weixin_41987016/article/details/135346492?spm1001.2014.3001.5501一…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）线程池的启动和从线程池中取出一个反应堆实例

基于多反应堆的高并发服务器【C/C++/Reactor】（中）线程池的启动和从线程池中取出一个反应堆实例

一、线程池的启动 // 启动线程池 void threadPoolRun(struct ThreadPool* pool) {assert(pool && !pool->isStart);if(pool->mainLoop->threadID ! pthread_self()) {exit(0);}pool->isStart true;if(pool->threadNum) {for(int i0;i<pool->th…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）子线程 WorkerThread的实现 和 线程池ThreadPool的初始化

基于多反应堆的高并发服务器【C/C++/Reactor】（中）子线程 WorkerThread的实现 和 线程池ThreadPool的初始化

一、子线程 WorkerThread的实现 &#xff08;1&#xff09;工作线程 线程ID&#xff1a;每个线程都有一个唯一的ID,用于标识线程的名字&#xff1a;非必需&#xff0c;主要用于识别线程互斥锁&#xff1a;线程同步条件变量&#xff1a;线程阻塞EventLoop&#xff1a;在每个子…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）HttpRequest模块 解析http请求协议

基于多反应堆的高并发服务器【C/C++/Reactor】（中）HttpRequest模块 解析http请求协议

一、HTTP响应报文格式 HTTP/1.1 200 OK Bdpagetype: 1 Bdqid: 0xf3c9743300024ee4 Cache-Control: private Connection: keep-alive Content-Encoding: gzip Content-Type: text/html;charsetutf-8 Date: Fri, 26 Feb 2021 08:44:35 GMT Expires: Fri, 26 Feb 2021 08:44:35 GM…
阅读更多...
Linux学习之网络编程3（高并发服务器）

Linux学习之网络编程3（高并发服务器）

写在前面 Linux网络编程我是看视频学的&#xff0c;Linux网络编程&#xff0c;看完这个视频大概网络编程的基础差不多就掌握了。这个系列是我看这个Linux网络编程视频写的笔记总结。 高并发服务器 问题&#xff1a; 根据上一个笔记&#xff0c;我们可以写出一个简单的服务端…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）Channel 模块的实现

基于多反应堆的高并发服务器【C/C++/Reactor】（中）Channel 模块的实现

在这篇文章中虽然实现了能够和多客户端建立连接&#xff0c;并且同时和多个客户端进行通信。 基于多反应堆的高并发服务器【C/C/Reactor】&#xff08;上&#xff09;-CSDN博客https://blog.csdn.net/weixin_41987016/article/details/135141316?spm1001.2014.3001.5501但是有…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）在EventLoop的任务队列中添加新任务

基于多反应堆的高并发服务器【C/C++/Reactor】（中）在EventLoop的任务队列中添加新任务

任务队列是一个链表&#xff0c;每个节点包含channel类型、文件描述符和操作类型。在添加节点时&#xff0c;需要考虑线程同步&#xff0c;并确保节点被正确地添加到链表中。节点的操作可以写到另一个函数中&#xff0c;以便于程序的维护。在添加任务节点时&#xff0c;需要加互…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）HttpResponse的定义和初始化 以及组织 HttpResponse 响应消息

基于多反应堆的高并发服务器【C/C++/Reactor】（中）HttpResponse的定义和初始化 以及组织 HttpResponse 响应消息

一、HttpResponse的定义 1.定义状态码枚举 // 定义状态码枚举 enum HttpStatusCode {Unknown 0,OK 200,MovedPermanently 301,MovedTemporarily 302,BadRequest 400,NotFound 404 }; 2.HTTP 响应报文格式 这个数据块主要是分为四部分 第一部分是状态行第二部分是响应…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）在TcpConnection 中接收并解析Http请求消息

基于多反应堆的高并发服务器【C/C++/Reactor】（中）在TcpConnection 中接收并解析Http请求消息

一、在TcpConnection 中多添加和http协议相关的request和response struct TcpConnection {struct EventLoop* evLoop;struct Channel* channel;struct Buffer* readBuf;struct Buffer* writeBuf;char name[32];// http协议struct HttpRequest* request;struct HttpResponse* r…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）创建一个TcpConnection实例 以及 接收客户端数据

基于多反应堆的高并发服务器【C/C++/Reactor】（中）创建一个TcpConnection实例 以及 接收客户端数据

#CSDN 年度征文&#xff5c;回顾 2023&#xff0c;赢专属铭牌等定制奖品# 一、主线程反应堆模型的事件添加和处理详解 >>服务器和客户端建立连接和通信流程&#xff1a; 基于多反应堆模型的服务器结构图&#xff0c;这主要是一个TcpServer&#xff0c;关于HttpServer,…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）Buffer的创建和销毁、扩容、写入数据

基于多反应堆的高并发服务器【C/C++/Reactor】（中）Buffer的创建和销毁、扩容、写入数据

TcpConnection:封装的就是建立连接之后得到的用于通信的文件描述符&#xff0c;然后基于这个文件描述符&#xff0c;在发送数据的时候&#xff0c;需要把数据先写入到一块内存里边&#xff0c;然后再把这块内存里边的数据发送给客户端&#xff0c;除了发送数据&#xff0c;剩下…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）HttpRequest 提取请求行、解析请求行和优化 以及解析请求头并存储

基于多反应堆的高并发服务器【C/C++/Reactor】（中）HttpRequest 提取请求行、解析请求行和优化 以及解析请求头并存储

### 知识点1&#xff1a;读取网络数据 客户端发送给服务器的通信数据通过封装的bufferSocketRead函数读取读取的数据存储在struct Buffer结构体实例中&#xff0c;可将该实例作为参数传递给解析函数 回顾Buffer.c中的bufferSocketRead函数 // 写内存 2.接收套接字数据 int b…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）创建并初始化TcpServer实例 以及 启动

基于多反应堆的高并发服务器【C/C++/Reactor】（中）创建并初始化TcpServer实例 以及 启动

对于一个TcpServer来说&#xff0c;它的灵魂是什么&#xff1f;就是需要提供一个事件循环EventLop(EventLoop)&#xff0c;不停地去检测有没有客户端的连接到达&#xff0c;有没有客户端给服务器发送数据&#xff0c;描述的这些动作&#xff0c;反应堆模型能够胜任。当服务器和…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）在EventLoop中处理被激活的文件描述符的事件

基于多反应堆的高并发服务器【C/C++/Reactor】（中）在EventLoop中处理被激活的文件描述符的事件

文件描述符处理与回调函数 一、主要概念 反应堆模型&#xff1a;一种处理系统事件或网络事件的模型&#xff0c;当文件描述符被激活时&#xff0c;可以检测到文件描述符&#xff1a;在操作系统中&#xff0c;用于标识打开的文件、套接字等的一种数据类型 处理激活的文件描述符…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）ChannelMap 模块的实现

基于多反应堆的高并发服务器【C/C++/Reactor】（中）ChannelMap 模块的实现

&#xff08;三&#xff09;ChannelMap 模块的实现 这个模块其实就是为Channel来服务的&#xff0c;前面讲了Channel这个结构体里边它封装了文件描述符。假如说我们得到了某一个文件描述符&#xff0c;需要基于这个文件描述符进行它对应的事件处理&#xff0c;那怎么办呢&…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）完整代码

基于多反应堆的高并发服务器【C/C++/Reactor】（中）完整代码

Buffer.h #pragma oncestruct Buffer {// 指向内存的指针char* data;int capacity;int readPos;int writePos; };// 初始化 struct Buffer* bufferInit(int size);// 销毁 void bufferDestroy(struct Buffer* buf);// 扩容 void bufferExtendRoom(struct Buffer* buf, int siz…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）添加 删除 修改 释放

基于多反应堆的高并发服务器【C/C++/Reactor】（中）添加 删除 修改 释放

在上篇文章&#xff08;处理任务队列中的任务&#xff09;中我们讲解了处理任务队列中的任务的具体流程&#xff0c;eventLoopProcessTask函数的作用&#xff1a; 处理队列中的任务&#xff0c;需要遍历链表并根据type进行对应处理,也就是处理dispatcher中的任务。 // 处理任…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）处理任务队列中的任务

基于多反应堆的高并发服务器【C/C++/Reactor】（中）处理任务队列中的任务

一、处理任务队列中的任务 &#xff08;1&#xff09;EventLoop启动 EventLoop初始化和启动 // 启动反应堆模型 int eventLoopRun(struct EventLoop* evLoop) {assert(evLoop ! NULL);// 取出事件分发和检测模型struct Dispatcher* dispatcher evLoop->dispatcher;// 比较…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）创建并初始化TcpServer实例

基于多反应堆的高并发服务器【C/C++/Reactor】（中）创建并初始化TcpServer实例

对于一个TcpServer来说&#xff0c;它的灵魂是什么&#xff1f;就是需要提供一个事件循环EventLop(EventLoop)&#xff0c;不停地去检测有没有客户端的连接到达&#xff0c;有没有客户端给服务器发送数据&#xff0c;描述的这些动作&#xff0c;反应堆模型能够胜任。当服务器和…
阅读更多...
基于多反应堆的高并发服务器【C/C++/Reactor】（中）EventLoop初始化

基于多反应堆的高并发服务器【C/C++/Reactor】（中）EventLoop初始化

这个Dispatcher是一个事件分发模型&#xff0c;通过这个模型,就能够检测对应的文件描述符的事件的时候,可以使用epoll/poll/select,前面说过三选一。另外不管是哪一个底层的检测模型,它们都需要使用一个数据块,这个数据块就叫做DispatcherData。除此之外,还有另外一个部分,因为…
阅读更多...

Copyright @ 2022~2023