2

我只想使用 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 对象并接收回显 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() 函数不起作用。

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

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

4

2 回答 2

5

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

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

您可以将writeTo()andpasrseFrom()与流一起使用，但前提是您要写入/读取单个消息并在写入后关闭流。然后，阅读器将获得一个 EOF 来指示消息的结束（从仅包含单个消息的文件中读取时也是这种情况）。

于 2013-05-29T13:55:39.630 回答
1

不要编写自己的客户端/服务器，即。RPC 解决方案。这里有一个...... https://code.google.com/p/protobuf-rpc-pro/它已经为 java 提供了一些不错的功能。

于 2013-05-30T19:00:26.153 回答