在Java TCP中接受多個客戶端，並讓每個客戶端等待5分鐘

Question

我正在嘗試構建一個TCP服務器在接受10個客戶端的java中，每個客戶端都應該在線程中處理，以免客戶端正在等待。每個線程都會收到客戶端並讓他等待5分鐘。

這是我迄今爲止的代碼;

公共類ThreadServer {

static class ServerThread implements Runnable { 
Socket client = null; 
public ServerThread(Socket c) { 
    this.client = c; 
} 
public void run() { 
    try { 
     System.out.println("Connected to client : "+client.getInetAddress().getHostName()); 
     client.close(); 
    } catch (Exception e) { 
     System.err.println(e.getMessage()); 
    } 
} 
} 
public static void main(String args[]) { 
    try { 
     ServerSocket server = new ServerSocket(8787); 
     while (true) { 
      Socket p = server.accept(); 
      new Thread(new ServerThread(p)).start(); 
     } 
    } catch (Exception ex) { 
     System.err.println("Error : " + ex.getMessage()); 
    } 
} 

}

Answer 1

這可以很容易地與這樣的ScheduledExecutorService的解決：

public class RespondLater implements Runnable { 

    final Socket client; 

    public RespondLater(final Socket c) { 
    this.client = c; 
    } 

    public void run() { 
    try { 
     System.out.println("5 minutes later on client: " + client.getInetAddress().getHostName()); 
     // do whatever you want with the client 5 minutes later here 
    } catch (Exception e) { 
     System.err.println(e.getMessage()); 
    } finally { 
     try { 
     client.close(); 
     } catch (Exception ex) { 
     } 
    } 
    } 

    public static void main(String[] args) { 
    final ScheduledExecutorService executor = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors()); 
    try (final ServerSocket server = new ServerSocket(8787)) { 
     while (true) { 
     final Socket p = server.accept(); 
     executor.schedule(new RespondLater(p), 5, TimeUnit.MINUTES); 
     } 
    } catch (Exception ex) { 
     System.err.println("Error : " + ex.getMessage()); 
    } finally { 
     executor.shutdownNow(); 
    } 
    } 
} 

請注意，有從未超過Runtime.getRuntime().availableProcessors()線程活躍，所以你可以讓這個構造句柄處理成千上萬的連接。

但是，我認爲大多數客戶會在達到5分鐘之前超時。