Java TCP客户端读取Python服务端InputStream数据后程序挂起问题排查

问题根因 #

Java客户端retrieve()方法里的InputStream.read(buffer)是阻塞调用，只有当服务端主动关闭TCP连接时，read()才会返回-1退出while循环。但当前Python服务端发完YES/NO响应后不会关闭连接，还在等待接收客户端的下一条指令，所以客户端会一直卡在read调用处，不会进入后续等待用户输入的逻辑。

解决方案 #

方案1：直接适配当前逻辑，修改客户端读取代码 #

当前RETRIEVE指令的响应只有YES、NO两种固定短字符串，不需要循环等待流结束标识，读完单次响应即可退出读取逻辑：

private void retrieve() throws IOException {
    byte[] buffer = new byte[1024];
    InputStream is = socket.getInputStream();
    int len = is.read(buffer);
    if (len > 0) {
        String line = new String(buffer, 0, len);
        System.out.println(line);
        System.out.flush();
    }
}

方案2：标准化通信规则，避免后续出现粘包/阻塞问题 #

如果后续要扩展更多交互指令，建议约定统一的消息边界规则：

1. 服务端修改发送逻辑，所有响应末尾加换行符作为结束标识，比如发送b'YES\n'、b'NO\n'
2. 客户端按行读取响应，读到结束标识就停止读取：

private void retrieve() throws IOException {
    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String line = br.readLine();
    System.out.println(line);
    System.out.flush();
}

内容的提问来源于stack exchange，提问作者cheng raphael