Java Creating a new ObjectInputStream Blocks

Question

I'm trying to create a new ObjectInputStream using an InputStream retrieved from a Socket. Here is my code:

This is the constructor for my MessageGetterSender class. The program does not get to Checkpoint 4.

public MessageGetterSender(Socket socket) {

    System.out.println("MessageGetterSender: Checkpoint 1");

    this.socket = socket;

    // Get input and output streams
    try {
        System.out.println("MessageGetterSender: Checkpoint 2");

        InputStream is = socket.getInputStream();

        System.out.println("MessageGetterSender: Checkpoint 3");

        this.in = new ObjectInputStream(is);

        System.out.println("MessageGetterSender: Checkpoint 4");

    } catch (IOException ioe) {
        System.out.println("Could not get ObjectInputStream on socket: " + socket.getLocalPort());
    }

    try {
        this.out = new ObjectOutputStream(socket.getOutputStream());
    } catch (IOException ioe) {
        System.out.println("Could not get ObjectOutputStream on socket: " + socket.getLocalPort());
    }

    System.out.println("MessageGetterSender: Checkpoint 5");
}

I'm instantiating a new MessageGetterSender object from a class in which I connect to a server to get the socket. Here is the relevant code. It is the constructor for the InstantMessageClass, the class that instantiates the MessageGetterSender object:

public InstantMessageClient(String username) {

try {
    socket = new Socket("localhost", 5555);
} catch (IOException ioe) {
    System.out.println("Error: Could not connect to socket on port: " + serverPort);
}

messageGetterSender = new MessageGetterSender(socket);

...

Since the code does not execute to Checkpoint 4 but it does get to Checkpoint 3, I'm pretty sure the instantiation of the ObjectInputStream is the culprit. I cannot figure out why though. Any ideas? Thanks for the help.

BartoszKP · Accepted Answer · 2014-06-07 10:10:43Z

44

When you construct an ObjectInputStream, in the constructor the class attempts to read a header that the associated ObjectOutputStream on the other end of the connection has written. It will not return until that header has been read. So if you are seeing the constructor 'hang', it's because the other side of the socket either hasn't used an ObjectOutputStream, or hasn't flushed the data yet.

edited Jun 7, 2014 at 10:10

BartoszKP

36k15 gold badges109 silver badges135 bronze badges

answered Apr 14, 2011 at 3:09

MeBigFatGuy

28.7k8 gold badges64 silver badges68 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Haywood Slap · Accepted Answer · 2011-09-28 15:56:22Z

44

Just to expand on FatGuy's answer for other Googlers that find this; the solution to this "chicken and egg problem" is to have each side open the output stream first, flush the output stream, and then open the input stream.

ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());
out.flush();
ObjectInputStream in = new ObjectInputStream(socket.getInputStream());

answered Sep 28, 2011 at 15:56

Haywood Slap

7526 silver badges12 bronze badges

3 Comments

Timmos Over a year ago

That's indeed the proper solution. And you hit the nail on the head by describing it as a "chicken and egg" problem.

Dominik Over a year ago

I would say that out.flush() is not necessary (except if you are using some buffered stream as underlying stream) as the BlockDataOutputStream used by ObjectOutputStream writes the stream header before it enables block data mode.

Gurkirat Singh Guliani Over a year ago

i'm trying this but it is not working, the code halts at input stream , i do not know why

Mihai Danila · Accepted Answer · 2013-01-27 19:53:37Z

1

You can also delay the initialization of the ObjectInputStream until data is available in the underlying stream.

This approach works regardless of the stream initialization order, and is especially useful if one end of the channel is in library code that you cannot change.

answered Jan 27, 2013 at 19:53

Mihai Danila

2,3491 gold badge25 silver badges29 bronze badges

2 Comments

Jack Over a year ago

Might I ask how one would go about doing this?

Mihai Danila Over a year ago

I think you can peek at the underlying stream to see if there's data available. It's been a while since I've looked at the Stream API.

Collectives™ on Stack Overflow

Java Creating a new ObjectInputStream Blocks

3 Answers 3

Comments

3 Comments

2 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

Comments

3 Comments

2 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related