java - 无法在不损坏文件和阻塞 while 循环的情况下保持套接字打开

Question

我有一个 Java 服务器和 Android 客户端。客户端通过 TCP 套接字向服务器发送 3 件事。第一个是以 int 为单位的文件大小，第二个是一个 long，即序列号，第三个它使用 while 循环来发送 pdf 文件。

所有三个文件均已成功发送到服务器，但是要执行此操作，必须在 while 循环之后立即关闭两侧的输出流 (BufferedOutputStream)。如果不这样做，则发送到服务器的 pdf 文件将不完整且损坏。并且程序将被阻塞或卡住在服务器的 while 循环中，不再执行任何程序。

问题是，在关闭客户端中的输出流后，也会关闭套接字，并且我无法从服务器将响应发送回客户端。我也无法在客户端打开新的输入流来接收此响应。

并且有 20 个不同的 Android 客户端，因此需要相同的套接字来确保返回消息返回到其预期的正确客户端，因为服务器为每个连接的 Android 客户端启动一个单独的套接字对象。

如何保持套接字打开？并且仍然能够发送完整的文件？

显示 while 循环的服务器代码示例

         @Override
        public void run() { // launch new thread

        fileSizeFromClient = dis.readInt();
        serialNumber = dis.readLong();

        byte[] buffer = new byte[fileSizeFromClient];

          while((count = dis.read(buffer)) > 0){
          bos.write(buffer, 0, count);
          }

         bos.close();

         } // end thread

显示 while 循环的客户端代码示例

             @Override
             public void run() { // launch new thread

             dos.writeInt((int)length); // sends the length as number bytes is file size
             dos.writeLong(serial); 

                int count = 0; // number of bytes

                while ((count = bis.read(bytes)) > 0) {
                    dos.write(bytes, 0, count);
                }
             dos.flush();
             dos.close();

             } // end thread

观察结果:

1 - 在 BufferedOutputStream 或 DataOuputStream 对象上调用 close() 将关闭套接字

2 - 如果在客户端中没有调用outputStream.close()，那么在服务器代码中它将被卡住或卡在while循环上，并且线程的执行将不会继续，将被阻塞，并且pdf文件发送的内容将不完整且已损坏

3 - 如果服务器中未调用 outputSteam.close()，则服务器代码不会像上面#2 中那样被阻止或卡住，但发送的 pdf 文件到达时将不完整或损坏

4 - 如果在客户端和服务器的输出流上直接在 while 循环之后调用 close()，则客户端或服务器中的程序执行不会出现阻塞或问题。并且 pdf 文件始终完好无损地送达。

编辑:我的方向是否完全错误？发送pdf文件后关闭套接字并打开新套接字是否更好？如果那么如何使用早期套接字连接到的同一个 Android 客户端打开。想要将响应消息发送回同一个 Android 客户端，而不是其他客户端。

Answer 1

由于您在 while 循环之前从客户端获得了文件大小，因此您可以修改服务器代码以仅读取文件大小的字节数，并在收到这些字节后关闭 PDF 流。

byte[] bufferPDF = new byte[fileSizeFromClient];
int count =0;
while (count!=fileSizeFromClient){
   bufferPDF[count]= disSocket.readByte();
   count++;
}
bosPDF.write(bufferPDF);
bosPDF.close();

/** Send response to client **/
dosSocket.write(responseBytes);

在客户端，您在发送文件后尝试从套接字读取数据，并且不需要关闭套接字。

while ((count = bisPDF.read(bytes)) > 0) {
  dosSocket.write(bytes, 0, count);
}
dosSocket.flush();

while(disSocket.read(responseBytes)>0){
   //Process the response from server
}