linux异步通信之epoll【转】

简介:

转自:http://www.cnblogs.com/snake-hand/archive/2012/08/13/2636229.html

1、简介

epoll是linux提供的一种异步的I/O通知方式,相比较于select机制而言,select是轮询的,而epoll是触发式的,而且select的最大连接数只有1024,超过这个限制后就只能使用多进程来操作了。所以epoll的效率相对而言更高。

2、主要函数

epoll_create      创建epoll

epoll_ctl       把某个句柄添加到epoll里面

epoll_wait       等待epoll事件的产生。只要注册的句柄发生了变化即会检查到有epoll事件的产生。

3、主要流程

 

    /* 创建EPOLL*/
    iEpollFd = epoll_create(MYPING_EPOLLEVENT_MAX);
 
    /* 设置sicket选项 */
    stServaddr.ucLen = sizeof(stServaddr);
    stServaddr.ucFamily = (UCHAR)AF_LIPC;
    stServaddr.usPort   = htons(LIPC_GLOBAL_PORT_MYPING);
    stServaddr.usAddr   = htons(LIPC_LIP_ADDR_ANY);

    /* 创建 socket */
    iLipcFd = socket(PF_LIPC, SOCK_DGRAM, LIPC_PROTO_STCP);
 
    /* bind socket */
    iRet += bind(iLipcFd, (struct sockaddr *)(&stServaddr), (UINT)sizeof(LIPC_SOCK_ADDR_S));
    
    /* listen socket */
    iRet += listen(iLipcFd, SOMAXCONN);

    /* bind or listen error */
    if(0 != iRet)
    {
        printf("bind or listen socket failed\r\n");
        (VOID)close(iLipcFd);
        return ERROR_FAILED;
    }

    /* regist socket to epoll */
    iRet = MYPING_EpollReg(EPOLLIN, iLipcFd, MYPING_LipcListenCallback);
    if(0 != iRet)
    {
        printf("regist lipc socket to epoll failed\r\n");
        (VOID)close(iLipcFd);
        return ERROR_FAILED;
    }
    /* 等待事件的产生 */
    for(;;)
    {
        /* this will be blocked until any registered event happend or timeout */
        iNfds = epoll_wait(g_iEpollHandle, astEpEvt, MYPING_EPOLLEVENT_MAX, -1);


        /* 轮询产生的事件 */
        for(i = 0; i < iNfds; i ++)
        {
            /* 获取注册的回调函数 */
            pfCallback = (VOID *)(ULONG)astEpEvt[i].callback;

            /* 调用相关的回调函数进行处理  */
            pfCallback(astEpEvt[i].events, astEpEvt[i].data.fd);
        }
    }

4、机制

实际上一般先在epoll上面注册一个监听的socket,当这个socket监听到有数据连接时,即创建一个新的socket来接收数据,然后把这个新的socket的句柄注册到epoll上面去,再在这个 socket的回调函数里面来做相应的处理。

 








本文转自张昺华-sky博客园博客,原文链接:http://www.cnblogs.com/sky-heaven/p/5847477.html,如需转载请自行联系原作者


相关文章
|
5月前
|
安全 算法 Linux
探索Linux命令gpgv2:安全通信与数据验证的利器
`gpgv2`是GPG的签名验证工具,用于确保文件完整性和来源真实性。基于公钥密码学,支持多种加密算法和OpenPGP标准。通过`--verify`等参数验证签名,例如`gpgv2 --verify signature_file file`。重要注意事项包括保护私钥、定期更新密钥、验证签名来源及使用强密码。在数据安全场景中,`gpgv2`是保障信息安全的利器。
|
18天前
|
存储 JSON Java
细谈 Linux 中的多路复用epoll
大家好,我是 V 哥。`epoll` 是 Linux 中的一种高效多路复用机制,用于处理大量文件描述符(FD)事件。相比 `select` 和 `poll`,`epoll` 具有更高的性能和可扩展性,特别适用于高并发服务器。`epoll` 通过红黑树管理和就绪队列分离事件,实现高效的事件处理。本文介绍了 `epoll` 的核心数据结构、操作接口、触发模式以及优缺点,并通过 Java NIO 的 `Selector` 类展示了如何在高并发场景中使用多路复用。希望对大家有所帮助,欢迎关注威哥爱编程,一起学习进步。
|
1月前
|
Linux C++
Linux C/C++之IO多路复用(poll,epoll)
这篇文章详细介绍了Linux下C/C++编程中IO多路复用的两种机制:poll和epoll,包括它们的比较、编程模型、函数原型以及如何使用这些机制实现服务器端和客户端之间的多个连接。
24 0
Linux C/C++之IO多路复用(poll,epoll)
|
1月前
|
网络协议 Linux 网络性能优化
Linux C/C++之TCP / UDP通信
这篇文章详细介绍了Linux下C/C++语言实现TCP和UDP通信的方法,包括网络基础、通信模型、编程示例以及TCP和UDP的优缺点比较。
36 0
Linux C/C++之TCP / UDP通信
|
1月前
|
网络协议 Linux
linux学习之套接字通信
Linux中的套接字通信是网络编程的核心,允许多个进程通过网络交换数据。套接字提供跨网络通信能力,涵盖本地进程间通信及远程通信。主要基于TCP和UDP两种模型:TCP面向连接且可靠,适用于文件传输等高可靠性需求;UDP无连接且速度快,适合实时音视频通信等低延迟场景。通过创建、绑定、监听及读写操作,可以在Linux环境下轻松实现这两种通信模型。
35 1
|
3月前
|
Linux
Linux源码阅读笔记13-进程通信组件中
Linux源码阅读笔记13-进程通信组件中
|
3月前
|
消息中间件 安全 Java
Linux源码阅读笔记13-进程通信组件上
Linux源码阅读笔记13-进程通信组件上
|
3月前
|
Linux 开发者
深入理解Linux I/O模型:同步、异步、阻塞与非阻塞
【8月更文挑战第1天】在探索操作系统的奥秘中,I/O模型作为影响性能的关键因素之一,常常让开发者们感到困惑。本文将通过浅显易懂的语言和实际代码示例,揭示Linux下同步与异步、阻塞与非阻塞的概念及其区别,并指导如何在实际应用中选择合适的I/O模型以优化程序性能。
136 1
|
5月前
|
消息中间件 存储 监控
实战Linux I/O多路复用:借助epoll,单线程高效管理10,000+并发连接
本文介绍了如何使用Linux的I/O多路复用技术`epoll`来高效管理超过10,000个并发连接。`epoll`允许单线程监控大量文件描述符,显著提高了资源利用率。文章详细阐述了`epoll`的几个关键接口,包括`epoll_create`、`epoll_ctl`和`epoll_wait`,以及它们在处理并发连接中的作用。此外,还探讨了`epoll`在高并发TCP服务场景的应用,展示了如何通过`epoll`和线程/协程池来构建服务框架。
622 10
|
5月前
|
Linux
Linux异步io机制 io_uring
Linux异步io机制 io_uring
77 1