java - 我的代码挂起，但当我调试它时它永远不会挂起

Question

我有一个java代码，当我运行它时有时会挂起。它是一个put命令，通过套接字(和输入流等文件从服务器到客户端)。有时这有效，但有时不起作用，并且我收到一条错误消息。我尝试了通过调试可以采取的所有可能的路径，但我永远无法让它挂起。有没有办法在 Eclipse 挂起时检查它？`

if (sentence.length() > 3 && sentence.substring(0, 3).equals("put")) {

                    File checkFile = new File(dir.getCurrentPath(), sentence.substring(4));
                    if (checkFile.isFile() && checkFile.exists()) {

                        try {
                            outToServer.writeBytes(sentence + "\n");
                            boolean cont = false;
                            String x;
                            while (!cont) {
                                if ((x = inFromServer.readLine()).equals("continue")) {
                                    cont = true;

                                }
                            }
                            String name = sentence.substring(4);
                            copy.copyFile(name);
                            //                          outToServer.writeBytes("continue" + "\n");

这是接收 PUT 请求的客户端代码(即 put test.txt 获取文件 test.txt 并将其放入服务器的本地目录中。

复制文件:(复制数据的东西)

File checkFile = new File(dir.getCurrentPath(), file);
    if (checkFile.isFile() && checkFile.exists()) {

        DataOutputStream outToClient = new DataOutputStream(socket.getOutputStream());
        //              byte[] receivedData = new byte[8192];
        File inputFile = new File(dir.getCurrentPath(), file);
        byte[] receivedData = new byte[(int) inputFile.length()];
        //      String theLength = "" + inputFile.length();
        outToClient.writeBytes("" + inputFile.length() + "\n");
        BufferedInputStream bis = new BufferedInputStream(new FileInputStream(getCopyPath(file)));

        //      if (extension.equals("")) {
        //          extension = "txt";
        //      }
        //          BufferedReader inFromClient = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        //          boolean cont = false;
        //          while (!cont) {
        //              if (inFromClient.readLine().equals("continue")) {
        //                  cont = true;
        //
        //              }
        //          }
        //          outToClient.writeBytes("continue" + "\n");

        bis.read(receivedData, 0, receivedData.length);
        OutputStream os = socket.getOutputStream();
        os.write(receivedData, 0, receivedData.length);
        //          outToClient.writeBytes("finish" + "\n");
        os.flush();

服务器上的协议(protocol)(复制文件中的内容)

if (get.equals("put")) {
                    //so the client sends: the put request
                    //then sends the length 
                    try {
                        BufferedReader inFromClient = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                        DataOutputStream outToClient = new DataOutputStream(socket.getOutputStream());
                        outToClient.writeBytes("continue" + "\n");
                        int length = Integer.parseInt(inFromClient.readLine());
                        //                      String x = "";
                        //                      boolean cont = false;
                        //                      while (!cont) {
                        //                          String temp = inFromClient.readLine();
                        //                          if (temp.equals("finish")) {
                        //                              cont = true;
                        //                          }
                        //                          else {
                        //                              x += temp;
                        //                          }
                        //                      }
                        byte[] recieveFile = new byte[length];
                        InputStream is = socket.getInputStream();
                        FileOutputStream fos = new FileOutputStream("Copy " + input.substring(4));
                        BufferedOutputStream bos = new BufferedOutputStream(fos);
                        int bytesRead;
                        int current = 0;
                        bytesRead = is.read(recieveFile, 0, recieveFile.length);
                        current = bytesRead;

如果您无法具体回答问题，请告诉我如何调试挂起的代码或如何调试并发代码。(顺便说一下，完成信号传递的方式是通过传递 token 来实现)参见，即服务器发送了一个继续 token ，告诉客户端开始发送数据，我还没有使用线程方法通知和等待来完成此操作，因为我无法使用，因为任何单个对象只有 1 个方法。

Answer 1

当进程挂起时，获取该进程的当前堆栈转储。这将告诉您进程挂起的原因。

请注意，您的程序中至少有一个错误，因为您没有处理 InputStream.read() 方法的返回值，这至少会导致您在服务器端破坏了数据。 (更多详情请参阅@rk2010的回答)。

不过，您的主要错误是，当您将 BufferedReader 包装在套接字 InputStream 周围时，您最终可能会从流中“窃取”比长度值更多的字节。当 BufferedReader 从底层流读取数据时，它可以读取比 readLine() 方法中实际返回的数据更多的数据(因此，它可以在内部读取 1000 个字符，但第一个“行”可能只包含 20 个字符)。如果您继续使用 BufferedReader，一切都很好，但是如果您放弃 BufferedReader 并尝试从底层流中读取更多数据，那么那里的数据将比您预期的要少。因此，当您去读取文件内容时，没有足够的可用字节。

相反，您应该专门使用 DataOutputStream/DataInputStream。将长度写入长值(即 DataOutputStream.writeLong(long))，然后写入后面的字节(即 DataOutputStream.write(byte[]))。然后使用DataInputStream中相应的方法读取数据。由于您可以在读取时专门使用 DataInputStream(首先读取文件大小，然后读取实际文件字节)，因此在切换读取“模式”时不会有丢失字节的风险(此外，DataInputStream 不会 进行任何内部缓冲，如 BufferedReader)。根本不使用 Readers/Writers。