我想将文件从客户端发送到服务器,并且将来能够再次发送。
所以我的客户端连接到服务器并上传文件,好的 - 它可以工作,但它在最后挂起..
所以这是我在客户端的代码,服务器端非常相似。
private void SenderFile(File file) {
try {
FileInputStream fis = new FileInputStream(file);
OutputStream os = socket.getOutputStream();
IoUtil.copy(fis, os);
} catch (Exception ex) {
ex.printStackTrace();
}
}
在 Stack 上找到的 IoUtils :)
public static class IoUtil {
private final static int bufferSize = 8192;
public static void copy(InputStream in, OutputStream out)
throws IOException {
byte[] buffer = new byte[bufferSize];
int read;
while ((read = in.read(buffer, 0, bufferSize)) != -1) {
out.write(buffer, 0, read);
}
out.flush();
}
}
解释:我的客户端有一个连接到服务器的套接字,我向他发送任何文件。我的服务器下载了它,但最后挂起,因为他正在监听更多信息。如果我选择另一个文件,我的服务器会将新数据下载到现有文件中。
如何将任何文件上传到服务器,使我的服务器正常工作并能够正确下载另一个文件?
附言。如果我在函数结束时添加到 ioutil.copy,out.close
我的服务器将继续工作,但连接将丢失。我不知道该怎么办 :{
更新后:客户端:
private void SenderFile(File file) {
try {
FileInputStream fis = new FileInputStream(file);
OutputStream os = socket.getOutputStream();
DataOutputStream wrapper = new DataOutputStream(os);
wrapper.writeLong(file.length());
IoUtil.copy(fis, wrapper);
} catch (Exception ex) {
ex.printStackTrace();
}
}
服务器端(线程监听来自客户端的任何消息):
public void run() {
String msg;
File newfile;
try {
//Nothing special code here
while ((msg = reader.readLine()) != null) {
String[] message = msg.split("\\|");
if (message[0].equals("file")) {//file|filename|size
String filename = message[1];
//int filesize = Integer.parseInt(message[2]);
newfile = new File("server" + filename);
InputStream is = socket.getInputStream();
OutputStream os = new FileOutputStream(newfile);
DataInputStream wrapper = new DataInputStream(is);
long fileSize = wrapper.readLong();
byte[] fileData = new byte[(int) fileSize];
is.read(fileData, 0, (int) fileSize);
os.write(fileData, 0, (int) fileSize);
System.out.println("Downloaded file");
} else
//Nothing special here too
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
好的,现在我可以下载文件了 - 仍然有一次,另一个已下载但无法读取。例如,第二次我想由客户端发送一个 file.png。我在服务器上得到了它,但是无法查看此文件。提前致谢 :)