我有一个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
}