システムプログラム（第8回）: スレッドによる複数のクライアントに対するサービスの同時提供(Java版)

                                       筑波大学 システム情報系 情報工学域
                                       新城 靖
                                       <yas@cs.tsukuba.ac.jp>

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

EchoServer.java

 $ diff -c  EchoServerSingle.java EchoServer.java
 *** EchoServerSingle.java       2014-07-29 08:10:27.000000000 +0900
 --- EchoServer.java     2014-07-31 13:57:42.000000000 +0900
 ***************
 *** 1,26 ****
   /*
 !   EchoServerSingle.java -- 文字列を送受信するサーバ(TCP/IP, Java版, スレッドなし)
 !   ~yas/syspro/ipc/EchoServerSingle.java
 !   Created on 2004/05/09 20:00:24
   */

   import java.net.*;
   import java.io.*;

 ! class EchoServerSingle
   {
	 public static void main(String argv[]) throws IOException
	 {
		 if( argv.length != 1 )
		 {
 !                       stderr.printf("Usage: %% java EchoServerSingle port\n");
			 System.exit( -1 );
		 }
		 int portno = Integer.parseInt( argv[0] );
 !               echo_server_single( portno );
	 }

 !       public static void echo_server_single( int portno ) throws IOException
	 {
		 ServerSocket acc = new ServerSocket( portno );
		 print_my_host_port( portno );
 --- 1,26 ----
   /*
 !   EchoServer.java -- 文字列を送受信するサーバ(TCP/IP, Java版)
 !   ~yas/syspro/ipc/EchoServer.java
 !   Created on 2004/02/14 16:22:13
   */

   import java.net.*;
   import java.io.*;

 ! class EchoServer
   {
	 public static void main(String argv[]) throws IOException
	 {
		 if( argv.length != 1 )
		 {
 !                       stderr.printf("Usage: %% java EchoServer port\n");
			 System.exit( -1 );
		 }
		 int portno = Integer.parseInt( argv[0] );
 !               echo_server( portno );
	 }

 !       public static void echo_server( int portno ) throws IOException
	 {
		 ServerSocket acc = new ServerSocket( portno );
		 print_my_host_port( portno );
 ***************
 *** 29,36 ****
			 stdout.printf("accepting incoming connections (hash== %s) ...\n", acc.hashCode());
			 Socket com = acc.accept();
			 tcp_peeraddr_print( com );
 !                       EchoServerWorker esw = new EchoServerWorker(com);
 !                       esw.run();
		 }
	 }
	 public static void print_my_host_port( int portno ) throws UnknownHostException
 --- 29,36 ----
			 stdout.printf("accepting incoming connections (hash== %s) ...\n", acc.hashCode());
			 Socket com = acc.accept();
			 tcp_peeraddr_print( com );
 !                       Thread th = new Thread( new EchoServerWorker(com) );
 !                       th.start();
		 }
	 }
	 public static void print_my_host_port( int portno ) throws UnknownHostException
 $ 

実行例

$ cp ~yas/syspro/ipc/EchoServer{,Worker}.java . 
$ ls *java 
EchoServer.java         EchoServerWorker.java
$ javac EchoServer.java EchoServerWorker.java 
$ ls *class 
EchoServer.class        EchoServerWorker.class
$ java  EchoServer 1231 
run telnet crocus39.coins.tsukuba.ac.jp 1231
accepting incoming connections (hash== 785360174) ...
connection (hash== 1113949956) from 130.158.86.247:50100
accepting incoming connections (hash== 785360174) ...
received (com hash==1113949956) 5 characters, [012
]
connection (hash== 967831570) from 130.158.86.248:49708
accepting incoming connections (hash== 785360174) ...
received (com hash==967831570) 5 characters, [abc
]
received (com hash==967831570) 5 characters, [def
]
received (com hash==1113949956) 5 characters, [345
]
connection (com hash==1113949956) closed.
connection (com hash==967831570) closed.
^C
$ 

$ telnet crocus39.coins.tsukuba.ac.jp 1231 
Trying 130.158.86.249...
Connected to crocus39.coins.tsukuba.ac.jp.
Escape character is '^]'.
012
012
345
345
^]
telnet> ^D
Connection closed.
$ 

$ telnet crocus39.coins.tsukuba.ac.jp 1231 
Trying 130.158.86.249...
Connected to crocus39.coins.tsukuba.ac.jp.
Escape character is '^]'.
abc
abc
def
def
^]
telnet> ^D
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.
$