epoll服务器连接性能,使用Epoll 在 Linux 上开发高性能应用服务器

古城微笑少年丶 2022-09-03 15:25 191阅读 0赞

Multiplexor::Multiplexor(int size, int timeout, bool lt)

\{

m\_epfd = epoll\_create(size);

if (m\_epfd == -1)

throw HERM\_SOCKET\_EXCEPTION(ST\_OTHER);

m\_size = size;

m\_evts = new struct epoll\_event\[size\];

m\_timeout = timeout;

// sys/epoll.h is no EPOLLRDHUP(0X2000), don't add EPOLLRDHUP

m\_otherMasks = EPOLLERR | EPOLLHUP;

if (!lt)

m\_otherMasks |= EPOLLET;

\}

Multiplexor::~Multiplexor()

\{

close(m\_epfd);

delete\[\] m\_evts;

\}

void Multiplexor::Run()

\{

int fds = epoll\_wait(m\_epfd, m\_evts, m\_size, m\_timeout);

if (fds == -1)

\{

if (errno == EINTR)

return;

\}

for (int i = 0; i < fds; ++i)

\{

\_\_uint32\_t evts = m\_evts\[i\].events;

ISockHandler\* eh = reinterpret\_cast(m\_evts\[i\].data.ptr);

int stateType = ST\_SUCCESS;

if (evts & EPOLLIN)

stateType = eh->OnReceive();

if (evts & EPOLLOUT)

stateType = eh->OnSend();

if (evts & EPOLLERR || evts & EPOLLHUP)

stateType = ST\_EXCEPT\_FAILED;

if (stateType != ST\_SUCCESS)

eh->OnError(stateType, errno);

\}

\}

void Multiplexor::Register(ISockHandler\* eh, MultiplexorMask mask)

\{

MultiplexorMask masks = mask | m\_otherMasks;

OperateHandler(EPOLL\_CTL\_ADD, eh, masks);

\}

void Multiplexor::Remove(ISockHandler\* eh)

\{

// Delete fd from epoll, don't need masks

OperateHandler(EPOLL\_CTL\_DEL, eh, ALL\_EVENTS\_MASK);

\}

void Multiplexor::EnableMask(ISockHandler\* eh, MultiplexorMask mask)

\{

MultiplexorMask masks = mask | Herm::READ\_MASK | Herm::WRITE\_MASK;

OperateHandler(EPOLL\_CTL\_MOD, eh, masks | m\_otherMasks);

\}

void Multiplexor::DisableMask(ISockHandler\* eh, MultiplexorMask mask)

\{

MultiplexorMask masks = (Herm::READ\_MASK | Herm::WRITE\_MASK) & (~mask);

if (!OperateHandler(EPOLL\_CTL\_MOD, eh, masks | m\_otherMasks))

throw HERM\_SOCKET\_EXCEPTION(ST\_OTHER);

\}

上面类就用到epoll\_create(), epoll\_ctl()和epoll\_wait()，以及几种事件。epoll用起来比select清爽一些。

大致用法类似下面这样：

先定义一个Handler

class StreamHandler : public Herm::ISockHandler

\{

public:

virtual Herm::Handle GetHandle() const;

virtual int OnReceive(int);

virtual int OnSend(int);

\};

在OnReceive()处理收到数据的动作，在OnSend()。。。。

在通信线程中，大概类似这样的代码，实际看情况。

Multiplexor multiplexor;

StreamHandler sh;

multiplexor.Register(&sh, READ\_EVT);

multiplexor.Run(...);![0b1331709591d260c1c78e86d0c51c18.png][]

[0b1331709591d260c1c78e86d0c51c18.png]: /images/20220829/65efd7c3d1b74eabb50f8c6b5cf4ba43.png

发表评论取消回复

表情：

评论列表（有 0 条评论，191人围观）

还没有评论，来说两句吧...

相关阅读

相关在开发高性能服务器应用时，Java性能优化实例

在开发高性能服务器应用时，Java通常会面临一些性能瓶颈。以下是一些Java性能优化的实例： 1. **对象池**：创建对象时可能会消耗大量内存。通过建立对象池，可以复用已创

分手后的思念是犯贱/ 2024年10月17日 17:24/ 0 赞/ 61 阅读

相关 linux服务器开发-网络编程-epoll

一. epoll的含义的定义 epoll是Linux下多路复用IO接口select/poll的增强版本，它能显著提高程序在大量并发连接中只有少量活跃的情况下的系统CPU利用

忘是亡心i/ 2023年10月06日 19:53/ 0 赞/ 78 阅读

相关 Linux 高并发服务器—— epoll 实现

1.epoll 原理 epoll 相对于select和poll来说，没有描述符限制，所以在高并发处理当中是真正意义上的高并发。select和poll采用的是轮询的方式监听

ゞ浴缸里的玫瑰/ 2023年07月26日 05:30/ 0 赞/ 36 阅读

相关 Linux Http服务器 epoll + threadpool 实现

Http服务器中包含了http协议、TCP/IP协议，同时该项目又包含了I/O复用技术、多进程多线程、线程池管理以及Linux gdb多线程多进程调试等一系列基本操作，所以通过

￡神魔★判官ぃ/ 2023年02月25日 08:50/ 0 赞/ 31 阅读

相关 linux编程c语言epoll小型http服务器

linux编程c语言epoll小型http服务器模型服务器端实现 void http_respond_head(int cfd, char typ

蔚落/ 2022年12月03日 02:22/ 0 赞/ 180 阅读

相关 linux并发服务器epoll

文章目录 linux并发服务器epoll 三个函数第一个函数 epoll\_create 第二个函数 epoll\_ctl

た入场券/ 2022年11月30日 12:50/ 0 赞/ 212 阅读

相关 linux的epoll机制,Linux epoll机制

epoll\_create、epoll\_ctl、epoll\_wait、close g++ 时加上， -pg 启用gprof，gcc编译的时候带上-pg参数即可，参考：

约定不等于承诺〃/ 2022年10月20日 12:15/ 0 赞/ 238 阅读

相关 linux服务器开发之epoll的封装类实现

![linux服务器开发之epoll的封装类实现][linux_epoll] 推荐视频： [全网最详细epoll讲解，6种epoll的设计，让你吊打面试官][epoll_

客官°小女子只卖身不卖艺/ 2022年09月16日 11:05/ 0 赞/ 207 阅读

相关 epoll服务器连接性能,使用Epoll 在 Linux 上开发高性能应用服务器

Multiplexor::Multiplexor(int size, int timeout, bool lt) \{ m\_epfd = epoll\_create(si

古城微笑少年丶/ 2022年09月03日 15:25/ 0 赞/ 191 阅读

相关 linux epoll ET，LT和用epoll实现简单的服务器

EPOLL事件的两种模型： 1，Level Triggered (LT) 水平触发 //缺省工作方式，即默认的工作方式,支持blocksocket和no\_blocksoc

我不是女神ヾ/ 2022年03月06日 08:58/ 0 赞/ 262 阅读