C语言实现Reactor

2024-08-22 11:44
文章标签 语言 实现 reactor

本文主要是介绍C语言实现Reactor,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

​ 在前边的C语言实现简易tcp服务器中,我们实现服务器是采用了最笨拙的方法,就是每来一个客户端,我们就创建一个线程进行连接处理。试想如果有10w个客户端来,就需要10w个线程,需要创建大量的线程,耗费大量的资源,并且为了保证线程安全,还需要考虑锁,死锁等问题,这些都需要一定的开销。因此为了解决这个问题,我们下一篇介绍了select、poll、epoll,他们三个是常用的I/O多路复用机制。解决了创建大量的线程的问题。用一个线程就可以去处理多个客户端连接的问题。那么问题来了,性能是否还能继续优化?之前我们用epoll来实现服务器是对i/o进行操作,我们可以使用Reactor模式封装epoll,隐藏底层io细节,在事件的层次上进行操作。

Reactor网络模式

​ 在传统的阻塞io模型中,当一个线程遇到一个io操作时,它会一直等待操作完成。这意味着线程无法同时处理其他任务,导致资源利用率低下。
​ 而Reactor(反应堆)模式可以解决上述问题。Reactor是一种事件驱动的设计模式,将I/O事件的管理和处理分离开来,使得程序能够同时处理多个并发的 I/O 事件。
​ 具体来说,在 Reactor 模式中,有一个事件循环(event loop)负责监听各种输入事件,并将其分发给对应的处理函数进行处理。这样就实现了非阻塞地进行 I/O 操作,不需要等待单个 I/O 完成再进行下一个操作。相反,通过监听多个文件描述符上的事件,并将其交由合适的回调函数或处理器进行处理,可以实现高效的并发执行。

​ Reactor模式有单线程Reactor模式和多线程Reactor模式。今天我们主要在之前用epoll写简易tcp服务器的代码上进行修改从而实现单线程Reactor模式。

#include<sys/socket.h>
#include<errno.h>
#include<netinet/in.h>
#include<stdio.h>
#include<string.h>
#include<stdlib.h>
#include<sys/select.h>
#include<sys/epoll.h>
#include<unistd.h>#define SERV_PORT 2048
#define BUFFER_LENGTH 128
typedef int (*RCALLBACK)(int fd);struct conn_item
{int fd;char rbuffer[BUFFER_LENGTH];int rlen;char wbuffer[BUFFER_LENGTH];int wlen;union{RCALLBACK accept_callback;RCALLBACK recv_callback;}recv_t;RCALLBACK send_callback;
};int epfd = 0;
struct conn_item connlist[1024] = {0};
void set_event(int fd,int event,int flag)
{if(flag) //1 add 0 mod{struct epoll_event ev;ev.events = event;ev.data.fd = fd;epoll_ctl(epfd, EPOLL_CTL_ADD, fd, &ev);}else{struct epoll_event ev;ev.events = event;ev.data.fd = fd;epoll_ctl(epfd, EPOLL_CTL_MOD, fd, &ev);}
}int init_server()
{int sockfd = socket(AF_INET,SOCK_STREAM,0);struct sockaddr_in servaddr;memset(&servaddr,0,sizeof(struct sockaddr_in));servaddr.sin_family = AF_INET;servaddr.sin_port = htons(SERV_PORT);servaddr.sin_addr.s_addr = htonl(INADDR_ANY);if(-1 == bind(sockfd,(struct sockaddr*)&servaddr,sizeof(struct sockaddr))){perror("bind");return -1;}listen(sockfd,10);return sockfd;
}int recv_cb(int fd)
{char *buffer = connlist[fd].rbuffer;	int idx = connlist[fd].rlen;//读的长度是剩余的多少: BUFFER_LENGTH - idx//每次从idx开始int count = recv(fd, buffer+idx, BUFFER_LENGTH - idx, 0);if (count == 0) {printf("disconnect\n");epoll_ctl(epfd, EPOLL_CTL_DEL, fd, NULL);		close(fd);return -1;}connlist[fd].rlen += count;//send(fd, buffer, connlist[fd].idx, 0);//设置事件 event
//need to sendmemcpy(connlist[fd].wbuffer,connlist[fd].rbuffer,connlist[fd].rlen);connlist[fd].rlen -= connlist[fd].rlen;connlist[fd].wlen = connlist[fd].rlen;set_event(fd,EPOLLOUT,0);return count;
}int send_cb(int fd)
{char *buffer = connlist[fd].wbuffer;int idx = connlist[fd].wlen;int count = send(fd,buffer,idx,0);//没有会一直recv bufferset_event(fd,EPOLLIN,0);return count;
}int accept_cb(int fd)
{struct sockaddr_in clientaddr;socklen_t len = sizeof(clientaddr);int clientfd = accept(fd, (struct sockaddr*)&clientaddr, &len);if(clientfd<0){return -1;}set_event(clientfd,EPOLLIN,1);connlist[clientfd].fd = clientfd;memset(connlist[clientfd].rbuffer,0,BUFFER_LENGTH);connlist[clientfd].rlen = 0;memset(connlist[clientfd].wbuffer,0,BUFFER_LENGTH);connlist[clientfd].wlen = 0;connlist[clientfd].recv_t.recv_callback = recv_cb;connlist[clientfd].send_callback = send_cb;return clientfd;
}int main()
{int sockfd = init_server();epfd = epoll_create(1);if(sockfd <0 ){printf("error\n");}connlist[sockfd].fd = sockfd;connlist[sockfd].recv_t.accept_callback = accept_cb;set_event(sockfd,EPOLLIN,1);struct epoll_event events[1024] = {0};printf("epoll test:\n");while(1){int nready = epoll_wait(epfd, events, 1024, -1);printf("nready:%d\n",nready);int i = 0;for(i = 0;i<nready;i++){int connfd = events[i].data.fd;if(events[i].events & EPOLLIN){int count = connlist[connfd].recv_t.recv_callback(connfd);printf("client send count:%d buffer: %s\n",count,connlist[connfd].rbuffer);}else if(events[i].events & EPOLLOUT){//printf("recv buffer: %s\n", connlist[connfd].wbuffer);int count = connlist[connfd].send_callback(connfd);printf("servre send buffer: %s\n",connlist[connfd].wbuffer);}}}}

这篇关于C语言实现Reactor的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1096177

相关文章

Python实现终端清屏的几种方式详解

《Python实现终端清屏的几种方式详解》在使用Python进行终端交互式编程时,我们经常需要清空当前终端屏幕的内容,本文为大家整理了几种常见的实现方法,有需要的小伙伴可以参考下... 目录方法一:使用 `os` 模块调用系统命令方法二:使用 `subprocess` 模块执行命令方法三:打印多个换行符模拟

SpringBoot+EasyPOI轻松实现Excel和Word导出PDF

《SpringBoot+EasyPOI轻松实现Excel和Word导出PDF》在企业级开发中,将Excel和Word文档导出为PDF是常见需求,本文将结合​​EasyPOI和​​Aspose系列工具实... 目录一、环境准备与依赖配置1.1 方案选型1.2 依赖配置(商业库方案)二、Excel 导出 PDF

Python实现MQTT通信的示例代码

《Python实现MQTT通信的示例代码》本文主要介绍了Python实现MQTT通信的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 安装paho-mqtt库‌2. 搭建MQTT代理服务器(Broker)‌‌3. pytho

使用zip4j实现Java中的ZIP文件加密压缩的操作方法

《使用zip4j实现Java中的ZIP文件加密压缩的操作方法》本文介绍如何通过Maven集成zip4j1.3.2库创建带密码保护的ZIP文件,涵盖依赖配置、代码示例及加密原理,确保数据安全性,感兴趣的... 目录1. zip4j库介绍和版本1.1 zip4j库概述1.2 zip4j的版本演变1.3 zip4

python生成随机唯一id的几种实现方法

《python生成随机唯一id的几种实现方法》在Python中生成随机唯一ID有多种方法,根据不同的需求场景可以选择最适合的方案,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习... 目录方法 1:使用 UUID 模块(推荐)方法 2:使用 Secrets 模块(安全敏感场景)方法

Spring StateMachine实现状态机使用示例详解

《SpringStateMachine实现状态机使用示例详解》本文介绍SpringStateMachine实现状态机的步骤,包括依赖导入、枚举定义、状态转移规则配置、上下文管理及服务调用示例,重点解... 目录什么是状态机使用示例什么是状态机状态机是计算机科学中的​​核心建模工具​​,用于描述对象在其生命

Spring Boot 结合 WxJava 实现文章上传微信公众号草稿箱与群发

《SpringBoot结合WxJava实现文章上传微信公众号草稿箱与群发》本文将详细介绍如何使用SpringBoot框架结合WxJava开发工具包,实现文章上传到微信公众号草稿箱以及群发功能,... 目录一、项目环境准备1.1 开发环境1.2 微信公众号准备二、Spring Boot 项目搭建2.1 创建

IntelliJ IDEA2025创建SpringBoot项目的实现步骤

《IntelliJIDEA2025创建SpringBoot项目的实现步骤》本文主要介绍了IntelliJIDEA2025创建SpringBoot项目的实现步骤,文中通过示例代码介绍的非常详细,对大家... 目录一、创建 Spring Boot 项目1. 新建项目2. 基础配置3. 选择依赖4. 生成项目5.

深入理解Go语言中二维切片的使用

《深入理解Go语言中二维切片的使用》本文深入讲解了Go语言中二维切片的概念与应用,用于表示矩阵、表格等二维数据结构,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧... 目录引言二维切片的基本概念定义创建二维切片二维切片的操作访问元素修改元素遍历二维切片二维切片的动态调整追加行动态

Linux下删除乱码文件和目录的实现方式

《Linux下删除乱码文件和目录的实现方式》:本文主要介绍Linux下删除乱码文件和目录的实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录linux下删除乱码文件和目录方法1方法2总结Linux下删除乱码文件和目录方法1使用ls -i命令找到文件或目录