單客戶端到多客戶端支持：在java中的多線程轉換

Question

所以我不知道誰去創建一個多線程服務器。我的客戶端和服務器一起工作良好，但無法正確引入多個客戶端。這裏是我的服務器代碼：

package dod; 
import java.net.*; 
import java.io.*; 

import dod.game.GameLogic; 

public class Server{ 
    Server(GameLogic game, int port) throws IOException{ 
     ServerSocket ss = null; 
     Socket sock = null; 
     try{ 
      ss = new ServerSocket(4444);//port no. 
      while(true){ 
       try{ 
        sock = ss.accept();  
        ClientThread thread = new ClientThread(game, sock); 
        System.out.println("Adding new player..."); 
        thread.run(); 
       }catch(final Exception e) { 
        System.err.println(e.getMessage()); 
        System.exit(1); 
       } 
      } 
     }catch(Exception d){ 
      System.out.println(d); 
     }finally{ 
      if(ss!=null){ 
       ss.close(); 
      } 
     } 
    } 
} 

這裏是我的線程類：

package dod; 

import java.io.*; 
import java.net.Socket; 
import dod.game.GameLogic; 
import dod.game.PlayerListener; 

public class ClientThread extends CommandLineUser implements PlayerListener, Runnable{ 
    DataInputStream in; 
    PrintStream out; 

    // The game which the command line user will operate on. 
    // This is private to enforce the use of "processCommand". 
    ClientThread(GameLogic game, Socket sock) { 
     super(game); 
     try{ 
      in = new DataInputStream(sock.getInputStream()); 
      out = new PrintStream(sock.getOutputStream()); 
     }catch(IOException ioe){ 
      System.out.println(ioe); 
     } 
     game.addPlayer(this); 
    } 

    /** 
    * Constantly asks the user for new commands 
    */ 
    public void run() { 
     System.out.println("Added new human player."); 
     // Keep listening forever 
     while(true){ 
      try{ 
       // Try to grab a command from the command line 
       final String command = in.readLine();; 
       // Test for EOF (ctrl-D) 
       if(command == null){ 
        System.exit(0); 
       } 
       processCommand(command); 

      }catch(final RuntimeException e){ 
       System.err.println(e.toString()); 
       System.exit(1); 
      } catch (final IOException e) { 
       System.err.println(e.toString()); 
       System.exit(1); 
      } 
     } 
    } 

    /** 
    * Outputs a message to the player 
    * 
    * @param message 
    *   the message to send to the player. 
    */ 
    public void outputMessage(String message) { 
     out.print(message); 
    } 

} 

不要求新的代碼，例如，只需要指針，以什麼我需要做的有在多個客戶端連接同時！感謝任何有幫助的人！

Answer 1

要開始，請在服務器中添加新線程（clientThread），並在其上調用start（） - 因爲所有事情都發生在同一線程上。

Answer 2

public class Server{ 
    Server(GameLogic game, int port) throws IOException{ 
     ServerSocket ss = null; 
     Socket sock = null; 
     try{ 
      ss = new ServerSocket(4444);//port no. 
      while(true){ 
       try{ 
        sock = ss.accept();  
        ClientThread thread = new ClientThread(game, sock); 
        System.out.println("Adding new player..."); 
        thread.start(); //you have to use start instead of run method to create multi thread application. 
       }catch(final Exception e) { 
        System.err.println(e.getMessage()); 
        System.exit(1); 
       } 
      } 
     }catch(Exception d){ 
      System.out.println(d); 
     }finally{ 
      if(ss!=null){ 
       ss.close(); 
      } 
     } 
    } 
} 

您必須使用start而不是run方法來創建多線程應用程序。

如果您想發送有關新連接的消息，則必須在列表中保存sock，並在新連接接受時將消息發送到列表中的所有套接字對象。 （服務器廣播到所有連接的插座）

我希望它有幫助。