Java 클라이언트 - 서버/하나의 스레드 다중 클라이언트

Question

우선 무엇보다 혼란스럽지 않고 설명하는 방법이 너무 명확하지 않으므로 간단하게하려고 노력할 것입니다. 2 명의 플레이어 게임의 일부로 2 명의 클라이언트를 "쌍으로"묶는 서버 응용 프로그램이 있습니다. 첫 번째 클라이언트가 서버에 연결될 때 소켓 연결이 수락되면 해당 클라이언트와 함께 새 ClientProtocol 스레드가 만들어 지지만 시작되지는 않습니다. 다른 클라이언트가 서버에 연결하면 이전 스레드에 추가되고 스레드가 시작됩니다. 스레드는 두 개의 입력 스트림과 두 개의 출력 스트림 (각 클라이언트에 하나씩)을 알고 있습니다. 그러나 클라이언트 또는 서버 측에서 읽으려고하면 아무 일도 일어나지 않습니다. 이것은 단일 스레드에서 단일 클라이언트에 대해 잘 작동합니다.

서버 측 (메인 스레드)

public static Queue<ContestProtocol> contesters; 

public static void main(String[] args) throws IOException { 
    ServerSocket serverSocket = null; 
    contesters = new LinkedList<ContestProtocol>(); 

    try { 
     serverSocket = new ServerSocket(4444); 
    } catch (IOException e) { 
     System.err.println("Could not listen on port: 4444."); 
     System.exit(-1); 
    } 

    while (true) { 
     Socket socket = serverSocket.accept(); 

     ObjectInputStream ois; 
     ObjectOutputStream oos; 

     try { 
      ois = new ObjectInputStream(socket.getInputStream()); 
      oos = new ObjectOutputStream(socket.getOutputStream()); 

      synchronized (contesters) { 
       if (contesters.size() == 0) { 
        Contester contester1 = new contester(ois, oos); 
        contesters.add(new ContestProtocol(contester1)); 
       } else { 
        Contester contester2 = new Contester(ois, oos); 
        contesters.poll().hook(contester2).start(); 
       } 
      } 
     } 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 
} 

서버 측 (ContestProtocol)

private Contester contester1, contester2; 

public ContestProtocol(Contester contester1) { 
    super("ContestProtocol"); 
} 

public ContestProtocol hook(Contester contester2) { 
    this.contester2 = contester2; 
    return this; 
} 

public void run() { 
    try { 
     contester1.getOOS().writeInt(-1); 
     contester2.getOOS().writeInt(-2); 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 
} 

서버 측 (contester) :

public Contester(ObjectInputStream ois, ObjectOutputStream oos) { 
    this.ois = ois; 
    this.oos = oos; 
} 

public ObjectInputStream getOIS() { 
    return ois; 
} 

public ObjectOutputStream getOOS() { 
    return oos; 
} 

클라이언트 측 여기에 몇 가지 코드는 다음과 같습니다

try { 
      socket = new Socket(serverAddr, 4444); 
      oos = new ObjectOutputStream(socket.getOutputStream()); 
      ois = new ObjectInputStream(socket.getInputStream()); 
      int selectedChampion = ois.readInt(); 
} catch (Exception e) { 
       e.printStackTrace(); 
} 

ContestProtocol 스레드는 문제없이 실행을 완료하지만 두 클라이언트는 모두 readInt()에서 중단됩니다. 나는 왜 그런지 이해하지 못한다.

Answer 1

자원에 액세스 할 때 뮤텍스 또는 세마포어 문제가 발생해야합니다. 사용중인 스트림 (이 경우 출력 스트림과 입력 스트림)은 동일한 리소스를 읽고 쓰는 것이 좋습니다. 이 모든 프로세스는 하나의 스레드가 계속 될 때 발생하기 때문에 스레드가 서로 인터럽트하고 서로 대기 프로세스를 작성합니다.
하나의 솔루션은 스트림 객체에 이벤트 라이저를 등록하여 하나가 완료 될 때마다 다른 객체 만 시작되도록하는 것입니다.

Answer 2

클라이언트 측 입력 스트림을 루프해야합니다.

while(true){ 
if(ois.avaible() > 0) 
ois.readInt(); 
} 

팁 : 더 나은 성능을 얻으려면 netty로 비동기 네트워킹을 살펴보십시오.