3. サーバソケット

この節ではソケットを利用したサーバアプリケーションの作成方法を解説します。マルチスレッドで複数の接続を処理できるサーバの作成方法についても解説します。

3.1. サーバソケット

前節では、新しいSocketインスタンスを作成しサーバに接続するクライアントアプリケーションを作成しました。それでは、クライアントからの接続を受け付けるサーバはどのようにして実現するのでしょうか。接続を受け付けるためにはServerSocketクラスを用います。

クライアントのアプリケーションは、サーバに接続したいときにいつでも接続できます。接続先を指定してSocketのインスタンスを作成すれば、ただちにサーバへの接続が完了していました。しかし、サーバ側は、クライアントがいつ接続を要求してくるかわかりません。そのため、クライアントが接続してくるのをずっと待っていなければいけません。

接続を受け付けられる状態で待機するには、acceptメソッドを用います。acceptメソッドを呼び出すと、ServerSocketは接続待ちの状態となり、クライアントが接続してくるまでプログラムはそれ以上先に進みません。クライアントが接続してくると、acceptメソッドは、そのクライアントと接続されたソケットを返して終了します。サーバアプリケーションはここで取得したソケットを利用してクライアントとの通信処理を行います。

それでは、前節で利用したEchoServerクラスのソースファイルを見てみましょう。　　

リスト EchoServer.java

 1: import java.net.Socket;
 2: import java.net.ServerSocket;
 3: import java.io.BufferedReader;
 4: import java.io.InputStreamReader;
 5: import java.io.PrintWriter;
 6: import java.io.IOException;
 7: 
 8: public class EchoServer {
 9: 
10:   public static final int ECHO_PORT = 10007;
11: 
12:   public static void main(String args[]) {
13:     ServerSocket serverSocket = null;
14:     Socket socket = null;
15:     try {
16:       serverSocket = new ServerSocket(ECHO_PORT);
17:       System.out.println("EchoServerが起動しました(port="
18:                          + serverSocket.getLocalPort() + ")");
19:       socket = serverSocket.accept();
20:       System.out.println("接続されました "
21:                          + socket.getRemoteSocketAddress() );
22:       BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
23:       PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
24:       String line;
25:       while ( (line = in.readLine()) != null ) {
26:         System.out.println("受信: " + line);
27:         out.println(line);
28:         System.out.println("送信: " + line);
29:       }
30:     } catch (IOException e) {
31:       e.printStackTrace();
32:     } finally {
33:       try {
34:         if (socket != null) {
35:           socket.close();
36:         }
37:       } catch (IOException e) {}
38:       try {
39:         if (serverSocket != null) {
40:           serverSocket.close();
41:         }
42:       } catch (IOException e) {}
43:     }
44:   }
45: 
46: }

16行目で、待ち受けポートを指定して新しいサーバソケットを生成しています。

16:       serverSocket = new ServerSocket(ECHO_PORT);

19行目でacceptメソッドを呼び出し、クライアントからの接続待機状態に入ります。クライアントからの接続要求があると、socketにはクライアントとの通信に利用できるSocketのインスタンスが代入されます。

19:       socket = serverSocket.accept();

Socketが利用できるようになると、あとはクライアントアプリケーションと同じように入出力ストリームを取得して通信処理を行います。25〜29行のループで通信処理を記述しています。このサーバはクライアントから送られてきた文字列をそのまま送り返すだけの処理を行います。

25:       while ( (line = in.readLine()) != null ) {
26:         System.out.println("受信: " + line);
27:         out.println(line);
28:         System.out.println("送信: " + line);
29:       }

---

---