`
cloudmail
  • 浏览: 271934 次
  • 来自: 广州
社区版块
存档分类
最新评论

用epoll实现异步的Echo服务器

阅读更多

epoll是Kernel 2.6后新加入的事件机制,在高并发条件下,远优于select.

用个硬件中的例子吧,可能不太恰当:epoll相当于I/O中断(有的时候才相应),而select相当于轮询(总要反复查询)。

其实epoll比slect好用很多,主要一下几个用法。

struct epoll_event ; epoll事件体,事件发生时候你可以得到一个它。其中epoll_event.data.fd可以存储关联的句柄,epoll_event.event是监听标志,常用的有EPOLLIN (有数据,可以读)、EPOLLOUT(有数据,可以写)EPOLLET(有事件,通用);

(1)创建epoll句柄

int epFd = epoll_create(EPOLL_SIZE);

(2)加入一个句柄到epoll的监听队列

ev.data.fd = serverFd;
ev.events = EPOLLIN | EPOLLET;
epoll_ctl(epFd, EPOLL_CTL_ADD, serverFd, &ev);

上面的fd是你要绑定给事件发生时候使用的fd,到时候只能操作这个,下面是事件类型。

使用epoll_ctl添加到之中,EPOLL_CTL_ADD是epoll控制类型,这里监听的fd和给event的fd一般相同。

(3)等待event返回

int nfds = epoll_wait(epFd, evs, EVENT_ARR, -1);

传入的evs是epoll_event的数组,EVENT_ARR应当是不超过这个数组的长度。返回nfds的是不超过EVENT_ARR的数值,表示本次等待到了几个事件。

(4)遍历事件

注意,这里遍历的事件是肯定已经发生了的,而select中遍历的是每个fd,而fd不一定在FDSET中(即不一定有读事件发生)!这是效率最大的差别所在!

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

{

//do something

}

(5)其他技巧

对事件是否是serverFd判断,如果是,进行accept并加入epoll监听队列,要设置异步读取。

如果evts[i]&EPOLLIN,表示可读,使用read进行试探,如果>0表示连接没有关闭,否则连接已经关闭(出发事件又读取不到东西,表示socket关闭!)。如果<0出错。如果>0,需要继续读取直到为0,但是注意这里的为0是在第一次read不为0的前提下,毕竟我们设置了异步读取,暂时没有数据可以读就返回0了!而如果第一次返回0,那么就是关闭吧!

注意关闭要移出出epoll并且close(clientFd)

罗嗦了好多,看代码!

001    /*
002     * main.cc
003     *
004     *  Created on: 2009-11-30
005     *      Author: liheyuan
006     *    Describe: epoll实现阻塞模式服务器(Echo服务器)
007     *
008     *   Last Date: 2009-11-30
009     *   CopyRight: 2009 @ ICT LiHeyuan
010     */
011    #include <stdio.h>
012    #include <stdlib.h>
013    #include <unistd.h>
014    #include <fcntl.h>
015    #include <arpa/inet.h>
016    #include <netinet/in.h>
017    #include <sys/epoll.h>
018    #include <errno.h>
019     
020    #define EPOLL_SIZE 10
021    #define EVENT_ARR 20
022    #define BACK_QUEUE 10
023    #define PORT 18001
024    #define BUF_SIZE 16
025     
026    void setnonblocking(int sockFd) {
027        int opt;
028     
029        //获取sock原来的flag
030        opt = fcntl(sockFd, F_GETFL);
031        if (opt < 0) {
032            printf("fcntl(F_GETFL) fail.");
033            exit(-1);
034        }
035     
036        //设置新的flag,非阻塞
037        opt |= O_NONBLOCK;
038        if (fcntl(sockFd, F_SETFL, opt) < 0) {
039            printf("fcntl(F_SETFL) fail.");
040            exit(-1);
041        }
042    }
043     
044    int main() {
045     
046        int serverFd;
047     
048        //创建服务器fd
049        serverFd = socket(AF_INET, SOCK_STREAM, 0);
050        setnonblocking(serverFd);
051     
052        //创建epoll,并把 serverFd放入监听队列
053        int epFd = epoll_create(EPOLL_SIZE);
054        struct epoll_event ev, evs[EVENT_ARR];
055        ev.data.fd = serverFd;
056        ev.events = EPOLLIN | EPOLLET;
057        epoll_ctl(epFd, EPOLL_CTL_ADD, serverFd, &ev);
058     
059        //绑定服务器端口
060        struct sockaddr_in serverAddr;
061        socklen_t serverLen = sizeof(struct sockaddr_in);
062        serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);
063        serverAddr.sin_port = htons(PORT);
064        if (bind(serverFd, (struct sockaddr *) &serverAddr, serverLen)) {
065            printf("bind() fail.\n");
066            exit(-1);
067        }
068     
069        //打开监听
070        if (listen(serverFd, BACK_QUEUE)) {
071            printf("Listen fail.\n");
072            exit(-1);
073        }
074     
075        //死循环处理
076        int clientFd;
077        sockaddr_in clientAddr;
078        socklen_t clientLen;
079        char buf[BUF_SIZE];
080        while (1) {
081            //等待epoll事件的到来,最多取EVENT_ARR个事件
082            int nfds = epoll_wait(epFd, evs, EVENT_ARR, -1);
083            //处理事件
084            for (int i = 0; i < nfds; i++) {
085                if (evs[i].data.fd == serverFd && evs[i].data.fd & EPOLLIN) {
086                    //如果是serverFd,表明有新连接连入
087                    if ((clientFd = accept(serverFd,
088                            (struct sockaddr *) &clientAddr, &clientLen)) < 0) {
089                        printf("accept fail.\n");
090                    }
091                    printf("Connect from %s:%d\n", inet_ntoa(clientAddr.sin_addr),
092                            htons(clientAddr.sin_port));
093                    setnonblocking(clientFd);
094                    //注册accept()到的连接
095                    ev.data.fd = clientFd;
096                    ev.events = EPOLLIN | EPOLLET;
097                    epoll_ctl(epFd, EPOLL_CTL_ADD, clientFd, &ev);
098                } else if (evs[i].events & EPOLLIN) {
099                    //如果不是serverFd,则是client的可读
100                    if ((clientFd = evs[i].data.fd) > 0) {
101                        //先进行试探性读取
102                        int len = read(clientFd, buf, BUF_SIZE);
103                        if (len > 0) {
104                            //有数据可以读,Echo写入
105                            do {
106                                if (write(clientFd, buf, len) < 0) {
107                                    printf("write() fail.\n");
108                                }
109                                len = read(clientFd, buf, BUF_SIZE);
110                            } while (len > 0);
111                        } else if (len == 0) {
112                            //出发了EPOLLIN事件,却没有可以读取的,表示断线
113                            printf("Client closed at %d\n", clientFd);
114                            epoll_ctl(epFd, EPOLL_CTL_DEL, clientFd, &ev);
115                            close(clientFd);
116                            evs[i].data.fd = -1;
117                            break;
118                        } else if (len == EAGAIN) {
119                            continue;
120                        } else {
121                            //client读取出错
122                            printf("read() fail.");
123                        }
124                    }
125                } else {
126                    printf("other event.\n");
127                }
128            }
129        }
130     
131        return 0;
132    }

转自:http://www.coder4.com/archives/135

 

分享到:
评论

相关推荐

    Unix Echo服务器和客户端(C语言)

    此外,为了实现并发处理,服务器可能使用了**多线程**或**异步I/O**模型,如`select()`、`poll()`或`epoll()`等机制来监控多个套接字的活动状态,以便在数据可用时立即处理。 文件名为`TCPEchoServerAndClient`的...

    tcpecho.zip_Echo Echo_echo server_echotcpip

    【TCP/IP Echo 服务器原理与实现】 在计算机网络通信中,Echo 服务器是一种常见的测试工具,它接收客户端发送的数据并原样返回,主要用于检查网络连接的可靠性。"tcpecho.zip" 包含了一个基于 TCP/IP 实现的 Echo ...

    evpp based echo server

    1. **异步事件驱动**:EVPP采用Epoll事件通知机制,通过libevent或libev等事件库,实现非阻塞I/O,提高系统并发能力。 2. **C++11标准**:EVPP利用C++11新特性,如lambda函数、智能指针等,提供更现代的编程体验和更...

    linux并发回音服务器与客户端

    - **异步非阻塞I/O**:使用select()、poll()或epoll()等机制,让单个线程能同时处理多个连接。 7. **测试和截图**:项目中的测试截图通常会展示服务器的启动、客户端的连接以及数据的交互过程。这有助于验证程序的...

    半同步反应堆模型实现Echo_Server

    在"Echo_Server"的实现中,我们通常会创建一个服务器,它能够响应客户端发送的数据并原样返回,即所谓的回显服务。这种服务常用于测试网络连接和协议实现。以下是对这个模型和实现的详细解释: 1. **事件库**:在...

    Learning-Echo:做得好玩。 练习学习无阻塞回声服务器。 一个(不是很)功能的实现。 包括阻塞式多线程实现以及非阻塞式异步回显实现,以便充分了解两者之间的区别

    总的来说,"Learning-Echo"项目是一个很好的学习平台,它涵盖了网络编程的核心概念和技术,有助于提升开发者对服务器实现的理解,尤其是无阻塞和异步处理在高并发场景下的应用。通过实践这个项目,不仅可以巩固C语言...

    C++异步网络IO库,仿java的mina实现

    echoserv echo 服务器,把客户端的数据不更改地返回。 编译,提供两种编译模式,windows的cygwin环境,还有linux环境。不用配置,直接make即可。 先编译core工程,在core工程下直接执行make指令 然后编译tools ...

    chibi.rar_EchoServer_c++ 网页游戏_网页 游戏_网页游_网页游戏

    这通常需要用到多线程或异步I/O模型,如epoll或select/poll等机制。这些技术可以提高服务器的并行处理能力,确保在高并发环境下仍能稳定运行。 此外,为了优化网络通信,EchoServer可能会采用TCP/IP协议栈中的各种...

    使用OTP原理构建一个非阻塞的TCP服务器

    4. **tcp_echo_fsm**: 这是处理客户端连接的有限状态机,它实现了echo服务器功能,即接收到客户端的任何数据后,都会原样返回。这对于演示目的非常合适,但在实际应用中,gen_fsm可以处理更复杂的交互逻辑。 为了...

    cpp-uWebSockets最轻量级的高效的可伸缩的WebSocket服务器实现

    1. 高性能:uWebSockets利用了最新的异步I/O技术,如epoll和kqueue,以及libuv库,确保了高效的事件驱动模型,能够处理成千上万的并发连接。 2. 轻量级:uWebSockets代码量小,没有过多的依赖,便于理解和维护,同时...

    basic-binary-ipc:BASIC-BINARY-IPC系统提供了一个接口,用于使用IPv4或本地流执行进程间通信。 该接口遵循非阻塞模式,该模式允许应用程序同步或异步通信

    基本二进制IPC 基本的二进制IPC系统提供了一个接口,用于... 可以使用以下命令启动echo服务器( load " examples/echo-example.lisp " )(echo-example:run-server 12345 ) 可以使用以下命令执行回显客户端( load " ex

    天津工程师范学院09年计算机网络课程设计程序大全

    - **异步编程**:使用异步I/O模型(如select、poll或epoll)提高端口扫描效率。 - **网络套接字编程**:在C/C++或Java中创建和使用套接字,进行网络通信。 这些项目涵盖了计算机网络编程的基础到高级概念,包括...

    netty的入门经典例子的使用

    Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。这个“netty的入门经典例子的使用”很可能是为了引导初学者了解和掌握 Netty 的基本用法和核心概念。下面将...

    PHP扩展swoole,PHP7及以上版本可用

    1. **异步非阻塞I/O**:Swoole利用epoll(Linux)和kqueue(FreeBSD)等事件驱动模型,实现I/O操作的异步非阻塞,提高了服务器处理高并发请求的能力。 2. **协程(Coroutine)**:Swoole在PHP7中引入了协程支持,...

    Netty基础应用实战.docx

    然后,你可以通过创建一个简单的echo服务器和客户端来理解Netty的基本工作原理。Echo服务器会将接收到的数据原样返回,而客户端则发送数据并接收回显。 Netty 的ChannelHandler 和 ChannelPipeline 是处理网络数据...

    libevent demo

    在"libevent demo"中,我们通常会看到一个基础的echoserver示例,它是使用libevent来实现的。Echoserver是一个简单的服务器,它接收客户端发送的数据并原样返回,常用于测试网络连接和数据传输。 **Libevent核心...

    Python的Tornado框架异步编程入门实例

    在实现异步编程的示例代码中,一个简单的echo server可以使用Tornado框架来创建,该server能够接收客户端的连接和数据,并将数据回送给客户端。在这个过程中,服务器端将监听读事件,当读事件发生时,读取数据,并...

    netty-in-action中文版

    - **写一个echo服务器**:通过实现简单的回显服务器来展示Netty的基本使用方法。 - **写一个echo客户端**:与回显服务器相对应,客户端同样重要,用于测试服务器的功能。 - **编译和运行Echo服务器和客户端**:详细...

    TCPecho.rar_in

    9. **多线程/并发处理**:为了同时处理多个客户端的连接,可以使用多线程或异步I/O模型如select、poll或epoll。 通过分析“TCPecho.c”源码,我们可以深入理解上述技术点的具体实现,以及作者如何利用它们来实现TCP...

    1_echo_server

    3. **多线程/异步I/O**:为了处理多个并发的客户端连接,服务器通常需要使用多线程或多进程,或者利用非阻塞I/O和事件驱动模型(如epoll、kqueue)来实现高效的并发处理。 4. **数据处理**:服务器接收到客户端的...

Global site tag (gtag.js) - Google Analytics