システムプログラム（第8週）: select()による複数のクライアントに対するサービスの同時提供
筑波大学 システム情報系 情報工学域
新城 靖
<yas@cs.tsukuba.ac.jp>
このページは、次の URL にあります。
http://www.coins.tsukuba.ac.jp/~syspro/2013/2013-06-05
/echo-server-select.html
あるいは、次のページから手繰っていくこともできます。
http://www.coins.tsukuba.ac.jp/~syspro/2013/
http://www.coins.tsukuba.ac.jp/~yas/
fork版 では、クライアントから接続要
求を受け付けるたびに、新しいプロセスを作っていた。以下の
echo-server-select.cでは、１つのプロセスで実行している。
1:
2: /*
3: echo-server-select.c -- 受け取った文字列をそのまま返すサーバ(select版)
4: ~yas/syspro/ipc/echo-server-select.c
5: Created on 1997/06/09 19:53:33
6: */
7: #include <stdio.h>
8: #include <stdlib.h> /* exit() */
9: #include <sys/types.h> /* socket(), time(), select() */
10: #include <sys/socket.h> /* socket() */
11: #include <netinet/in.h> /* struct sockaddr_in */
12: #include <sys/time.h> /* select() */
13: #include <unistd.h> /* select() */
14: #include <netdb.h> /* getnameinfo() */
15: #include <string.h> /* memset() */
16:
17: extern void echo_server_select( int portno, int ip_version );
18: extern void echo_reply_select( int com );
19: extern int find_maxfds( fd_set *fds );
20: extern int echo_reply_once( int com );
21: extern void print_my_host_port( int portno );
22: extern void tcp_peeraddr_print( int com );
23: extern void sockaddr_print( struct sockaddr *addrp, socklen_t addr_len );
24: extern int tcp_acc_port( int portno, int pf );
25: extern int fdopen_sock( int sock, FILE **inp, FILE **outp );
26: extern ssize_t writen(int fd, const void *vptr, size_t n);
27: extern ssize_t readline(int fd, void *vptr, size_t maxlen);
28:
29: main( int argc, char *argv[] )
30: {
31: int portno, ip_version;
32: if( !(argc == 2 || argc==3) ) {
33: fprintf(stderr,"Usage: %s portno {ipversion}\n",argv[0] );
34: exit( 1 );
35: }
36: portno = strtol( argv[1],0,10 );
37: if( argc == 3 )
38: ip_version = strtol( argv[2],0,10 );
39: else
40: ip_version = 4; /* IPv4 by default */
41: echo_server_select( portno, ip_version );
42: }
43:
main() 関数の部分は、fork版 とほと
んど同じである。
44: void
45: echo_server_select( int portno, int ip_version )
46: {
47: int acc,com ;
48: fd_set readfds,readfds_save ;
49: int i,n, maxfds, next_maxfds ;
50:
51: acc = tcp_acc_port( portno, ip_version );
52: if( acc<0 )
53: exit( -1 );
54: print_my_host_port( portno );
55:
56: FD_ZERO( &readfds_save );
57: FD_SET( acc,&readfds_save );
58: maxfds = next_maxfds = acc + 1;
59: while( 1 )
60: {
61: readfds = readfds_save ;
62: n = select( maxfds,&readfds,0,0,0 );
63: if( n <= 0 )
64: {
65: perror("select");
66: exit( 1 );
67: }
68: if( FD_ISSET(acc,&readfds) )
69: {
70: FD_CLR( acc,&readfds );
71: printf("[%d] accepting incoming connections (fd==%d) ...\n",getpid(),acc );
72: if( (com = accept( acc,0,0 )) < 0 )
73: {
74: perror("accept");
75: exit( -1 );
76: }
77: FD_SET( com, &readfds_save );
78: if( com+1 > maxfds )
79: {
80: next_maxfds = com+1;
81: }
82: tcp_peeraddr_print( com );
83: }
84: for( i=0 ; i<maxfds ; i++ )
85: {
86: if( FD_ISSET(i,&readfds) )
87: {
88: if( echo_reply_once( i )<=0 )
89: {
90: printf("[%d] connection (fd==%d) closed.\n",getpid(),i );
91: close( i );
92: FD_CLR( i,&readfds_save );
93: if( maxfds == i+1 )
94: {
95: next_maxfds = find_maxfds( &readfds_save );
96: }
97: }
98: }
99: }
100: maxfds = next_maxfds ;
101: }
102: }
103:
tcp_acc_port() で、接続受付け用ポートに対応したソケットを
作り、print_my_host_port() (fork版 と同じ)
で表示している。
ループに入る前に、fd_set 形の変数 readfds_save を初期化している。
fd_set は、ファイル記述子(file descriptor) の set (集合)を意味する。内
部的には、ビットの並びで実現されていることが多い。次のような操作がある。
- FD_ZERO(&fds)
- 初期化する(集合を空にする)
- FD_SET(fd,&fds)
- fd を集合に加える(ビットを１にする)
- FD_CLR(fd,&fds)
- fd を集合から取り除く(ビットを０にする)
- FD_ISSET(fd,&fds)
- その fd が集合に含まれているかを調べる。
初期値は、tcp_acc_port() で作成した接続受付け用ポートに対応したソケッ
トを入れる。
無限ループを含むのは、fork版と同じ
である。
readfds = readfds_save は、select() の実行で壊されるので、保存してある。
「壊される」とは、プロセスからシステムへの方向に値を送るだけでなく、同
じ場所に、システムからプロセスの方向へ結果が返される（同じ場所に上書き
される）ことを意味する。
select() は、引数で指定された集合が、入力可能かどうかを調べている。入
力可能でなければ、入力可能になるまで待つ。
第３引数以降を使えば、出力可能かを調べたり、無限に待つのではなくて、あ
る指定された時間だけ待つこともできる。
もし、要求受付け用ポートに対応したソケット acc が入力可能ならば、
accept() すると止まらずに処理が進むことを意味する。処理とは、クライア
ントとの間の通信用ポートに対応したソケットが作ることである。fork() 版
とは違い、この accept() の所で待つことはない。
accept() が成功したら、結果として返されたファイル記述子を、
readfds_save に加える。次のループから select() の監視の対象になる。
for 文で、残りのファイル記述子について調べる。一度に複数のファイル記
述子がセットされている可能性がある。
もしセットされているファイル記述子を見つけたら、echo_reply_once() を呼
び出す。普通は、0 より大きい数が返ってくる。そして次のセットされている
ファイル記述子について echo_reply_once() の処理を続ける。
特殊な場合として、echo_reply_once() は、クライアントが接続を切った場合
には、0 以下の値を返す。その場合は、close() でファイル記述子を解放し、
readfds_save からも FD_CLR() で取り除く。
select() の第１引数には、最大の「ファイル記述子＋１」を与える。
初期値は、acc+1 である。
accept() の時に、増える可能性があり、その場合は増やす。
close() の時に減る可能性があり、その場合は減らす。
select版では、fork版とは異なり、ゾンビ・プロセスは発生しない。
104: int
105: find_maxfds( fd_set *fds )
106: {
107: int i, maxfds ;
108: for( i=FD_SETSIZE; i>= 0; i-- )
109: {
110: if( FD_ISSET(i,fds) )
111: {
112: return( i+1 );
113: }
114: }
115: return( 0 );
116: }
117:
find_maxfds() は、select() の第１引数に与える最大の「ファイル記述子＋
１」を探す関数である。引数の fd_set を、FD_SETSIZE から 0 に向かって探
している。
118: #define BUFFERSIZE 1024
119:
120: int
121: echo_reply_once( int com )
122: {
123: char line[BUFFERSIZE] ;
124: int rcount ;
125: int wcount ;
126:
127: if( (rcount=readline(com,line,BUFFERSIZE)) > 0 )
128: {
129: printf("[%d] read(%d,,) %d bytes, %s",getpid(),com,rcount,line );
130: fflush( stdout );
131: if( (wcount=writen(com,line,rcount))!= rcount )
132: {
133: perror("write");
134: exit( 1 );
135: }
136: }
137: return( rcount );
138: }
139:
データを読込む時には、readline() を使っている。これは、fgets() と同様
に\n 記号が現れるまでを一区切りとして、読込むものである。引数は
fgets() とは異なり、ファイル記述子である。readline() は、バッファサイ
ズ以上は、読込まない。また、最後に文字列の終端の 0 を付ける。(read()
システムコールでは、付けてくれない。)
このプログラムでは、write() システムコールの変りに writen() 関数（ソー
ス・プログラムは同じファイルの下の方にある）を使っている。TCP/IP の通
信では、write(fd,buf,100) としても、100バイト送られずに、50 バイトしか
送られないことがある。残りの 50 バイトも送る必要があれば、ループして全
部送るようにする。システム・コール write() は、今は送る必要がない（後
で送ってもよい）場合、送らなくてもよい場合にも対応できるようになってい
る。しかし、一般には送る方は全部送り終わるまでループして待った方がよい
場合が多い。writen() は、このような目的のための関数である。
echo_reply_once() は、readline() の結果(多くの場合は、読込んだバイト数)
をそのまま返す。0 以下の数を返した時にもそのまま返す。
以下の関数は、fork() 版と同じである。
141: print_my_host_port( int portno )
150: tcp_peeraddr_print( int com )
166: sockaddr_print( struct sockaddr *addrp, socklen_t addr_len )
182: tcp_acc_port( int portno, int ip_version )
260: fdopen_sock( int sock, FILE **inp, FILE **outp )
282: /*
283: W.リチャード・スティーブンス著、篠田陽一訳:
284: "UNIXネットワークプログラミング第２版 Vol.1 ネットワークAPI:ソケットとXTI",
285: ピアソン・エデュケーション, 1999年. ISBN 4-98471-205-9
286: 3.9節 readn, writen, および readline 関数 (p.76)
287:
288: Richard Stevens: "UNIX Network Programming, Volume 1, Second Edition:
289: Networking APIs: Sockets and XTI", Prentice Hall, 1998.
290: ISBN 0-13-490012-X.
291: Section 3.9 readn, writen, and readline Functions (p.77)
292:
293: http://www.kohala.com/start/ (http://www.kohala.com/~rstevens/)
294: http://www.kohala.com/start/unpv12e/unpv12e.tar.gz
295:
296: */
297:
298: /* include writen */
299: /*#include "unp.h"*/
300: #include <errno.h>
301:
302: ssize_t /* Write "n" bytes to a descriptor. */
303: writen(int fd, const void *vptr, size_t n)
304: {
305: size_t nleft;
306: ssize_t nwritten;
307: const char *ptr;
308:
309: ptr = vptr;
310: nleft = n;
311: while (nleft > 0) {
312: if ( (nwritten = write(fd, ptr, nleft)) <= 0) {
313: if (errno == EINTR)
314: nwritten = 0; /* and call write() again */
315: else
316: return(-1); /* error */
317: }
318:
319: nleft -= nwritten;
320: ptr += nwritten;
321: }
322: return(n);
323: }
324:
325: /* include readline */
326: /*#include "unp.h"*/
327:
328: ssize_t
329: readline(int fd, void *vptr, size_t maxlen)
330: {
331: ssize_t n, rc;
332: char c, *ptr;
333:
334: ptr = vptr;
335: for (n = 1; n < maxlen; n++) {
336: again:
337: if ( (rc = read(fd, &c, 1)) == 1) {
338: *ptr++ = c;
339: if (c == '\n')
340: break; /* newline is stored, like fgets() */
341: } else if (rc == 0) {
342: if (n == 1)
343: return(0); /* EOF, no data read */
344: else
345: break; /* EOF, some data was read */
346: } else {
347: if (errno == EINTR)
348: goto again;
349: return(-1); /* error, errno set by read() */
350: }
351: }
352:
353: *ptr = 0; /* null terminate like fgets() */
354: return(n);
355: }
356: /* end readline */
readline() は、\n 記号が現れるまでを一区切りとして、読込む。fgets() と
同様に、最後に終端の 0 を付けてくれる。
このプログラムは、１バイトずつ読み込んでいるので、性能が悪い。上記の教
科書では、高速版やマルチスレッドで動作するプログラムも示してある。
実行例。
サーバ側。サーバは、終了しないので、最後に、^C を押して、割り
込みを掛けて終了させる。
注意：同じホストで複数人がポート番号 1231 を使うと動作しない。
$ cp ~yas/syspro/ipc/echo-server-select.c . ![[←]](../icons/screen-return.gif)
$ make echo-server-select
cc echo-server-select.c -o echo-server-select
$ ./echo-server-select
Usage: ./echo-server-select portno {ipversion}
$ ./echo-server-select 1231
run telnet cosmos10(v6) 1231
[17181] accepting incoming connections (fd==3) ...
[17181] connection (fd==4) from 130.158.86.150:57753
[17181] read(4,,) 5 bytes, 012
[17181] accepting incoming connections (fd==3) ...
[17181] connection (fd==5) from 130.158.86.1:54488
[17181] read(5,,) 5 bytes, abc
[17181] read(5,,) 5 bytes, def
[17181] read(4,,) 5 bytes, 345
[17181] connection (fd==4) closed.
[17181] connection (fd==5) closed.
^C
$ ![[]](../icons/screen-cursor.gif)
クライアント側（その１）。
$ telnet cosmos10 1231
Trying 130.158.86.150...
Connected to cosmos10.coins.tsukuba.ac.jp.
Escape character is '^]'.
012
012
345
345
^]
telnet> quit
Connection closed.
$
クライアント側（その２）。
$ telnet cosmos10 1231
Trying 130.158.86.150...
Connected to cosmos10.coins.tsukuba.ac.jp.
Escape character is '^]'.
abc
abc
def
def
^]
telnet> quit
Connection closed.
$
図１ 複数のクライアントが接続した時(select())
このプログラムでは、readline() を使っているので、クライアントから \nが
送られてこないと、サーバ全体の処理が停止してしまう。select() の結果、
本来ならブロックしないはずであるが、\n が来たらブロックしてしまう。
readline() の代りにread() を使えば、そのような問題は生じない。しかし、
行単位で何か処理を行うようなサーバを作るには、「クライアントごとに」、
少なくとも１行をためるためのバッファを設ける必要がある。
クライアントが意図的に '\n' を送らないことがある。これも、DoS 攻撃
(Denial of Service攻撃、サービス運用妨害攻撃)の一種である。
その他に、writen() に対して、クライアントが read() しないという攻撃も
ある。
fork版では、クライアントご
とにプロセス（スレッド）が存在するので、安全に fgets() を使うことが
できる。ただし、プロセスをコピーする処理が重たいので、過剰な connect()
による接続要求による DoS 攻撃には弱くなる。(fork() の処理ばかりして、
通常の業務ができなくなる。)
サーバ・プログラムを作成する時には、DoS 攻撃に強いものを作成するように
気をつける。
Last updated: 2013/06/04 21:50:47
Yasushi Shinjo / <yas@cs.tsukuba.ac.jp>