我有一个Java服务器和Android客户端。客户端通过TCP套接字将3件事发送到服务器。第一个是int的文件大小,第二个是长号(即序列号),第三个是使用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和loop中的每个循环之后立即在客户端和服务器的输出流上调用close(),则客户端或服务器中的程序执行都不会出现阻塞或问题。并且pdf文件始终处于良好状态。

编辑:我是朝着完全错误的方向前进吗?发送pdf文件后打开新插座并关闭插座是否更好?如果然后如何与早期套接字连接到相同的android客户端打开。想要将响应消息发送回相同的android客户端,而不是其他客户端。

最佳答案

由于您在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
}

07-24 09:51
查看更多