Java - 各クライアントを別々のスレッドで処理するサーバー？

Question

MessageServerクラスをセットアップして、別のリクエストで各クライアントにサービスを提供しようとしています（これはかなり直感的です）。

どうすればよいですか？

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

public class MessageServer { 

public static final int PORT = 6100; 

public static void main(String[] args) { 

    Socket client = null; 
    ServerSocket sock = null; 
    BufferedReader reader = null; 

    try { 
     sock = new ServerSocket(PORT); 
     // now listen for connections 
     while (true) { 
      client = sock.accept(); 

      reader = new BufferedReader(new InputStreamReader(client.getInputStream())); 

      Message message = new MessageImpl(reader.readLine()); 

      // set the appropriate character counts 
      message.setCounts(); 

      // now serialize the object and write it to the socket 
      ObjectOutputStream soos = new ObjectOutputStream(client.getOutputStream()); 
      soos.writeObject(message); 
      System.out.println("wrote message to the socket"); 

      client.close(); 
     } 
    } 
    catch (IOException ioe) { 
      System.err.println(ioe); 
    } 


} 

}

Answer 1

申し訳ありませんが、あなたの質問にはあまり意味がありません。

通常の方法で「要求」という用語を使用している場合、クライアントはサーバーに要求を送信し、サーバーは各要求を処理します。サーバーが要求を別々に（ある意味で）サービスしないのは、単純に意味がありません。

おそらく、あなたは何か違うことを求めています。 （それぞれのクライアントのリクエストを別のスレッドで処理するという意味ですか？）何を意味していても、用語を確認してください。あなたがExecutorService APIを使用して、別のスレッドで要求を実行について話していることを考えると

---

は良い選択です。ワーカースレッドの数に上限を設定できる実装クラスを使用します。そうしないと、オーバーロードの結果、スレッドの数が多くなり、サーバーの速度が遅くなる問題が発生します。 （新しいスレッドを作成するのは安価ではありません。リサイクルしなければなりません）

また、は、要求キューを持たないようにexecutorを構成することを検討してください。使用可能なワーカーがない場合、エグゼキュータ・サービスがジョブをサブミットしようとしているスレッドをブロックするようにします。オペレーティングシステムが着信接続/要求をServerSocketレベルにキューさせます。要求を内部的にキューに入れると、クライアント側がすでにタイムアウト/放棄した要求を処理して時間を無駄にしている状況に陥ることがあります。