システムプログラム（第7週）: Pthreadによる複数のクライアントに対するサービスの同時提供

                                       筑波大学 システム情報工学研究科 
                                       コンピュータサイエンス専攻, 電子・情報工学系
                                       新城 靖
                                       <yas@is.tsukuba.ac.jp>

このページは、次の URL にあります。
http://www.coins.tsukuba.ac.jp/~syspro/2007/No7_files/echo-server-pthread.html
あるいは、次のページから手繰っていくこともできます。
http://www.coins.tsukuba.ac.jp/~syspro/2007/
http://www.coins.tsukuba.ac.jp/~yas/

Ptheadとは

echo-server-pthread.c

   1:	
   2:	/*
   3:	        echo-server-pthread.c -- 受け取った文字列をそのまま返すサーバ(pthread版)
   4:	        ~yas/syspro/ipc/echo-server-pthread.c
   5:	        Created on 2002/02/04 21:17:04
   6:	*/
   7:	#include <stdio.h>
   8:	#include <stdlib.h>     /* exit() */
   9:	#include <sys/types.h>  /* socket(), time() */
  10:	#include <sys/socket.h> /* socket() */
  11:	#include <netinet/in.h> /* struct sockaddr_in */
  12:	#include <pthread.h>    /* pthread_create */
  13:	#include <netdb.h>      /* getnameinfo() */
  14:	#include <string.h>     /* strlen() */
  15:	
  16:	extern  void echo_server( int portno );
  17:	extern  void echo_reply( int com );
  18:	extern  void print_my_host_port( int portno );
  19:	extern  void tcp_peeraddr_print( int com );
  20:	extern  void sockaddr_print( struct sockaddr *addrp, socklen_t addr_len );
  21:	extern  tcp_acc_port( int portno );
  22:	extern  int fdopen_sock( int sock, FILE **inp, FILE **outp );
  23:	
  24:	main( int argc, char *argv[] )
  25:	{
  26:	    int portno ;
  27:	        if( argc >= 3 )
  28:	        {
  29:	            fprintf( stdout,"Usage: %s [portno] \n",argv[0] );
  30:	            exit( -1 );
  31:	        }
  32:	        if( argc == 2 )
  33:	            portno = strtol( argv[1],0,10 );
  34:	        else
  35:	            portno = getuid();
  36:	        echo_server( portno );
  37:	}
  38:	

  39:	void
  40:	echo_server( int portno )
  41:	{
  42:	    int acc,com ;
  43:	    pthread_t worker ;
  44:	        acc = tcp_acc_port( portno );
  45:	        if( acc<0 )
  46:	            exit( -1 );
  47:	        print_my_host_port( portno );
  48:	        while( 1 )
  49:	        {
  50:	            if( (com = accept( acc,0,0 )) < 0 )
  51:	            {
  52:	                perror("accept");
  53:	                exit( -1 );
  54:	            }
  55:	            tcp_peeraddr_print( com );
  56:	            if( pthread_create( &worker, NULL, (void *)echo_reply, (void *)com)
  57:	                != 0 )
  58:	            {
  59:	                perror("pthread_create()");
  60:	                exit( 1 );
  61:	            }
  62:	            pthread_detach( worker );
  63:	        }
  64:	}

このプログラムの特徴を以下にまとめる。

• fork() の代りに pthread_create() をしている。fork()版より すっきりしている。
• wait しない代りに pthread_detach() している。fork版では必要だった delete_zombie() が不要である。

他の関数は、fork版、forkなし版とと同じである。

 % diff -c echo-server-nofork-fdopen.c echo-server-pthread.c
 *** echo-server-nofork-fdopen.c Sun May 21 20:12:41 2006
 --- echo-server-pthread.c       Sun May 21 22:14:21 2006
 ***************
 *** 1,16 ****

   /*
 !       echo-server-nofork-fdopen.c -- 受け取った文字列をそのまま返すサーバ(fork無し版)
 !       ~yas/syspro/ipc/echo-server-nofork-fdopen.c
 !       Created on 2004/05/09 19:08:47
   */
   #include <stdio.h>
   #include <stdlib.h>   /* exit() */
 ! #include <sys/types.h>        /* socket(), wait4() */
   #include <sys/socket.h>       /* socket() */
   #include <netinet/in.h>       /* struct sockaddr_in */
 ! #include <sys/resource.h> /* wait4() */
 ! #include <sys/wait.h> /* wait4() */
   #include <netdb.h>    /* getnameinfo() */
   #include <string.h>   /* strlen() */

 --- 1,15 ----

   /*
 !       echo-server-pthread.c -- 受け取った文字列をそのまま返すサーバ(pthread版)
 !       ~yas/syspro/ipc/echo-server-pthread.c
 !       Created on 2002/02/04 21:17:04
   */
   #include <stdio.h>
   #include <stdlib.h>   /* exit() */
 ! #include <sys/types.h>        /* socket(), time() */
   #include <sys/socket.h>       /* socket() */
   #include <netinet/in.h>       /* struct sockaddr_in */
 ! #include <pthread.h>  /* pthread_create */
   #include <netdb.h>    /* getnameinfo() */
   #include <string.h>   /* strlen() */

 ***************
 *** 41,46 ****
 --- 40,46 ----
   echo_server( int portno )
   {
       int acc,com ;
 +     pthread_t worker ;
	 acc = tcp_acc_port( portno );
	 if( acc<0 )
	     exit( -1 );
 ***************
 *** 53,59 ****
		 exit( -1 );
	     }
	     tcp_peeraddr_print( com );
 !           echo_reply( com );
	 }
   }

 --- 53,65 ----
		 exit( -1 );
	     }
	     tcp_peeraddr_print( com );
 !           if( pthread_create( &worker, NULL, (void *)echo_reply, (void *)com)
 !               != 0 )
 !           {
 !               perror("pthread_create()");
 !               exit( 1 );
 !           }
 !           pthread_detach( worker );
	 }
   }

 % 

サーバ側。サーバは、終了しないので、最後に、^C を押して、割り 込みを掛けて終了させる。

注意：全員がポート番号 1231 を使うとプログラムが動かないことがある。

% ./echo-server-pthread 1231 
run telnet azalea20.coins.tsukuba.ac.jp 1231 
[17785] connection (fd==4) from 130.158.86.40:56001
[17785] received (fd==4) 5 bytes, [012
]
[17785] connection (fd==6) from 130.158.86.50:52817
[17785] received (fd==6) 5 bytes, [abc
]
[17785] received (fd==6) 5 bytes, [def
]
[17785] connection (fd==6) closed.
[17785] received (fd==4) 5 bytes, [345
]
[17785] connection (fd==4) closed.
^C
% 

% telnet azalea20.coins.tsukuba.ac.jp 1231 
Trying 130.158.86.40...
Connected to azalea20.coins.tsukuba.ac.jp.
Escape character is '^]'.
012
012
345
345
^]
telnet> quit
Connection closed.
% 

% telnet azalea20.coins.tsukuba.ac.jp 1231 
Trying 130.158.86.40...
Connected to azalea20.coins.tsukuba.ac.jp.
Escape character is '^]'.
abc
abc
def
def
^]
telnet> quit
Connection closed.
%