文档章节

并发服务器之高级IO

RLRL
 RLRL
发布于 2014/05/30 21:21
字数 1560
阅读 87
收藏 0
点赞 0
评论 0

高级IO

APUE第14章讲解了高级IO,主要有:非阻塞IO、IO多路转接技术:(select、poll),下面就简要就上述几个方面讲一讲个人观点。

  1. 非阻塞IO

    顾名思义,对数据不进行阻塞(你有数据我就处理,没有我就返回,不去花时间等数据到来)。相对于阻塞IO模型,时间效率要好,这对于开发大规模并发服务器无疑是画龙点睛(这成语是不是有点过了^-^,楼主高考语文75分^-^),但是你这个IO又调皮了,你不光能读,还能写。万一数据来了,你让我读,还是让我写?元芳,你猜!于是第一位智者带着它的专利来了:select(applause^-^)

  2. select

    select有专门的读事件集合,写事件集合。万一调皮的IO有数据了,我就可以知道对应于哪一个事件,是不是相比傻瓜的”你猜“IO要好很多。select一个不好的地方就是:万一IO亲朋好又多了,祖宗十八代都加入到这个大家庭集合中了,select开销不起啊,我只能容纳maxfd个,只能忍痛割爱,多余的我就不接受了。---------select有最大描述符限制。一般是1024。有一天有3个干儿子发来贺电(IO有可读写数据),亲爹select就在事件集合中找啊找。尼玛,岂不是要线性扫描一遍(好歹将事件集合设计成平衡二叉树之类的查找利器。。),爹找的好辛苦,太累了。--------线性扫描太耗时(究其原因:非活跃IO也在扫描序列中)

  3. poll

    这一年,亲爹select出去鬼混了,养了个儿子poll。熟话说,长江后浪推前浪,儿子poll比爹聪明了一点,把两个事件集合打了个包(有了一个pollfd数组)。哎,换汤不换药啊!优缺点与select差不多,不在赘述。

  4. epoll

        终于到了改革开放的时代,小伙伴们集齐了七龙珠,召唤出神龙,带来了epoll,该高级IO家族带来了福音。

        epoll三大法宝:epoll_create(创建)、epoll_ctl(一般用来注册事件)、epoll_wait(等待事件,而且是活跃的啊)

        之前也看过不少关于epoll的博客文章和相关资料,都说epoll的数据结构设计的好,我认为最主要的是它有一个指向事件描述符的指针,指针,就是一指,一针见血。快哉!!!

      (以上细节之处未说明!)

     下面附一段国外网站关于epoll使用示例的源码以及个人的中文注释,只能说,epoll很好很强大,一直想写一个epoll服务器应用。。欢迎四面八方的建议^-^(当然细节决定成败,细节要设计好)

      代码来源:https://banu.com/blog/2/how-to-use-epoll-a-complete-example-in-c/

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/epoll.h>
#include <errno.h>
#define MAXEVENTS 64
static int
make_socket_non_blocking (int sfd)
{
  int flags, s;
  flags = fcntl (sfd, F_GETFL, 0);//获取描述符标志
  if (flags == -1)
    {
      perror ("fcntl");
      return -1;
    }
  flags |= O_NONBLOCK;//非阻塞
  s = fcntl (sfd, F_SETFL, flags);
  if (s == -1)
    {
      perror ("fcntl");
      return -1;
    }
  return 0;
}
static int
create_and_bind (char *port)
{
  struct addrinfo hints;
  struct addrinfo *result, *rp;
  int s, sfd;
  memset (&hints, 0, sizeof (struct addrinfo));
  hints.ai_family = AF_UNSPEC;     /* Return IPv4 and IPv6 choices */
  hints.ai_socktype = SOCK_STREAM; /* We want a TCP socket */
  hints.ai_flags = AI_PASSIVE;     /* All interfaces */
  s = getaddrinfo (NULL, port, &hints, &result);//hints是一个用于地址过滤的模板
  if (s != 0)
    {
      fprintf (stderr, "getaddrinfo: %s\n", gai_strerror (s));//此处不能用strerror或perror来生成错误信息,这里使用gai_strerror(int error)
      return -1;
    }
  for (rp = result; rp != NULL; rp = rp->ai_next) //addrinfo是一个链表
    {
      sfd = socket (rp->ai_family, rp->ai_socktype, rp->ai_protocol);
      if (sfd == -1)
        continue;
      s = bind (sfd, rp->ai_addr, rp->ai_addrlen);
      if (s == 0)
        {
          /* We managed to bind successfully! */
          break;
        }
      close (sfd);
    }
  if (rp == NULL)
    {
      fprintf (stderr, "Could not bind\n");
      return -1;
    }
  freeaddrinfo (result);
  return sfd;
}
int
main (int argc, char *argv[])
{
  int sfd, s;
  int efd;
  struct epoll_event event;
  struct epoll_event *events;
  if (argc != 2)
    {
      fprintf (stderr, "Usage: %s [port]\n", argv[0]);
      exit (EXIT_FAILURE);
    }
  sfd = create_and_bind (argv[1]);
  if (sfd == -1)
    abort ();
  s = make_socket_non_blocking (sfd);
  if (s == -1)
    abort ();
  s = listen (sfd, SOMAXCONN);
  if (s == -1)
    {
      perror ("listen");
      abort ();
    }
  efd = epoll_create1 (0);
  if (efd == -1)
    {
      perror ("epoll_create");
      abort ();
    }
  event.data.fd = sfd;
  event.events = EPOLLIN | EPOLLET;//读事件与ET模式
  s = epoll_ctl (efd, EPOLL_CTL_ADD, sfd, &event);//注册事件
  if (s == -1)
    {
      perror ("epoll_ctl");
      abort ();
    }
  /* Buffer where events are returned */
  events = calloc (MAXEVENTS, sizeof event);//calloc与malloc的区别在于calloc分配后对内存空间数据做了初始化(0),而malloc只管分配空间,而内存为垃圾数据。
  /* The event loop */
  while (1)
    {
      int n, i;
      n = epoll_wait (efd, events, MAXEVENTS, -1);
      for (i = 0; i < n; i++)
 {

   if ((events[i].events & EPOLLERR) ||
              (events[i].events & EPOLLHUP) ||
              (!(events[i].events & EPOLLIN)))
     {
              /* An error has occured on this fd, or the socket is not
                 ready for reading (why were we notified then?) */
       fprintf (stderr, "epoll error\n");
       close (events[i].data.fd);
       continue;
     }
   else if (sfd == events[i].data.fd)//监听端口有事件^-^
     {
              /* We have a notification on the listening socket, which
                 means one or more incoming connections. */
              while (1)
                {
                  struct sockaddr in_addr;
                  socklen_t in_len;
                  int infd;
                  char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV];
                  in_len = sizeof in_addr;
                  infd = accept (sfd, &in_addr, &in_len);//接受请求(来吧,data)
                  if (infd == -1)
                    {
                      if ((errno == EAGAIN) ||
                          (errno == EWOULDBLOCK))
                        {
                          /* We have processed all incoming
                             connections. */
                          break;
                        }
                      else
                        {
                          perror ("accept");
                          break;
                        }
                    }
                  s = getnameinfo (&in_addr, in_len,
                                   hbuf, sizeof hbuf,
                                   sbuf, sizeof sbuf,
                                   NI_NUMERICHOST | NI_NUMERICSERV);
                  if (s == 0)
                    {
                      printf("Accepted connection on descriptor %d "
                             "(host=%s, port=%s)\n", infd, hbuf, sbuf);
                    }
                    //不断的注册事件
                  /* Make the incoming socket non-blocking and add it to the
                     list of fds to monitor. */
                  s = make_socket_non_blocking (infd);
                  if (s == -1)
                    abort ();
                  event.data.fd = infd;
                  event.events = EPOLLIN | EPOLLET;
                  s = epoll_ctl (efd, EPOLL_CTL_ADD, infd, &event);
                  if (s == -1)
                    {
                      perror ("epoll_ctl");
                      abort ();
                    }
                }
              continue;
            }
          else
            {
              /* We have data on the fd waiting to be read. Read and
                 display it. We must read whatever data is available
                 completely, as we are running in edge-triggered mode
                 and won't get a notification again for the same
                 data. */
              int done = 0;
              while (1)
                {
                  ssize_t count;
                  char buf[512];
                  count = read (events[i].data.fd, buf, sizeof buf);
                  if (count == -1)
                    {
                      /* If errno == EAGAIN, that means we have read all
                         data. So go back to the main loop. */
                      if (errno != EAGAIN)
                        {
                          perror ("read");
                          done = 1;
                        }
                      break;
                    }
                  else if (count == 0)
                    {
                      /* End of file. The remote has closed the
                         connection. */
                      done = 1;
                      break;
                    }
                  /* Write the buffer to standard output */
                    //将接收到的数据写到标准输出
                  s = write (1, buf, count);
                  if (s == -1)
                    {
                      perror ("write");
                      abort ();
                    }
                }
              if (done)
                {
                  printf ("Closed connection on descriptor %d\n",
                          events[i].data.fd);
                  /* Closing the descriptor will make epoll remove it
                     from the set of descriptors which are monitored. */
                  close (events[i].data.fd);
                }
            }
        }
    }
  free (events);
  close (sfd);
  return EXIT_SUCCESS;//上面的EXIT_FAILURE 与此处的EXIT_SUCCESS是方便程序移植,我们平常都写return 0;return -1啊
}


/*There is still space to explore ^-^,just fight*/

© 著作权归作者所有

共有 人打赏支持
RLRL
粉丝 13
博文 18
码字总数 10318
作品 0
嘉定
程序员
Linux多线程并发服务器编程(线程池,FTP服务器)

分享网盘下载:https://pan.baidu.com/s/1gfNCcXt 密码: irfk 内容简介 本课程从最基础的进程、线程概念讲起逐步深入,通过理论与实践结合的方式,使学员快说掌握linux多线程网络编程技术,并...

人气王子333
06/26
0
0
关于Apache与Nginx的优势比较

不断有人跟我说Nginx比Apache好、比Apache快之类。Nginx更主要是作为反向代理,而非Web服务器使用。我翻译过一本关于反向代理的技术书籍,同时精通Apache API开发,对Nginx和Apache的工作原理...

daniel-john
2014/10/13
0
2
Python高级编程和异步IO并发编程

Python高级编程和异步IO并发编程 网盘地址:https://pan.baidu.com/s/1eB-BsUacBRhKxh7qXwndMQ 密码: tgba 备用地址(腾讯微云):https://share.weiyun.com/5Z3x9V0 密码:7cdnb2 针对Pytho...

人气王子333
04/23
0
0
0-Linux 网络编程学习笔记导航

学习交流群: Linux 学习交流群 610441700 说明:本系列文章并不能取代 《UNP》这本旷世之作,文章中难免有错误与不足之处,希望读者们遇到有疑问的地方可以加群互相交流,共同进步。写这一系...

q1007729991
2017/04/04
0
0
PHP的HTTP客户端--Leaps/HttpClient

HttpClient 通过HTTP/HTTPS协议获取数据 安装 "require" : { "php" : ">=5.4.0", "leaps/httpclient": "1.3.4" } 基本使用 这个组件极易使用: <?php //Create an instance $HttpClient = n......

灵魂架构师
2015/01/31
3K
3
异步IO、APC、IO完成端口、线程池与高性能服务器 (三)

异步IO、APC、IO完成端口、线程池与高性能服务器 (三)  作者 Fang(fangguicheng@21cn.com)

啊莱
2006/01/22
0
0
Walle 1.1.0正式版发布,上线部署系统

Walle 1.1.0正式版发布。 Walle - 瓦力 是一个支持svn、git、多用户、多项目、多环境同时部署的上线部署系统。 相比jenkins其项目配置更简单、回滚快速、权限分级、用户分组功能更完善;UI界...

wushuiyong
2016/03/24
5.6K
12
varnish、squid、nginx各自缓存的优缺点

◆Varnish 高性能、开源的反向代理服务器和内存缓存服务器。 优点: 1. 高性能; 2. 多核支持; 3. 支持0-60秒的精确缓存时间。 缺点: 1. 不具备自动容错和恢复功能,重启后数据丢失; 2. 在...

李丫头lmy
2017/03/28
0
0
Hyper-V 3 虚拟网卡带宽应用限制

Windows Server 2012的Hyper-V 3中,打来了系列新功能,例如网卡流量限制功能。基础架构注意的问题 宿主服务器规划过程中,管理员主要考虑服务器基础架构中的CPU、内存、磁盘空间等必要因素,...

wangshujiang
2012/07/24
0
0
Java BIO、NIO、AIO 比较

理解一下概念,以银行取款为例 同步 : 自己亲自出马持银行卡到银行取钱(使用同步IO时,Java自己处理IO读写)。 异步 : 委托一小弟拿银行卡到银行取钱,然后给你(使用异步IO时,Java将IO读...

Corlang
2016/02/01
94
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

解决dokuwiki创建中文词条文件乱码问题

若直接创建中文词条,打开本地文件夹\dokuwiki\data\pages你会发现,中文字段显示的是URL乱码,需要改一下utf8格式,方法如下:(linux系统亲测有效) 打开 .dokuwiki\conf\local.php 添加一行...

Rhymo-Wu
2分钟前
0
0
设置圆角长条progressbar背景色

1、首先在Drawable下面新建一个xml文件,将这段代码复制进去 <?xml version="1.0" encoding="utf-8"?><layer-list xmlns:android="http://schemas.android.com/apk/res/android"> <!-......

王先森oO
2分钟前
0
0
Java语言学习(九):异常处理

异常是程序中的一些错误,但并不是所有的错误都是异常,并且错误有时候是可以避免的。常见的三种异常类型有: 检查性异常,如打开一个不存在的文件 运行时异常,如数组越界 错误,如栈溢出 ...

海岸线的曙光
5分钟前
0
0
深入分析golang多值返回以及闭包的实现

一、前言 golang有很多新颖的特性,不知道大家的使用的时候,有没想过,这些特性是如何实现的?当然你可能会说,不了解这些特性好像也不影响自己使用golang,你说的也有道理,但是,多了解底...

万建宁
6分钟前
0
0
img与background-image之间的区别

1.img <img src="图片来源" alt="图片无法显示时显示图片说明性文字" style="设置样式属性" /> img标签虽然不是块状元素,但是可以设置宽高,占位, img设置width后height会自适应匹配,如果...

爱喝水的小熊
8分钟前
0
0
Swift - 添加提示音

func createSound() { //建立的SystemSoundID对象 var soundID:SystemSoundID = 123 //获取声音地址 let path = Bundle.main.path(forResource: "3quan......

west_zll
10分钟前
0
0
为图片写水印的时候中文乱码

缘由:源代码在本地win7 操作系统添加水印正常,但在linux 7.4 上 添加水印乱码(空心方格) 问题的本质是在linux 操作系统中没有对Font 类支持的字体,才会出现乱码 问题截图: 1.系统linux...

qimh
10分钟前
0
0
微信小游戏子域和主域

1、主域只能够设置自身的敏感属性值 2、子域只能够读取自身、朋友、群友的敏感属性值

微信小程序-暗潮
10分钟前
0
0
Django时区详解

引言 相信使用Django的各位开发者在存储时间的时候经常会遇到这样子的错误: RuntimeWarning: DateTimeField received a naive datetime while time zone support is active. 这个错误到底...

bobway
16分钟前
0
0
改造工程步骤

背景: 对于存在有问题的项目(包括 代码不规范 数据库表命名不规范 )需要改造 步骤: 1 新建工程 : 将需要改造的项目拷贝一份 修改项目名称 2 将相应的表结构拷贝到新的数据库中 修改不直...

猿神出窍
22分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部