Java ObjectInputStream не будет читать объект?

Question

У меня возникла проблема, когда я могу подключиться к серверу ServerSocket и отправлять объекты (точнее, пользовательский класс пакета), но когда я использую метод readObject(), мой код зависает и не читает никаких пакетов ,

Вот код клиента:

public class ObjectReaderThread extends Thread { 

public void run() { 

    Object obj = null; 

    while(!ClientTest.clientTest.socket.isClosed()) { 

     try { 

      obj = ClientTest.serverReader.reader.readObject(); 

      System.out.println("Packet recieved."); 

     } catch(Exception ex) { ex.printStackTrace(); System.exit(-1); } 

    } 

} 

Как вы можете видеть, я использую отдельный поток для моего цикла readObject. Может ли кто-нибудь помочь мне определить, что является неправильным? Если вам нужен еще один код, скажите мне, и я могу его опубликовать. Также обратите внимание, что исключение/ошибка не предоставляется. Благодаря!

EDIT: Вот код отправки пакета:

public void sendNextPacketInQueue() { 
    Iterator<Integer> queue = packetQueue.keySet().iterator(); 
    try { 

     if(outputStreamInitialized) ; 

     if(queue.hasNext()) { 

      int key = queue.next(); 
      Packet packet = packetQueue.get(key); 

      if(packet.getLocation().equals(PacketLocation.ALL) && GlobalVars.onlinePlayers.size() > 0) { 

       for(int i = 1; i <= GlobalVars.onlinePlayers.size(); i++) { 
        Player player = GlobalVars.onlinePlayers.get(i); 
        ObjectOutputStream out = new ObjectOutputStream(player.getOutputStream()); 
         out.writeObject(packet); 

        if(GlobalVars.debugOutput) GlobalClassVars.window.printToLog("Packet sent to " + player.getUsername()); 
       } 
      } 
      else { 
       if(GlobalVars.debugOutput) GlobalClassVars.window.printToLog("Not enough players online to send packet to."); 
      } 

      packetQueue.remove(key); 
      if(GlobalVars.debugOutput) GlobalClassVars.window.printToLog("Packet removed."); 

     } 

    } catch(Exception ex) { ex.printStackTrace(); } 
} 

Это постоянно работает в цикле сервера:

while(!serverSocket.isClosed()) { 

     ... 

     this.sendNextPacketInQueue(); 

} 

Answer 1

Я много сделал с этим неправильно. Во-первых, я каждый раз создавал новый ObjectOutputStream. Во-вторых, я получал игрока из списка, используя int вместо имени пользователя.

Даже не спрашивайте, как я сделал эти глупые ошибки ...

Answer 2

Ваш клиентский код блокировки на readObject вызова. Он ждет, пока следующий объект не станет доступен в сокете. Хотя вы пишете объект на сокете сервера, ваш клиент не получит его сразу из-за буфера сокета. Чтобы клиент мог немедленно получить объект, вам необходимо очистить поток на стороне сервера после записи каждого объекта. В sendNextPacketInQueue метод добавить out.flush() звонок после out.writeObject звонок.

out.writeObject(packet); 
out.flush();