java - 在 Java 中发送对象时如何停止从 BufferedReader 读取？

Question

我正在编写一个java程序，它通过套接字发送一个转换为字节数组的对象。客户端必须读取所有字节并将其转换回 Java 对象。然而，我的程序卡在循环内的 read() 上，我在其中读取所有字节，直到找到 -1。

我已阅读文档，它说 read() 方法在到达流末尾时返回 -1，但这不起作用。

这是我的代码:发送对象的方法:

Socket socket;
BufferedReader input;
DataOutputStream output;
boolean connectionOpen;  //Just for you to know the types of the attributes of my class
 public void sendResponse(Object obj) throws IOException{

    ByteArrayOutputStream bos = new ByteArrayOutputStream();
    ObjectOutput out = null;
    try {
      out = new ObjectOutputStream(bos);   
      out.writeObject(obj);
      byte[] yourBytes = bos.toByteArray();


      output.write(yourBytes);

    } finally {
      try {
        if (out != null) {
          out.close();
        }
      } catch (IOException ex) {
        // ignore close exception
      }
      try {
        bos.close();
      } catch (IOException ex) {
        // ignore close exception
      }
    }  


}     

读取字节的方法。 (这就是我的代码被卡住的地方)

public Email getMail(int id) throws Exception{
    byte[] bytes = new byte[50000];
    Email result;
    try{
        this.outToServer.writeBytes("MAIL "+id+"\n");
        String response = inFromServer.readLine();
        String[] data = response.split(" ");
        int code = Integer.parseInt(data[0]); 
        if(code==500){
            throw new Exception("Error en servidor Pop4. Servidor respondio: "+response);
        }
        int current =  inFromServer.read();
                int i = 0;

        while(current!=-1){

            bytes[i]=(byte) current;
            i++;
            current= inFromServer.read();
        }
        //Convertimos el arreglo de bytes a un objeto Email
        ByteArrayInputStream bis = new ByteArrayInputStream(bytes);
        ObjectInput in = null;
        try {
          in = new ObjectInputStream(bis);
          result = (Email) in.readObject(); 

        } finally {
          try {
            bis.close();
          } catch (IOException ex) {
            // ignore close exception
          }
          try {
            if (in != null) {
              in.close();
            }
          } catch (IOException ex) {
            // ignore close exception
              ex.printStackTrace();
          }
        }            
    }

    catch(Exception e){
            throw e;
    }
    return result;


}

Answer 1

我建议您直接从套接字一次读取一个对象。

final ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());

public void sendMessage(Object obj) {
    out.writeObject(obj);
    out.reset();
    out.flush();
}

final ObjectInputStream in = new ObjectInputStream(socket.getInputStream());

public Object readMessage() {
    return in.readObject();
}

简而言之，您需要知道何时应该停止阅读或使用可以停止阅读的流。