我正在从事应用程序开发。在该应用程序上,我正在执行文件存储、检索和删除操作。为了识别服务器上的文件,我使用了一个索引(哈希映射文件)文件。每次执行上传操作时,我都会更新“索引”文件并在服务器上上传“索引”文件以及其他上传文件。
为了首先执行删除操作,我正在检索“索引”文件,并根据索引从服务器中删除文件,在更新“索引”文件后,我再次在服务器上上传“索引”文件。
我能够成功执行文件上传操作,但是在执行删除操作时,当我尝试检索“索引”文件时,我收到“java.io.EOFException”异常。
我正在编写以下代码以从 FTPS 服务器下载“索引”文件
//download index file
if (service.retrFile("INDEX", "") == service.OK) {
try {
ObjectInputStream objIn = new ObjectInputStream(new FileInputStream("INDEX"));
try {
Map<String, FileData> filesUploaded = (HashMap<String, FileData>) objIn.readObject();
} catch (ClassNotFoundException ex) {
ex.printStackTrace();
}
objIn.close();
} catch (IOException ex) {
ex.printStackTrace();
}
}
如果“service.ok”成功连接到 FTPS 服务器,则返回“0”,“FileData”包含有关文件(属性)的信息。
我在执行上传操作时使用的代码相同。它在那里工作正常,无一例外。但是在我检索“索引”文件时执行删除操作时,我在语句中遇到异常:
映射文件上传 = (HashMap) objIn.readObject();
例外是:
严重:无
java.io.EOFException
at java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2298)
at java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2767)
at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:798)
at java.io.ObjectInputStream.<init>(ObjectInputStream.java:298)
at com.pixelvault.gui.DeleteServerFilesDialog.startDeleting(DeleteServerFilesDialog.java:447)
我已经检查了执行相应操作后FTPS服务器连接是否正确关闭。
我没有得到我做错的地方。
请给我您的宝贵建议。我感谢您的所有建议,这将帮助我克服这个问题。
我正在使用 org.apache.commons.net.ftp 并且“retrFile”是我创建的用于从服务器检索文件的方法。
这是“retrFile”的代码
FTPSClient ftp;
public int retrFile(String filename, String savePath) { if (!connected) { return ERR; }
FileOutputStream fout = null;
InputStream bin = null;
try {
ftp.enterLocalPassiveMode();
fout = new FileOutputStream(savePath + filename);
bin = ftp.retrieveFileStream(filename);
if (bin == null) {
fout.close();
return ERR;
}
byte[] b = new byte[ftp.getBufferSize()];
int bytesRead = 0;
while ((bytesRead = bin.read(b, 0, b.length)) != -1) {
fout.write(b, 0, bytesRead);
}
ftp.completePendingCommand();
fout.close();
} catch (FTPConnectionClosedException ex) {
ex.printStackTrace();
connected = false;
return NOT_CONNECTED;
} catch (IOException ex) {
ex.printStackTrace();
return ERR;
} finally {
try {
fout.close();
} catch (IOException ex) {
ex.printStackTrace();
return ERR;
}
try {
if (bin != null) {
bin.close();
}
} catch (IOException ex) {
ex.printStackTrace();
return ERR;
}
}
return OK;
}