输出流处的服务器-客户端通信失败

Question

我的程序基本上是：

>

客户端向服务器发送字符串，

基于这个字符串，服务器正在创建一个ArrayList，

ArrayList 被发送回客户端。

这里失败的是:

客户端发送字符串后，服务器会收到它，并且不执行任何其他操作。在这段时间里，客户端继续工作并得到一个空指针。

客户端:

    public static ArrayList<String> sendStringToServer(String report) {

    Socket socket;

    ArrayList<String> fieldsList = new ArrayList<String>();

    try {

        socket = new Socket("localhost", 2345);

        OutputStream os = socket.getOutputStream();
        PrintStream ps = new PrintStream(os, true);

        ps.println(report);
        ps.flush();

        //Here the debugger should stop and wait for server to create a List

        //at this point there is no answer, code breaks
        ObjectInputStream objectInput = new ObjectInputStream(socket.getInputStream());

        Object object = objectInput.readObject();
        fieldsList = (ArrayList<String>) object;

        socket.close();

        return fieldsList;

    } catch (IOException e1) {

        e1.printStackTrace();
    } catch (Exception e) {

        e.printStackTrace();
    }
    return null;
}

}

服务器端:

public class Server {

private ServerSocket serverSocket;
private Socket clientSocket;
private String telegram;
private StringBuilder telegramSB;

public static void main(String[] args) throws IOException, JRException {

    new Server();
}
public Server() {

    try {
        serverSocket = new ServerSocket(2345);

        while (true) {

            clientSocket = serverSocket.accept();
            InputStream is = clientSocket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);

            try {

                //debugger goes to here and then stops
                telegram = br.readLine();

                int counter = 0;

                boolean startSeq = false;

                for (char ch : telegram.toCharArray()) {

                    if (counter == 0 && ch == '/') {

                        startSeq = true;
                    }

                    if (startSeq == true) {

                        telegramSB = new StringBuilder();
                        telegramSB.append(ch);
                    }

                    if (ch == '\n') {

                        if (telegram.length() < 255) {

                            sendListWithFields();

                        } else {

                            new Launcher(telegram).run();
                        }
                    }
                    counter++;
                }
            } catch (JRException e) {

                e.printStackTrace();

            } catch (IOException e) {

                e.printStackTrace();

            }
        }
    } catch (IOException e) {

        System.out.println(e);
    }
}

Answer 1

我的猜测是，BufferedReader正在等待填充它的缓冲区，而你还没有发送足够的数据让它这样做并返回，所以它一直在等待更多的数据通过(因为你的客户机停止写并开始读)。您可以通过将更多的数据转储到客户机的OutputStream中并刷新它来暂时测试这个理论。

如果是上述情况，那么您可能不想使用BufferedReader，但您还有其他问题，这也意味着您可能希望避免使用PrintStream和BufferedReader进行通信和序列化。例如，两台不同机器和JVM上的默认字符编码可能不同。当您创建PrintStream和InputStreamReader时，您没有指定字符编码，因此它们可能会不匹配，您编写的字符串（包括换行符）可能会被远程端完全不同地理解，这也可能是其阻塞的原因（客户端以一种方式编码换行符，但服务器希望它以完全不同的方式编码），尽管我认为可能性不大。

如果您不必使用PrintStream，那么我建议您改用DataOutpuStream/DataInpuStream：

//Client
BufferedOutputStream bufout = new BufferedOutputStream(socket.getOutputStream());
DataOutputStream dout = new DataOutputStream(bufout);
dout.writeUTF(report);
dout.flush();

//Server
BufferedInputStream bufin = new BufferedInputStream(socket.getInputStream());
DataInputStream din = new DataInputStream(bufin);
String report = din.readUTF();

您仍然可以从BufferedIn/OutputStreams获得缓冲，因此它将是高性能的，但是DataIn/OutputStreams将为您管理可变长度对象的终止——它们将发送一个长度作为字符串的前缀，以告诉另一端要读取的确切字节数，因此您不需要使用特殊字符来终止您编写的字符串，这也意味着字符串的内容是什么并不重要。在上面的例子中，如果你的字符串中有一个换行符，服务器会一直读到第一个换行符，而不是读到你发送的字符串的末尾，这会使它们在下一次发送/接收时不同步。

使用写/读UTF还指定了编码（UTF-8），因此也没有不匹配。