자바의 쓰레드와 서버

Question

Java에서 쓰레드가 어떻게 동작하는지 알았을 때, 나는 틀렸어.이 서버가 클라이언트를 청취하고 동시에 콘솔에 텍스트를 입력 할 수있게하고 싶다.

public class MultiThreadChatServerSync implements Runnable{ 

    private static ServerSocket serverSocket = null; 
    private static Socket clientSocket = null; 
    private static final int maxClientsCount = 10; 
    private static final clientThread[] threads = new clientThread[maxClientsCount]; 

    public static void main(String args[]) { 
     int portNumber = 2222; 
     if (args.length < 1) { 
      System.out.println("Usage<portNumber>\n"); 

     } else { 
      portNumber = Integer.valueOf(args[0]).intValue(); 
     } 

     try { 
      serverSocket = new ServerSocket(portNumber); 
     } catch (IOException e) { 
      System.out.println(e); 
     } 
     //I thought this was the answer and it would run in the backround 
     (new Thread(new MultiThreadChatServerSync())).start(); 


    } 
    public void run() { 

     while (true) { 
      try { 
       clientSocket = serverSocket.accept(); 
       int i = 0; 
       for (i = 0; i < maxClientsCount; i++) { 
        if (threads[i] == null) { 
         (threads[i] = new clientThread(clientSocket, threads)).start(); 
         break; 
        } 
       } 
       if (i == maxClientsCount) { 
        PrintStream os = new PrintStream(clientSocket.getOutputStream()); 
        os.println("Server too busy. Try later."); 
        os.close(); 
        clientSocket.close(); 
       } 
      } catch (IOException e) { 
       System.out.println(e); 
      } 
     } 

    } 
} 

Please. 나는 무엇이 있습니까?

Answer 1

질문은 명확하지 않지만 콘솔에서 사용자 입력을 받아들이는 동안 주 스레드에서 서버를 실행하고 있다는 것이 좋습니다. 사용자 입력을 받아들이 길 원한다면 다른 스레드가 유일한 목적은 들어오는 연결을 수신하고 받아들이는 것입니다.

즉 당신이보고있는 건축물의 종류가 있어야한다 (의사 코드)

서버 스레드 :

public void run() { 
    while (connections < maxConnections) { 
     conn = accept connection 

     // pass the new connection to a seperate thread 
     sht = new ServerHelperThread(conn) 
     sht.start() 
     connections++ 
    } 
} 

개별 클라이언트 처리하는 서버 도우미 스레드 :

public ServerHelperThread(conn) { 
    this.conn = conn; 
} 

public void run() { 
    while(some condition) { 
     communicate with client 
    } 
    conn.close() 
} 

주류 :

public static void main(String[] args) { 
    new ServerThread().start 
    accept input from the console 
}