java.io.EOFException (с проблемами с закрывающими потоками)

Question

Получил простое клиент-серверное приложение только с входом/выходом из системы. Когда я нажимаю на соединение, он работает отлично, но проблема возникает после попытки отключения (получение EOFException на стороне клиента). Im почти уверен, что это связано с плохим закрытием потока. Любые намеки?

java.io.EOFException 
    at java.io.DataInputStream.readByte(DataInputStream.java:98) 
    at java.io.ObjectInputStream.nextTC(ObjectInputStream.java:506) 
    at java.io.ObjectInputStream.readNonPrimitiveContent(ObjectInputStream.java:778) 
    at java.io.ObjectInputStream.readObject(ObjectInputStream.java:2006) 
     at java.io.ObjectInputStream.readObject(ObjectInputStream.java:1963) 
    at com.mtm.ClientConnection.disconnect(ClientConnection.java:54)** 

класса Клиент:

public class ClientConnection implements Admin{ 

    public ObjectInputStream in; 
    public static ObjectOutputStream out; 
    public Socket socket; 

    public void connect(){ 

     String host = IP; 
     int port = PORTO; 

     try {  
      socket = new Socket (host,port); 
      out = new ObjectOutputStream(socket.getOutputStream()); 
      in = new ObjectInputStream(socket.getInputStream());   

      MSG_Login login = new MSG_Login();   
      login.setID(DeviceId.getId().toString()); 
      send(login); 

      Object c1 = in.readObject(); 
      if(c1 instanceof MSG_Login){ 
       Thread thread = new ClientThread(this); 
       thread.start(); 
      } 

     } 
     catch (UnknownHostException e) {  e.printStackTrace(); } 
     catch (SocketException e) {    e.printStackTrace(); } 
     catch (IOException e) {     e.printStackTrace(); } 
     catch (ClassNotFoundException e) {  e.printStackTrace(); } 
    } 

    public void disconnect(){ 
     try { 
      MSG_Logout logout = new MSG_Logout(); 
      logout.setID(DeviceId.getId().toString()); 
      send(logout); 

      Object c1 = in.readObject(); 
      if(c1 instanceof MSG_Logout){ 
       in.close(); 
       out.close(); 
       socket.close(); 
      } 
     } 
     catch (IOException e) { e.printStackTrace(); } 
     catch (ClassNotFoundException e) {  e.printStackTrace(); } 
    } 

    public static void send(Object obj) { 
     try { 
      out.writeObject(obj); 
      out.flush(); 
      out.reset(); 
     } 
     catch (IOException e) { e.printStackTrace(); } 
    } 
} 

сервера (резьба) Класс:

public class Servidor_Thread extends Thread{ 

    public Socket canal; 
    Servidor serv; 
    ObjectOutputStream oos=null; 
    ObjectInputStream ois=null; 
    private boolean logOff; 

    public Servidor_Thread(Servidor serv) { 
     this.serv = serv; 
     canal = serv.socket; 
     logOff = false; 
    } 

    public void run(){ 
      try { 
       ois=new ObjectInputStream(canal.getInputStream()); 
       oos=new ObjectOutputStream(canal.getOutputStream()); 
       while(logOff==false){ 
        Object obj=ois.readObject();/** Objecto recebido - Reconstrução **/ 
        DateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss"); 
        Date date = new Date(); 
        if(obj instanceof MSG_Login){ 
         serv.id_database.add(((MSG_Login) obj).getID()); 
         serv.getLog().appendConsole("["+dateFormat.format(date)+"]..........User "+((MSG_Login) obj).getID()+" connected."); 
         enviar(obj); 
        } 
        if(obj instanceof MSG_Logout){ 
         serv.id_database.remove(((MSG_Logout) obj).getID()); 
         serv.getLog().appendConsole("["+dateFormat.format(date)+"]..........User "+((MSG_Logout) obj).getID()+" disconnected."); 
         enviar(obj); 
         stopThread(); 
        } 
       } 
      } 
      catch (IOException e) {     stopThread();  } 
      catch (ClassNotFoundException e) {  e.printStackTrace(); } 
    } 

    public void stopThread(){ 
     logOff = true; 
     try { 
      ois.close(); 
      oos.close(); 
      canal.close(); 
     } catch (IOException e) { e.printStackTrace(); } 
    } 

    public void enviar(Object obj) { 
     try { 
      oos.writeObject(obj); 
      oos.flush(); 
      oos.reset(); 
     } 
     catch (IOException e) { e.printStackTrace(); } 
    } 
} 

Answer 1

Там нет никаких проблем здесь, чтобы ответить. Метод readObject() вызывает исключение EOFException в конце потока. Это нормальное поведение. Вы должны поймать его, закрыть поток, который вы читаете, и выйти из цикла чтения.