输入长度未知的套接字通信

Question

我试图修复一个java套接字通信错误，服务器不知道输入消息的长度。在当前情况下，服务器测试输入是否完成inputStream.available（）；方法。然而，这种方法并不总是返回正确答案。它会导致读取部分输入。似乎有两种不同的可能性来解决这个问题。

>

客户端应该在发送后关闭其输出流，但这会导致客户端不读取响应，因为输出流关闭时套接字也会关闭。

有没有其他建议，特别是在nio包的帮助下？

非常感谢。

Answer 1

至少还有另外两种方法没有提及，可能应该提及。

>

使用特殊字符表示某个输入的结尾。如果输入中不允许有新行，则\r\n是一个选择。

使用某种序列化-您可以将数据作为JSON对象或XML之类的格式发送，这样您就知道什么时候没有更多的数据了。

Answer 2

available（）不是消息长度的度量值，因此如果“正确答案”的定义是“消息长度”，则没有理由返回“正确答案”。

如果您想要消息长度，您必须发送一个。或者使用行或自描述协议，如XML、序列化等。

Answer 3

你可以用

socket.shutdownOutput();

关闭客户端的输出流。这将显示为关闭的输入流，而不关闭套接字。

顺便说一句：你不能使用套接字。GetOutputStream（）。关闭（） 我认为你可以。

IMHO发送长度是最佳选择，因为这将允许您使用同一套接字发送多个请求。

下面是一个例子

public class SimpleServerMain {
    public static void main(String... args) throws IOException, InterruptedException {
        ServerSocket ss = new ServerSocket(54321);
        Socket s = ss.accept();
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        for (String line; (line = br.readLine()) != null; )
            System.out.println("Got " + line);

        PrintStream ps = new PrintStream(s.getOutputStream());
        for (String word : "Hello World Bye Bye!".split(" ")) {
            ps.println(word);
            Thread.sleep(1000);
        }
        s.close();
        ss.close();
    }
}

和

public class SimpleClientMain {
    public static void main(String... args) throws IOException {
        Socket s = new Socket("localhost", 54321);
        InputStream inputStream = s.getInputStream();

        s.getOutputStream().write("Hello\n".getBytes());
        s.shutdownOutput();

        BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));
        for (String line; (line = br.readLine()) != null; )
            System.out.println("Got " + line);
        System.out.println("Disconnected.");
        s.close();
    }
}