服务器如何知道它收到的消息实际上何时结束？

Question

我正在尝试实现一个服务器，它在收到消息时会执行以下操作：

try{
       ObjectInputStream is = new ObjectInputStream(clientSocket.getInputStream());
       String message = (String)is.readObject();
       ActivateCommand(message,clientSocket);
       is.close();
    }

和激活命令：

private void ActivateEwolfCommand(String msg, Socket clientSocket) throws IOException 
{
    ObjectOutputStream os = new ObjectOutputStream(clientSocket.getOutputStream());
    Gson gsonObject = new Gson();
    .
    //code which makes a Json string
    .
    os.writeObject(json);
os.close();
}

现在，当我通过 junit 测试向本地主机发送消息对其进行测试时，它可以正常工作。但是当尝试从 C# 客户端连接到服务器时，客户端连接但服务器在到达 clientSocket.getInputStream() 点时抛出 EOF 异常。 我猜这是因为服务器不知道消息何时结束，但我不知道是否真的如此，如果是这样，那么我该如何解决？

Answer 1

如果您想通过套接字发送字符串，那么ObjectInputStream 或ObjectOutputStream 不是正确的流实现。这些流实现使用 Java 对象序列化。即使您序列化 String 实例，生成的字节也与使用适当字符编码的纯字符串到字节转换不同。

而且 C# 应用程序根本不理解 Java 序列化。

考虑使用PrintWriter 将字符串写入您的流并使用BufferedReader 进行读取。

PrintWriter writer = new PrintWriter(new OutputStreamWriter(clientSocket.getOutputStream(), "UTF-8"));
writer.println(...);


BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream(), "UTF-8"));
String line = reader.readLine();

然后您可以逐行读取和写入字符串。 这只是一个起点。如果你想实现自己的协议，你必须注意更多的点。例如，您可以阅读一些 TCP 协议的规范，例如 POP3、FTP 或 HTTP 1.0。

Answer 2

这就是为什么使用套接字和对象流创建自己的客户端-服务器协议是一个坏主意的原因。很多人花了很多年才带你，哦，好吧：

• 肥皂
• 休息
• RMI
• 黑森州
• CORBA
• 节俭

还有许多其他协议。当然，如果不是 5 个或 6 个，其中之一足以解决您的问题，包括所有框架问题。

Answer 3

当InputStream 到read() 上没有更多可用数据时 - 这基本上就是导致 EOF 的原因。有多少数据可用是由客户端决定的——它写入它一侧的 Socket 的OutputStream 的数据在服务器端的 Socket 的InputStream 上显示为这样。您可以调用InputStream.available() 来估算可能仍为read() 的字节数。

但是，您的代码尝试使用 ObjectInputStream 读取对象 - 此类有自己的协议来读取序列化字节流并将其转换为对象 - 如果找不到完成任务的字节，则可能会抛出EOF 异常。如果您的客户端使用 C# - 为序列化对象写入的字节格式肯定与服务器端 ObjectInputStream 所期望的不同。