筑波大学 システム情報工学研究科
コンピュータサイエンス専攻, 電子・情報工学系
新城 靖
<yas@is.tsukuba.ac.jp>
このページは、次の URL にあります。
http://www.coins.tsukuba.ac.jp/~syspro/2009/No7.html
あるいは、次のページから手繰っていくこともできます。
http://www.coins.tsukuba.ac.jp/~syspro/2009/
http://www.coins.tsukuba.ac.jp/~yas/
1:
2: /*
3: echo-server-nofork-fdopen.c -- 受け取った文字列をそのまま返すサーバ(fork無し版)
4: ~yas/syspro/ipc/echo-server-nofork-fdopen.c
5: Created on 2004/05/09 19:08:47
6: */
7: #include <stdio.h>
8: #include <stdlib.h> /* exit() */
9: #include <sys/types.h> /* socket(), wait4() */
10: #include <sys/socket.h> /* socket() */
11: #include <netinet/in.h> /* struct sockaddr_in */
12: #include <sys/resource.h> /* wait4() */
13: #include <sys/wait.h> /* wait4() */
14: #include <netdb.h> /* getnameinfo() */
15: #include <string.h> /* strlen() */
16:
17: extern void echo_server( int portno );
18: extern void echo_reply( int com );
19: extern void print_my_host_port( int portno );
20: extern void tcp_peeraddr_print( int com );
21: extern void sockaddr_print( struct sockaddr *addrp, socklen_t addr_len );
22: extern tcp_acc_port( int portno );
23: extern int fdopen_sock( int sock, FILE **inp, FILE **outp );
24:
25: main( int argc, char *argv[] )
26: {
27: int portno ;
28: if( argc != 2 )
29: {
30: fprintf( stdout,"Usage: %s portno\n",argv[0] );
31: exit( -1 );
32: }
33: portno = strtol( argv[1],0,10 );
34: echo_server( portno );
35: }
36:
main() は、引数として、ポート番号を取る。
文字列で受け取ったポート番号を strtol() で int へ変換している。
最後に、echo_server() を呼ぶ。
37: void
38: echo_server( int portno )
39: {
40: int acc,com ;
41: acc = tcp_acc_port( portno );
42: if( acc<0 )
43: exit( -1 );
44: print_my_host_port( portno );
45: while( 1 )
46: {
47: if( (com = accept( acc,0,0 )) < 0 )
48: {
49: perror("accept");
50: exit( -1 );
51: }
52: tcp_peeraddr_print( com );
53: echo_reply( com );
54: }
55: }
56:
tcp_acc_port() は、引数で与えられたポート番号を使って接続要求受付用ポー トを作成し、そのファイル記述子(ソケット)を返す。 このファイル記述子は、クライアント側とは異なり、そまままでは通信に 用いることはできない。 print_my_host_port() は、telnet で接続する時のヒントを表示する。
サーバのプログラムの特徴は、内部に無限ループを持っていることである。 サーバは、普通の状態では、終了しない。
accept() は、接続要求を待つシステムコールである。クライアントから接続 が来るまで、システムコールを実行したまま止まっているように見える。接続 要求が届くと、TCP/IP通信路の開設され、通信用ポートのファイル記述子が返 される。このファイル記述子は、クライアント側と同様に 標準入出力(0,1,2)や open() システム・コールの結果と同じもので、 ファイルに対する write() システムコールや read() システムコールの第一引数とし て使うことができる。つまり、write() システムコールを使うと、ネットワー クに対してデータを送り出すことができ、read() システムコールを使うとネッ トワークからデータを受け取ることができる。最後に不要になったら close() で解放する。
tcp_peeraddr_print() を呼び出し、通信相手(peer)のIPアドレスとポート番号 を表示する。
最後に、echo_reply() を呼び出し、その通信相手についての処理を行う。
57: #define BUFFERSIZE 1024
58:
59: void
60: echo_reply( int com )
61: {
62: char line[BUFFERSIZE] ;
63: int rcount ;
64: int wcount ;
65: FILE *in, *out ;
66:
67: if( fdopen_sock(com,&in,&out) < 0 )
68: {
69: fprintf(stderr,"fdooen()\n");
70: exit( 1 );
71: }
72: while( fgets(line,BUFFERSIZE,in) )
73: {
74: rcount = strlen( line );
75: printf("[%d] received (fd==%d) %d bytes, [%s]\n",getpid(),com,rcount,line );
76: fflush( stdout );
77: fprintf(out,"%s",line );
78: }
79: printf("[%d] connection (fd==%d) closed.\n",getpid(),com );
80: fclose( in );
81: fclose( out );
82: }
83:
この echo_reply() は、特定のクライアント専用のecho サービスを提供する。
クライアントからの要求が続く限り、動作する。
このプログラムでは、 クライアント側 と同様に fdopen_sock() を使って、通信可能なファイル記 述子 com から2つの FILE * を作成している。1つは、入力用、1つは出力 用である。その結果、 高水準入出力ライブラリ を使って通信が行えるようになっている。fprintf() で出力用の FILE * に書 き込むと、ネットワークに対してデータが送り出される。入力用の FILE * に fgets() を行うと、ネットワークからデータを受け取ることができる。
クライアントからの要求は、fgets() で読込んでいる。それを、サーバ側の端 末に printf() で表示している。fflush() は、printf() の内部のバッファ (stdoutのバッファ)に溜っているデータを書き出すものである。
クライアントには、fprintf() で結果を送り返している。こちらは、 fdopen_sock() でバッファリングを抑止しているのでfflush() は不要になって いる。
サーバ側。 サーバは、終了しないので、最後に、^C を押して、割り込みを掛け て終了させる。
注意:全員がポート番号 1231 を使うとプログラムが動かないことがある。
% ls echo-server-nofork-fdopen.c
ls: echo-server-nofork-fdopen.c: No such file or directory
% cp ~yas/syspro/ipc/echo-server-nofork-fdopen.c .
% make echo-server-nofork-fdopen
cc echo-server-nofork-fdopen.c -o echo-server-nofork-fdopen
% ./echo-server-nofork-fdopen
Usage: ./echo-server-nofork-fdopen portno
% ./echo-server-nofork-fdopen 1231
run telnet azalea20 1231
[2192] connection (fd==4) from 130.158.86.40:52013
[2192] received (fd==4) 5 bytes, [123
]
[2192] received (fd==4) 5 bytes, [456
]
[2192] received (fd==4) 5 bytes, [789
]
[2192] connection (fd==4) closed.
^C
%
クライアント側
% telnet azalea20 1231
Trying 130.158.86.40...
Connected to azalea20.coins.tsukuba.ac.jp.
Escape character is '^]'.
123
123
456
456
789
789
^]
telnet> quit
Connection closed.
%
複数のクライアントに対してサービスの同時に提供するには次のような方法が ある。
1:
2: /*
3: http-server-.c -- 常に同じ内容を返す HTTP サーバ(forkなし版)
4: ~yas/syspro/ipc/http-server.c
5: Created on: 2002/06/03 00:48:43
6: */
7: #include <stdio.h>
8: #include <stdlib.h> /* exit() */
9: #include <sys/types.h> /* socket(), wait4() */
10: #include <sys/socket.h> /* socket() */
11: #include <netinet/in.h> /* struct sockaddr_in */
12: #include <sys/resource.h> /* wait4() */
13: #include <sys/wait.h> /* wait4() */
14: #include <netdb.h> /* getnameinfo() */
15: #include <string.h> /* strlen() */
16:
17: extern void http_server( int portno );
18: extern void http_receive_request_and_send_reply( int com );
19: extern int http_receive_request( FILE *in );
20: extern int http_send_reply( FILE *out );
21: extern int http_send_reply_bad_request( FILE *out );
22: extern void print_my_host_port_http( int portno );
23: extern void tcp_peeraddr_print( int com );
24: extern void sockaddr_print( struct sockaddr *addrp, socklen_t addr_len );
25: extern tcp_acc_port( int portno );
26: extern int fdopen_sock( int sock, FILE **inp, FILE **outp );
27: extern char *fgets_chop(char *str, int size, FILE *stream);
28:
29: main( int argc, char *argv[] )
30: {
31: int portno ;
32: if( argc != 2 )
33: {
34: fprintf( stdout,"Usage: %s portno\n",argv[0] );
35: exit( -1 );
36: }
37: portno = strtol( argv[1],0,10 );
38: http_server( portno );
39: }
40:
main() は、引数として、ポート番号を取る。
文字列で受け取ったポート番号を strtol() で int へ変換している。
最後に、http_server() を呼ぶ。
echo-server-nofork-fdopen.cのmain()とほとんど同じ。
41: void
42: http_server( int portno )
43: {
44: int acc,com ;
45: pid_t child_pid ;
46: acc = tcp_acc_port( portno );
47: if( acc<0 )
48: exit( -1 );
49: print_my_host_port_http( portno );
50: while( 1 )
51: {
52: if( (com = accept( acc,0,0 )) < 0 )
53: {
54: perror("accept");
55: exit( -1 );
56: }
57: tcp_peeraddr_print( com );
58: http_receive_request_and_send_reply( com );
59: }
60: }
61:
echo-server-nofork-fdopen.cのecho_server()とほとんど同じ。違いは、次の所だけ。
62: #define BUFFERSIZE 1024
63:
64: void
65: http_receive_request_and_send_reply( int com )
66: {
67: FILE *in, *out ;
68: int err ;
69: if( fdopen_sock(com,&in,&out) < 0 )
70: {
71: fprintf(stderr,"fdooen()\n");
72: exit( 1 );
73: }
74: if( http_receive_request( in ) )
75: {
76: http_send_reply( out );
77: }
78: else
79: {
80: http_send_reply_bad_request( out );
81: }
82: fclose( in );
83: fclose( out );
84: }
85:
この関数では、
echo-server-nofork-fdopen.cのecho_reply() と同様に、
fdopen_sock() を使って、通信可能なファイル記
述子 com から2つの FILE * を作成している。
http_receive_request() を呼び出し、HTTP で要求を受け取っている。 もしエラーがなければ、http_send_reply() を呼び出し、HTTP で OK の応答を送信する。 エラーが有れば、http_send_reply_bad_request() を呼び出し、エラーの 応答を送信する。
86: int
87: http_receive_request( FILE *in )
88: {
89: char requestline[BUFFERSIZE] ;
90: char rheader[BUFFERSIZE] ;
91:
92: if( fgets_chop(requestline,BUFFERSIZE,in) <= 0 )
93: {
94: printf("No request line.\n");
95: return( 0 );
96: }
97: printf("requestline is [%s]\n",requestline );
98: if( strchr(requestline,'<') ||
99: strstr(requestline,"..") )
100: {
101: printf("Dangerous request line found. exit.\n");
102: return( 0 );
103: }
104:
105: while( fgets_chop(rheader,BUFFERSIZE,in) )
106: {
107: if( strcmp(rheader,"") == 0 )
108: break;
109: printf("Ignored: %s\n",rheader );
110: }
111: return( 1 );
112: }
113:
http_receive_request() は、まず、HTTPの最初の行(request line)を
fgets_chop() で読み込む。fgets_chop() は、fgets() と同じだが、
行末の改行 \n や \r を取り除く。
要求行の内容に対して簡単なエラーチェックをしている。次のような パタンが含まれるとエラーにしている。
< が現れる
".." が現れる
最初の要求行に続き、オプションの行を読み出している。 オプションの最後は、空行で終わる。 空行が来るまで、オプションの行を読み出す。
このプログラムでは、オプションは全て無視している。 しかし、HTTP の要求で送られてきたものは、必ず全部読み出す必要がある。
114: int
115: http_send_reply( FILE *out )
116: {
117: fprintf(out,"HTTP/1.0 200 OK\r\nContent-Type: text/html\r\n\r\n");
118: fprintf(out,"<html><head></head><body>hello.</body></html>\n");
119: }
120:
http_send_reply() は、HTTPのヘッダと本体を出力している。 ヘッダは、status line に Content-Typeが続く。 空行以降が本体である。
本体では、HTMLの文書を出力している。
121: int
122: http_send_reply_bad_request( FILE *out )
123: {
124: fprintf(out,"HTTP/1.0 400 Bad Request\r\nContent-Type: text/html\r\n\r\n");
125: fprintf(out,"<html><head></head><body>400 Bad Request</body></html>\n");
126: }
127:
http_send_reply_bad_request() は、HTTPのヘッダと本体を出力している。 ヘッダは、status line (エラー)に Content-Typeが続く。 空行以降が本体である。
本体では、HTMLの文書を出力している。
\n や
\r を削除する。
サーバ側。 サーバは、終了しないので、最後に、^C を押して、割り込みを掛け て終了させる。
注意:全員がポート番号 1231 を使うとプログラムが動かないことがある。
% ls http-server.c
ls: http-server.c: No such file or directory
% cp ~yas/syspro/ipc/http-server.c .
% make http-server
cc http-server.c -o http-server
% ./http-server
Usage: ./http-server portno
% ./http-server 1231
open http://azalea20:1231/index.html
[2595] connection (fd==4) from 130.158.83.140:51617
requestline is [GET /index.html HTTP/1.1]
Ignored: Host: azalea20.coins.tsukuba.ac.jp:1231
Ignored: User-Agent: Mozilla/5.0 (Macintosh; U; Intel Mac OS X 10.5; ja-JP-mac; rv:1.9.0.10) Gecko/2009042315 Firefox/3.0.10
Ignored: Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8
Ignored: Accept-Language: ja,en;q=0.7,en-us;q=0.3
Ignored: Accept-Encoding: gzip,deflate
Ignored: Accept-Charset: ISO-2022-JP,utf-8;q=0.7,*;q=0.7
Ignored: Keep-Alive: 300
Ignored: Connection: keep-alive
[2595] connection (fd==4) from 130.158.83.140:51618
requestline is [GET /favicon.ico HTTP/1.1]
Ignored: Host: azalea20.coins.tsukuba.ac.jp:1231
Ignored: User-Agent: Mozilla/5.0 (Macintosh; U; Intel Mac OS X 10.5; ja-JP-mac; rv:1.9.0.10) Gecko/2009042315 Firefox/3.0.10
Ignored: Accept: image/png,image/*;q=0.8,*/*;q=0.5
Ignored: Accept-Language: ja,en;q=0.7,en-us;q=0.3
Ignored: Accept-Encoding: gzip,deflate
Ignored: Accept-Charset: ISO-2022-JP,utf-8;q=0.7,*;q=0.7
Ignored: Keep-Alive: 300
Ignored: Connection: keep-alive
[2595] connection (fd==4) from 130.158.83.140:51619
requestline is [GET /favicon.ico HTTP/1.1]
Ignored: Host: azalea20.coins.tsukuba.ac.jp:1231
Ignored: User-Agent: Mozilla/5.0 (Macintosh; U; Intel Mac OS X 10.5; ja-JP-mac; rv:1.9.0.10) Gecko/2009042315 Firefox/3.0.10
Ignored: Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8
Ignored: Accept-Language: ja,en;q=0.7,en-us;q=0.3
Ignored: Accept-Encoding: gzip,deflate
Ignored: Accept-Charset: ISO-2022-JP,utf-8;q=0.7,*;q=0.7
Ignored: Keep-Alive: 300
Ignored: Connection: keep-alive
^C
%
クライアント側
% open http://azalea20:1231/index.html
Firefox で "http://azalea20:1231/index.html" を開く。
requestline is [...])
Ignored: ...)
% ./http-response /index.html
HTTP/1.0 200 OK
Content-Type: text/html
<HTML>
中略
</HTML>
%
この課題では、セキュリティに気をつけなさい。必ず次の条件を満たすように
しなさい。
~/public_html)以下のファ
イルしかアクセスできないようにすること。それには、ファイルを開く
(open(), fopen())時に、頭に
環境変数 HOME の値と "/public_html" を付加
する方法がある。環境変数は、getenv() ライブラリ関数を使うと入手できる。
他の方法としては、プログラムの中に定数として埋め込む方法が考えられる。
なお、~ は、open() システム・
コールや fopen() ライブラリ関数では使えない。~ は、シェルや
emacs が独自にホーム・ディレクトリを調べて置き換えている。
"HTTP/1.0 200 OK<以下省略>" を、ファイルが存在しなければ、
"HTTP/1.0 404 Not Found<以下省略>"1w
を返す。
| Content-Type: | 拡張子 |
|---|---|
| text/html | .html |
| text/plain | .txt |
"HTTP/1.0 200 OK\r\n" の行を fprintf() で stdout に出力する。
Content-Type: の行を fprintf() で stdout に出力する。
"HTTP/1.0 200 OK<以下省略>" のエラー
メッセージを出力する。
なお、この課題は、HTTP の応答を画面(stdout)に出力するが、ネットワーク通 信を一切行わない。
練習問題(703) を拡張して、 バイナリ・ファイルを扱えるようにしなさい。 次の型(Content-Type:)を扱えるようにしなさい。
| Content-Type: | 拡張子 |
|---|---|
| text/html | .html |
| text/plain | .txt |
| image/gif | .gif |
| image/jpeg | .jpeg |
| image/png | .png |
% cat > reqest.data
GET /index.html HTTP/1.0
Accept: image/png,*/*;q=0.5
Accept-Language: ja,en;q=0.7,en-us;q=0.3
^D
% ./http-request-analyze < reqest.data
/index.html
%
このプログラムは、次のような動作を行う。
なお、この課題は、HTTP の要求を標準入力(stdin)から読むが、ネットワーク 通信を一切行わない。
この課題を行う場合、次のファイルに含まれる関数を利用してもよい。
~yas/syspro/string/string-split.c
int string_split( char *str, char del, int *countp, char ***vecp )
void free_string_vector( int count, char **vec )
string_split() で得た vec のメモリを解放する。
int count;
char **vec;
int i ;
str = "GET /index.html HTTP/1.0";
if( string_split( str, ' ', &count, &vec ) < 0 )
{
perror("string_split-malloc");
exit( 1 );
}
for( i=0 ; i< count; i++ )
printf("%d: %s\n", i, vec[i] );
free_string_vector( count, vec );
まず、 練習問題(704) を実施しなさい。 次に、 練習問題(705) を実施しなさい。 そして、その時作成した関数を用いて、HTTP サーバを作成しなさい。 この課題を行う場合、http-server.c に含まれる関数を利用してもよい。
実際の WWW ブラウザ (Firefoxなど)で、動作を確認しなさい。telnet だけで は、きちんと HTTP のプロトコルに従っているか確認できないので、不十分で ある。
GET /?month=6&year=2009 HTTP/1.0
カレンダの出力については、cal コマンドを実行した結果を用いても良い。こ
れに対して、HTTP で結果を返す。Content-Type: としては、text/plain に
するか、text/html で <PRE></PRE>を使う方法が
考えられる。その他の手法でもよい。
このサーバを実行するための HTML の form を用意しなさい。
実際の WWW ブラウザ (Firefoxなど)で、動作を確認しなさい。telnet だけで は、きちんと HTTP のプロトコルに従っているか確認できないので、不十分で ある。
.cgi のプログラムを CGI と見なし、プログラムを実行し、そ
の結果をクライアントに返しなさい。
実際の WWW ブラウザ (Firefoxなど)で、動作を確認しなさい。telnet だけで は、きちんと HTTP のプロトコルに従っているか確認できないので、不十分で ある。
クライアントから送られてくるデータを、コマンドの標準入力に接続して実行 するプログラムを作りなさい。たとえば、次のようなコマンドを実行すること を考える。
% ./spipe-last 1231 head -5
<クライアントから送られてきた文字列のうち、先頭の5行だけがサーバの画面に表示される>
%
spipe-last は、指定されたポート番号で tcp_acc_port() を行う。
クライアントからの接続要求を受け付けた後、不要なポートを閉じ、標準出力を切
り替えて、コマンドラインから指定されたコマンドを実行する。
すなわち、dup(), dup2(), close() などで、標準出力を切り替えて、
execve() などで、プログラムを実行する。
コマンドを実行したらそのまま終了する。
クライアントとしては、telnet を用いてもよい。 または、以下の spipe-first を用いることもできる。
この課題では、fork() を行わないことを推奨する。 TCP/IP なら本来双方向で使えるが、この練習問題では単方向だけを 使うことで、パイプの機能を代替する。
また、fork() とパイプを使う実現方法もある。コマンドを実行するする時に fork() して実行し、その標準入力をパイプにして、TCP/IP で受け取ったデー タをパイプに書き込んでもよい。
% ./spipe-first hostname port ls -l
spipe-first は、指定されたホスト名とポート番号でtcp_connect() を行う。
不要なポートを閉じ、標準出力を切り替えた後、指定されたコマンドを実行す
る。すなわち、dup(), dup2(), close() などで、標準入出力を切り替えて、
execve() などで、プログラムを実行する。
コマンドを実行したらそのまま終了する。
この課題では、spipe-last と同様に、fork() を行わないことを推奨する。
% ./spipe-middle myport serverhost serverport sort +4
spipe-middle は、第2引数と第3引数で指定されたサーバにtcp_connect() で接
続要求を行う。
tcp_acc_port() により、第1引数で指定された
ポート番号で接続受付用ポートを作成する。
spipe-first から接続要求を受け取ると、
不要なポートを閉じ、標準入出力を切り替える。そして、第4引数以降で指定さ
れたコマンドを実行する。
finger サーバを作成しなさい。これは、受け取った文字列を引数にして、 finger コマンドを実行するとよい。そして、実行結果を、接続先に返すよう にするとよい。
finger コマンドのプロセスと finger サーバの間は、パイプで接続しなさい。 今までの例題で利用した方法を組み合わせることで実現することができるはず である(pipe(),fork(),dup(),close(),execve()など)。popen() ライブラリ 関数を利用してもよい。
finger コマンドのプロセスと finger サーバ間をパイプで結ぶ代わりに、 finger コマンドを exec する前に、配管工事をして、標準出力(1)をTCP/IPの ストリームに接続する方法もある。
受け取った文字列をそのまま popen() や system() などに渡すのは危険である。 というのも、これらの引数は、シェル(/bin/sh)が解釈するからである。 popen() や system() を使う場合には、 finger コ マンドが受付けるのに相応しいもの( isalpha() や isdigit() の並び)かどう かを検査しなさい。もし、シェルが解釈する特殊な文字列(|;<> など)が含まれていると、意図しないプログラムが実行させられることがある。
fork() や execve() を用いて直接 /usr/bin/finger を実行する方法はシェル を経由しないので、比較的安全である。
getpwnam() ライブラリ関数や utmp ファイルを用いて、finger コマンドと似たような 動きを実現してもよい。
HTTP proxy 作りなさい。次の機能を、1つ以上付けなさい。
上の tcp_peeraddr_print() は、IP アドレスを数字で表示していた。 これを、ホスト名で表示するようにしなさい。
% ./echo-server-fork 1231
bind: Address already in use
port number 1231 is already used. wait a moment or kill another program.
%
このエラーは、実際に同じポート番号を別のプロセスが使っている時にも出る
が、既に以前に使っていたプロセスが終了している時にも出ることがある。
後者の場合、次のオプションを付けると、この状態が緩和されることがある。
setsockopt( sock, SOL_SOCKET, SO_REUSEADDR, 0, 0);この効果を確かめなさい。
また、同じポート番号の再利用を制限している理由を考えなさい。
実際の WWW ブラウザ (Firefoxなど)で、動作を確認しなさい。telnet だけで は、きちんと HTTP のプロトコルに従っているか確認できないので、不十分で ある。
実際の WWW ブラウザ (Firefoxなど)で、動作を確認しなさい。telnet だけで は、きちんと HTTP のプロトコルに従っているか確認できないので、不十分で ある。