Chinaunix首页 | 论坛 | 博客

Aimerの博客

首页　| 　博文目录　| 　关于我

夏目玲子

  • 博客访问： 581109
  • 博文数量： 104
  • 博客积分： 0
  • 博客等级： 民兵
  • 技术积分： 1559
  • 用 户 组： 普通用户
  • 注册时间： 2014-08-21 00:58
个人简介

锻炼精神,首先要锻炼肉体

文章分类

全部博文（104）

文章存档

2018年（1）

2016年（1）

2015年（101）

2014年（1）

我的朋友
最近访客
推荐博文
相关博文
[c++,linux]网络编程之accept

分类： C/C++

2015-03-26 22:10:43

accept 函数常用在服务器端接收从客户端发来的请求信息，服务器程序一旦决定接收
来自客户端的请求
(通常情况下，请求可以是客户端请求读取服务器端的一个文件，或是
请求调用服务器上的一个函数，但无论是哪一种都需要服务器进程在本地为其提供一定的缓存空间
如果是文件，就会从服务器端的硬盘中通过系统调用将文件中的内容读取到内存中（缓存）；
如果是远程调用，便会调用服务器端的某个进程，进程的运行时需要创建变量和从系统堆栈上面获取运行空间的)
就需要向系统申请相关的缓冲空间，而在 socket 函数的讲解中我们也讨论过了，系统为
进程划分缓冲空间的方式与系统通过文件描述符来为文件划分空间的方式相似，
所以，一旦服务器 accept 客户端的请求成功，便会返回一个新的 套接字描述符，
而这个套接字描述符所指向的服务器本地系统中的缓冲空间，是用于 client 端与 server 端通信
交换数据的缓冲空间。它与服务器启动的时候通过 socket 函数返回的 套接字描述符 所对应的空间
不同，后者是用来接收并缓存来自各个不同 client端的连接信息的缓冲队列的数据缓冲空间。

下面介绍的是 accept 函数的 API
#include
#include
int accept ( int s , struct sockaddr *addr , socklen_t *addrlen ) ;

参数
 1. s : 是服务器端通过调用正确调用socket -> bind -> listen 函数之后的用于指向存放多个客户端缓冲
        队列缓冲区的套接字描述符
 2. addr : 是用来保存发起连接请求的主机的地址与端口的结构体变量，就是存放服务器接收请求
        的客户端的网络地址与端口的结构体变量
3.  addrlen: 用来传入第二个参数类型长度

返回值：
  如果函数执行正确的话，将会返回新的套接字描述符，用于指向与当前通信的客户端交换数据的缓冲区的
  套接字描述符

在这里不得不说的就是，服务器通过 accept 函数接收来自客户端的连接请求的方式，一共有两种，
1. 阻塞方式  这种方式是通过调用 socket 方法创建出来的 套接字描述符默认的通信方式，
   阻塞方式便是，当没有任何客户端向服务器端发送连接请求，同时服务器端的用于存放客户端连接请求
  缓冲队列为空的情况下，服务器端的代码执行一直卡在 accept 语句上不往下执行，直到接到来自客户端
 的连接请求才往下执行。
  
2. 非阻塞方式 
   这种方式通过 fcntl 函数作用于 socket 函数返回的 套接字描述符，并将该套机字描述符传入到 accept 函数
   的首个参数上来设定的。
   非阻塞的方式是指，当服务器端的请求连接缓冲队列为空，同时没有接到任何来自客户端的连接请求的时候，
   代码执行到 accept 函数调用的时候，会立即返回 -1 告知主程序这种情况而不是一直等待不往下进行。

这两种方式是通过调用 fcntl 这个函数来将 阻塞/非阻塞 信息标识到用于指向存放缓冲队列的套接字描述符
来实现 accept 是以阻塞还是非阻塞的方式接收来自各个客户端的连接请求的。

fcntl 函数的使用方式挺有意思，这种函数的使用方式在 unix 编程中很常见
就像是有三个参数，
第一个参数用作的记录用户信号， 第二个参数是告知用户信号发出什么动作，第三个参数是用作告诉用户信号动作的不同类型

就像是第一个参数是一张纸，这张纸将会作为指示工人的命令，
而 fcntl 函数是一个打印机，把白纸送入打印机
第二个参数用于告知打印机{画画}
第三个参数用于告知画画{画山水画，画油画，画素描}

待到将纸从打印机中取出的时候，纸上写着 (画画，画素描)
那么工人们便会{画画，画素描}

同样第一个参数是一张纸，这张纸将会作为指示工人的命令，
而 fcntl 函数是一个打印机，把白纸送入打印机
第二个参数用于告知打印机{打字}
第三个参数用于告知打字{打毛笔字，打钢笔字，打黑体，打宋体}

待到将纸从打印机中取出的时候，纸上写着 (打字，打毛笔字)
那么工人们便会{打字，打毛笔字}

这几种方式都可以通过不同的宏定义来实现，第二个参数就像是指定了第三个参数的变化阈值一样


所以对于 fcntl 函数来说 传入的 套接字描述符 sock_fd 就相当于是白纸，
int fcntl ( int sock_fd , int cmd , long arg ) ;
cmd 参数就相当于是命令 ，arg 参数就相当于是cmd命令所指定的指令集中的一条指令

在这里，要将 accept 的执行方式设定为非阻塞的便可以这样
fcntl ( 传入套接字描述符， F_SETFL , O_NONBLOCK )
待到传入的套接字描述符以上述的方式调用 fcntl 的时候，在被传入到 accept 函数中之后，
便会指示 accept 以 O_NONBLOCK 的方式来执行了。


实例代码1
阻塞通信方式（默认）

点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <string.h> // memset

  4. #include <sys/types.h> // AF_INET, SOCK_STREAM
  5. #include <sys/socket.h> // socket , bind ,listen , accept
  6. #include <netinet/in.h> // struct sockaddr_in
  7. #include <unistd.h> // unix standard libarary
  8. #include <fcntl.h> // fcntl



  12. #define SERVER_PORT 3369
  13. #define MAX_CONNECT_QUEUE_LENGTH 10

  15. int getSocketDone ()
  16. {
  17.   int ret = socket ( AF_INET , SOCK_STREAM , 0 ) ;
  18.   
  19.   if ( ret < 0 )
  20.   {
  21.     perror ("getSocketDone failed") ;
  22.   }
  23.  
  24.   return ret ;
  25. }

  27. int getBindDone ( int sock_fd )
  28. {
  29.   struct sockaddr_in serv_addr ;
  30.   int ret ;

  32.   memset ( &serv_addr , 0 , sizeof( struct sockaddr_in )) ;
  33.   serv_addr.sin_family = AF_INET ;
  34.   serv_addr.sin_port = htons (SERVER_PORT) ;
  35.   serv_addr.sin_addr.s_addr = htonl (INADDR_ANY) ;
  36.   
  37.   ret = bind ( sock_fd , (struct sockaddr *) (&serv_addr) ,
  38.         sizeof(struct sockaddr_in) ) ;
  39.   if ( ret < 0 )
  40.   {
  41.     perror ("getBindDone failed") ;
  42.   }
  43.   
  44.  return ret ;
  45. }

  47. int getListenDone ( int sock_fd )
  48. {
  49.   int ret = listen ( sock_fd , MAX_CONNECT_QUEUE_LENGTH ) ;
  50.  
  51.   if ( ret < 0 )
  52.   {
  53.     perror ("getListenDone failed") ;
  54.   }
  55.  
  56.   return ret ;
  57. }

  59. int setSocketFdNonblock( int *sock_fd ) // not used in this program
  60. {
  61.   // sock_fd will be modified in this method , so pointer will is need 

  63.   int ret = fcntl (*sock_fd , F_SETFL ,O_NONBLOCK) ;
  64.   if ( ret < 0 )
  65.   {
  66.     perror ("setSocketFdNonblock failed ") ;
  67.   }
  68.  
  69.  return ret ;
  70. }

  72. int getAcceptDone ( int sock_fd_queue , struct sockaddr_in *client_addr ,
  73.             int *client_len )
  74. {
  75.   int sock_fd_conn ;
  76.  
  77.   *client_len = sizeof (struct sockaddr_in) ;
  78.   
  79.   sock_fd_conn = accept ( sock_fd_queue , (struct sockaddr *)client_addr ,(socklen_t *) client_len ) ;
  80.  
  81.   if ( sock_fd_conn < 0 )
  82.   {
  83.       perror ("getAcceptDone failed") ;
  84.   }
  85.  
  86.  return sock_fd_conn ;
  87. }


  90. int main ( int argc , char ** argv )
  91. {
  92.   int sock_fd_queue , sock_fd_conn ;
  93.   int ret ;
  94.   struct sockaddr_in client_conn ;
  95.   int client_len ;
  96.  
  97.    
  98.   sock_fd_queue = getSocketDone () ;

  100.   if ( sock_fd_queue > 0 )
  101.   
  102.     printf (" getSocketDone success \n");
  103.   
  104.   else
  105.     goto error ;
  106.    
  107.   if ( !getBindDone ( sock_fd_queue ) )
  108.       printf ( "getBindDone success \n") ;
  109.   
  110.   else
  111.      goto error ;

  113.   if ( !getListenDone ( sock_fd_queue ) )
  114.      printf ("getListenDone success \n") ;
  115.   else
  116.     goto error ;
  117.  
  118.  if ( (sock_fd_conn = getAcceptDone ( sock_fd_queue , &client_conn , &client_len) ) > 0 )
  119.  {
  120.      printf ("getAcceptDone success \n ") ;
  121.      printf (" everything is done %d will used as the connect sock_fd \n " , sock_fd_conn ) ;

  123.  }

  125.  else
  126.    goto error ;

  128.   error :
  129.    printf ("one or more methods have failed \n ") ;
  130.    goto leave ;

  132.   leave:
  133.     return 0 ;
  134. }
代码执行的结果为

 getSocketDone success 
getBindDone success 
getListenDone success 

通过程序执行结果可知，代码执行到 accept 的时候进入阻塞状态，因为此时我们并没有创建请求连接的客户端


实例代码2
非阻塞通信方式（通过调用fcntl 函数设定）
两端代码没有太大区别注意红色代码段即可


点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <string.h> // memset

  4. #include <sys/types.h> // AF_INET, SOCK_STREAM
  5. #include <sys/socket.h> // socket , bind ,listen , accept
  6. #include <netinet/in.h> // struct sockaddr_in
  7. #include <unistd.h> // unix standard libarary
  8. #include <fcntl.h> // fcntl



  12. #define SERVER_PORT 3369
  13. #define MAX_CONNECT_QUEUE_LENGTH 10

  15. int getSocketDone ()
  16. {
  17.   int ret = socket ( AF_INET , SOCK_STREAM , 0 ) ;
  18.   
  19.   if ( ret < 0 )
  20.   {
  21.     perror ("getSocketDone failed") ;
  22.   }
  23.  
  24.   return ret ;
  25. }

  27. int getBindDone ( int sock_fd )
  28. {
  29.   struct sockaddr_in serv_addr ;
  30.   int ret ;

  32.   memset ( &serv_addr , 0 , sizeof( struct sockaddr_in )) ;
  33.   serv_addr.sin_family = AF_INET ;
  34.   serv_addr.sin_port = htons (SERVER_PORT) ;
  35.   serv_addr.sin_addr.s_addr = htonl (INADDR_ANY) ;
  36.   
  37.   ret = bind ( sock_fd , (struct sockaddr *) (&serv_addr) ,
  38.         sizeof(struct sockaddr_in) ) ;
  39.   if ( ret < 0 )
  40.   {
  41.     perror ("getBindDone failed") ;
  42.   }
  43.   
  44.  return ret ;
  45. }

  47. int getListenDone ( int sock_fd )
  48. {
  49.   int ret = listen ( sock_fd , MAX_CONNECT_QUEUE_LENGTH ) ;
  50.  
  51.   if ( ret < 0 )
  52.   {
  53.     perror ("getListenDone failed") ;
  54.   }
  55.  
  56.   return ret ;
  57. }

  59. int setSocketFdNonBlock( int *sock_fd )
  60. {
  61.   int new_sock_fd = fcntl (*sock_fd , F_SETFL ,O_NONBLOCK) ;
  62.   if ( new_sock_fd < 0 )
  63.   {
  64.     perror ("setSocketFdNonblock failed ") ;
  65.   }
  66.  
  67.  return new_sock_fd ;
  68. }

  70. int getAcceptDone ( int sock_fd_queue , struct sockaddr_in *client_addr ,
  71.             int *client_len )
  72. {
  73.   int sock_fd_conn ;
  74.  
  75.   *client_len = sizeof (struct sockaddr_in) ;
  76.   
  77.   sock_fd_conn = accept ( sock_fd_queue , (struct sockaddr *)client_addr ,(socklen_t *) client_len ) ;
  78.  
  79.   if ( sock_fd_conn < 0 )
  80.   {
  81.       perror ("getAcceptDone failed") ;
  82.   }
  83.  
  84.  return sock_fd_conn ;
  85. }


  88. int main ( int argc , char ** argv )
  89. {
  90.   int sock_fd_queue , sock_fd_conn ;
  91.   int ret ;
  92.   struct sockaddr_in client_conn ;
  93.   int client_len ;
  94.  
  95.    
  96.   sock_fd_queue = getSocketDone () ;

  98.   if ( sock_fd_queue > 0 )
  99.   
  100.     printf (" getSocketDone success \n");
  101.   
  102.   else
  103.     goto error ;
  104.    
  105.   if ( !getBindDone ( sock_fd_queue ) )
  106.       printf ( "getBindDone success \n") ;
  107.   
  108.   else
  109.      goto error ;

  111.   if ( !getListenDone ( sock_fd_queue ) )
  112.      printf ("getListenDone success \n") ;
  113.   else
  114.     goto error ;

  116.  // now we try to set accept running in non-blocking mode
  117. // by calling setSocketFdNonBlock

  119.   if ( !setSocketFdNonBlock (&sock_fd_queue) )
  120.      printf ( "setSocketFdNonBlock success , working in non blocking mode \n" ) ;
  121.   else
  122.       goto error ;
  123.  
  124.  if ( (sock_fd_conn = getAcceptDone ( sock_fd_queue , &client_conn , &client_len) ) > 0 )
  125.  {
  126.      printf ("getAcceptDone success \n ") ;
  127.      printf (" everything is done %d will used as the connect sock_fd \n " , sock_fd_conn ) ;

  129.  }

  131.  else
  132.  {
  133.    printf ("non accept working in non blocking mode , must return -1 ") ;
  134.    goto error ;
  135.  }

  137.   error :
  138.    printf ("one or more methods have failed \n ") ;
  139.    goto leave ;

  141.   leave:
  142.     return 0 ;
  143. }

程序运行结果为：

 getSocketDone success 
getBindDone success 
getListenDone success 
setSocketFdNonBlock success , working in non blocking mode 
getAcceptDone failed: Resource temporarily unavailable
non accept working in non blocking mode , must return -1 one or more  methods have failed 
阅读(8643) | 评论(0) | 转发(0) |
1

上一篇：[c++,linux]网络编程之listen

下一篇：[c++,linux]客户端和服务器端连接过程

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6