为什么 parseFrom() 函数在 java socket 中使用 protobuf 挂起？

Question

我只想使用 protobuf 和 java 创建回声服务器/客户端。

我用 protobuf-java-2.4.1 和 jdk1.7 进行了测试。

我写了如下的回声服务器代码

// create server socket and accept for client connection.
// ...
link = servSock.accept();                       
Person person = Person.parseFrom(link.getInputStream()); // blocking position
person.writeTo(link.getOutputStream());

我认为没有必要注意Person.proto。

客户端代码仅使用套接字输入流发送 Person 对象并接收 echo Person 对象。

// socket connect code was omitted.
Person person = Person.newBuilder().setId(1).setName("zotiger").build();
person.writeTo(echoSocket.getOutputStream());
person = Person.parseFrom(echoSocket.getInputStream());

但是当服务器和客户端都运行时，服务器在 parseFrom 函数中被阻止。

我发现如果我使用 writeDelimitedTo() 和 parseDelimitedFrom()，那就没问题了。我不明白为什么 writeTo() 和 parseFrom() 函数不起作用。

为什么服务器在那里阻塞？

是否有必要从客户端发送一些结束信号？

Answer 1

您必须使用writeDelimitedTo()/的原因parseDelimitedFrom()是，否则协议缓冲区可能不知道它需要从套接字读取多少数据。这提出了一个问题（我说可能是因为你当然可以创建一个只有固定长度字段的消息，不需要这个......但协议缓冲区必须处理这两种情况）

该writeDelimitedTo()方法将消息的长度写入OutputStream消息本身。它的对应部分parseDelimitedFrom()读取长度，然后读取消息。

您可以使用writeTo()和pasrseFrom()使用流，但前提是您想写入/读取单个消息并在写入后关闭流。然后，阅读器将获得一个 EOF 来指示消息的结尾（从仅包含一条消息的文件中读取时也是如此）。