新的 ObjectInputStream() 块

Question

public class SerProg {


    static ServerSocket ser=null;
    static Socket cli=null;
    static ObjectInputStream ins=null;
    static ObjectOutputStream outs=null;


    public static void main(String[] args) {

        try {

            ser=new ServerSocket(9000,10);
            cli=ser.accept();

            System.out.println("Connected to :"+cli.getInetAddress().getHostAddress()+" At Port :"+cli.getLocalPort());

            ins=new ObjectInputStream(cli.getInputStream());
            outs=new ObjectOutputStream(cli.getOutputStream());

            String str=(String)ins.readObject();


        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }


    }

}

还有客户

public class SerProg {

    /**
     * @param args
     */
    static ServerSocket ser=null;
    static Socket cli=null;
    static ObjectInputStream ins=null;
    static ObjectOutputStream outs=null;


    public static void main(String[] args) {
        // TODO Auto-generated method stub

        try {

            ser=new ServerSocket(9000,10);
            cli=ser.accept();

            System.out.println("Connected to :"+cli.getInetAddress().getHostAddress()+" At Port :"+cli.getLocalPort());

            ins=new ObjectInputStream(cli.getInputStream());
            outs=new ObjectOutputStream(cli.getOutputStream());

            String str=(String)ins.readObject();


        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }


    }

}

连接建立成功，但在服务器代码行中

ins=new ObjectInputStream(cli.getInputStream());

代码停止并且不继续，可能是什么问题？？

Answer 1

您需要在连接两侧的ObjectInputStream 之前创建ObjectOutputStream（！）。创建ObjectInputStream 时，它会尝试从InputStream 中读取对象流标头。所以如果另一边的ObjectOutputStream还没有创建，还没有对象流头可以读取，它会无限期地阻塞。

或者换一种说法：如果双方首先构造ObjectInputStream，双方都会阻止尝试读取对象流标头，直到ObjectOutputStream被创建后才会被写入（在该行的另一边);这永远不会发生，因为双方都被 ObjectInputStream 的构造函数阻塞了。

这可以从ObjectInputStream(InputStream in)的Javadoc推断：

从流中读取序列化流标头并进行验证。此构造函数将阻塞，直到相应的 ObjectOutputStream 已写入并刷新标头。

这也在 Esmond Pitt 的 Java 中的基本网络 的第 3.6.2 节中进行了描述。

Answer 2

您必须为流进行握手。我的意思是在客户端，当你创建一个对象输入流时，你必须在服务器端创建一个对象输出流。

//SERVER SIDE
Socket clientSocket = TcpServer.socket.accept();
// 1. input stream;
ObjectInputStream sInput = new ObjectInputStream(clientSocket.getInputStream());
// 2. output stream
ObjectOutputStream sOutput = new ObjectOutputStream(clientSocket.getOutputStream());


//CLIENT SIDE
Socket socket = new Socket(ip, port);
// 2. output stream
ObjectOutputStream sOutput = new (socket.getOutputStream());
// 1. input stream
ObjectInputStream sInput = new ObjectInputStream(socket.getInputStream());

我试图展示如何为流进行握手。