开发者社区> nkbai> 正文

unix网络编程str_cli使用epoll实现

简介: unix网络编程str_cli使用epoll实现 unix环境高级编程中也有这个函数,都是为了讲解IO多路转接。从本质上来看epoll就是一个改善了的select和poll,本质没发生任何变化,对于构建在poll,select和epoll上的框架使用者来说,没什么区别。
+关注继续查看

unix网络编程str_cli使用epoll实现

unix环境高级编程中也有这个函数,都是为了讲解IO多路转接。从本质上来看epoll就是一个改善了的select和poll,本质没发生任何变化,对于构建在poll,select和epoll上的框架使用者来说,没什么区别。而对框架设计者来说,使用epoll来替换select或者poll代价也不大。

epoll说明

epoll主要涉及到三个函数,这个要比select和poll复杂,从本质上来说是因为epoll把通知内核我想要观察的描述符和内核通知我哪些描述符发生了变化分成了两个独立的部分,而前述的select和poll都是合二为一的,这也是为什么epoll能做到性能优势。

1.通知内核我想要观察哪些描述符

epoll_create

epollcreate用于创建一个文件描述符,以后所有的操作都与此文件描述符有关。实际上你可以认为这个相当于一个文件,存放了进程要观察的所有文件描述符集合。
原型是

int epoll_create(int size)

调用方式也很简单:
int epfd=epoll_create(10);
size 根据需要调整.

epoll_ctl 用于通知内核添加删除待观察文件描述符

epoll_ctl的使用比较复杂,主要是涉及到epoll_event 的操作.
epoll_event的定义如下:

typedef union epoll_data {  
    void *ptr;  
    int fd;  
    __uint32_t u32;  
    __uint64_t u64;  
} epoll_data_t;  
 //感兴趣的事件和被触发的事件  
struct epoll_event {  
    __uint32_t events; /* Epoll events */  
    epoll_data_t data; /* User data variable */  
};  

epoll_ctl的原型如下:

int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);

  • epfd 就是刚刚用epoll_create返回的描述符
  • op 是对文件描述符集合的操作,主要有增,删,改,没有查是因为这个是使用者自己维护的
    + EPOLL_CTL_ADD 增
    + EPOLL_CTL_MOD 改
    + EPOLL_CTL_DEL 删
  • fd 待增删改的文件描述符
  • event 这个是最复杂的数据结构也是我们关注的核心.这里我们只使用到了文件描述符的操作,其他说真的,我也不晓得用来做什么.
    + events是要观察文件描述符的哪些事件,主要有
    - EPOLLIN 可读
    - EPOLLOUT 可写
    - EPOLLERR 发生错误
    - EPOLLET 设置为边沿出发Edge Triggered, 类似于数电中的概念 ,如果不指定默认是水平触发Level Triggered
    - EPOLLONESHOT 只观察一次事件,一旦发生,对应的fd就会被内核从集合中删除
    - EPOLLPRI tcp 带外数据,用的很少
    - EPOLLHUP 对应的文件描述符被挂断,终端关闭事件.
    + data中的fd 设置为和epoll_ctl参数列表中的fd一致即可.

经过以上处理,内核已经知道了和epfd关联的待观察文件描述符集以及上面的事件.

等待关心事件的发生.

epoll_wait就是用来等待上述事件发生的,原型:int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout), epfd和epoll_ctl是一样的,events是内核返回给进程哪个文件描述符发生了什么事情,具体用法参考epoll_ctl。maxevents指明了events数组 大小;timeout可以指定超时,单位为毫秒(0会立即返回,-1是永久阻塞)。

unix网络编程中的str_cli函数

这个函数同时监听标准输入和一个连接到服务器的socket,如果用户输入了什么内容就会发送到服务器,如果从服务器收到了任何内容就直接输出到终端.


//
// Created by bai on 2/2/16.
//

#include "../lib/unp.h"

#include <sys/epoll.h>

void str_cli(FILE *fp, int sockfd)
{
    int efd;
    struct epoll_event event;
    struct epoll_event events[20];
    int i;
    int nfds;
    char        buf[MAXLINE];
    int     n;

    efd = epoll_create (10);
    if(efd<0){
        err_sys("epoll create failed");
    }
    event.data.fd=fileno(fp);
    event.events=EPOLLIN;
    epoll_ctl(efd,EPOLL_CTL_ADD,fileno(fp),&event);

    event.data.fd=sockfd;
    event.events=EPOLLIN;
    epoll_ctl(efd,EPOLL_CTL_ADD,sockfd,&event);


    for ( ; ; ) {
        nfds=epoll_wait(efd,events,sizeof(events)/sizeof(struct epoll_event),-1);
        if(nfds<0){
            err_sys("epoll wait error %d ",errno);
        }
        for(i=0;i<nfds;i++){
            if(events[i].data.fd==sockfd){
                if ( (n = Read(sockfd, buf, MAXLINE)) == 0) {
                    err_quit("str_cli: server terminated prematurely");
                }
                Write(fileno(stdout), buf, n);
            }
            if(events[i].data.fd==fileno(fp)){
                if ( (n = Read(fileno(fp), buf, MAXLINE)) == 0) {
                    close(sockfd);
                    break;
                }

                Writen(sockfd, buf, n);
            }
        }

    }
    close(efd);
}

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
.NET数据库编程求索之路--6.使用ADO.NET实现(三层架构篇-使用List传递数据-基于存储过程)(2)
6.使用ADO.NET实现(三层架构篇-使用List传递数据-基于存储过程)(2)      【 夏春涛 email: xchuntao@163.com  blog: http://www.cnblogs.
802 0
使用WCF实现SOA面向服务编程——使用AJAX+WCF服务“.NET技术”页面开发
  在上一篇讲到,如果将BLL层的每一个类都转化为*.svc,这是一个不实在的想法。它会使服务变化复杂,难于管理。   这时候,我们第一时间想到的是23个简单开发模式中的Factory,在这里,Factory正好派上用场。
942 0
《UNIX网络编程 卷2:进程间通信(第2版)》——1.8 书中IPC例子索引表
生产者-消费者:一个或多个线程或进程(生产者)把数据放到一个共享缓冲区中,另有一个或多个线程或进程(消费者)对该共享缓冲区中的数据进行操作。序列号持续增1:一个或多个线程或进程给一个共享的序列号持续增1。该序列号有时在一个共享文件中,有时在共享内存区中。
1136 0
.NET数据库编程求索之路--7.使用ADO.NET实现(工厂模式-实现多数据库切换)(4)
7.使用ADO.NET实现(工厂模式-实现多数据库切换)(4) 7.7 业务逻辑层HomeShop.BLL OrderBiz.cs View Code  1 using System; 2 using System.
801 0
.NET数据库编程求索之路--7.使用ADO.NET实现(工厂模式-实现多数据库切换)(2)
7.使用ADO.NET实现(工厂模式-实现多数据库切换)(2)     7.3 数据访问层工厂HomeShop.DALFactory      1 using System; 2 using System.
910 0
.NET数据库编程求索之路--9.使用EF实现
9.使用EF实现   源码下载: /Files/SummerRain/NetDbDevRoad/9使用EF实现1自动ORM简单三层.rar /Files/SummerRain/NetDbDevRoad/9使用EF实现2自动纯POCO代理简单三层.
682 0
“.NET技术”使用WCF实现SOA面向服务编程—— 架构设计
  SOA本身就是一种面向企业级服务的系统架构,简单来说,SOA就是一种进行系统开发的新的体系架构,在基于SOA架构的系统中,具体应用程序的功能是由 一些松耦合并且具有统一接口定义方式的组件(也就是service)组合构建起来的。
736 0
了解超然物外的static-属性篇 | 带你学《Java面向对象编程》之十
本节通过传统类与使用static的类之间的比较,突出了static对于存储超大量重复性数据的优异表现。
1372 0
使用WCF实现SOA面向服务编程—— 架构设计
本文转载:http://kb.cnblogs.com/page/96479/  SOA本身就是一种面向企业级服务的系统架构,简单来说,SOA就是一种进行系统开发的新的体系架构,在基于SOA架构的系统中,具体应用程序的功 能是由 一些松耦合并且具有统一接口定义方式的组件(也就是service)组合构建起来的。
767 0
+关注
nkbai
区块链技术爱好者,智能合约安全专家
179
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载