Java 文件分块上传服务器端源代码(四)
seDao().update("upload.updatePreUploadInfo", preUpload);
if(Global.BLOCK_UPLOAD_TO!=Global.BLOCK_UPLOAD_TO_LOCAL)
{
//组装完毕没有问题 删除掉S2/S3上的block
String[] path=preUpload.getS3BlockUrl();
for (String string : path) {
try {
if(Global.BLOCK_UPLOAD_TO==Global.BLOCK_UPLOAD_TO_S2)
{
S2Util.deleteFile(preUpload.getBucketUrl(), string);
}else
{
S3Util.deleteFile(preUpload.getBucketUrl(), string);
}
} catch (Exception e) {
log.error(e.getMessage(), e);
}
}
}
if (log.isInfoEnabled())
log.info(preUpload.getUuid() + " assembleFileWithBlock");
} catch (IOException e) {
log.error(e.getMessage(), e);
try {
if (fileReader != null) {
fileReader.close();
}
if (fileWrite != null) {
fileWrite.close();
}
} catch (IOException ex) {
log.error(e.getMessage(), e);
}
}
}
BlockPreuploadFileInfo 是我们自定义的业务文件处理 bean。
OK，分块上传的服务器、客户端源代码及其工作流程至此已全部介绍完毕，以上源代码全部是经过项目实践过的，大部分现在仍运行于一些项目之中。有兴趣的朋友可以自己动手，将以上代码自行改造，看看能否运行成功。如果遇到问题可以在本博客下跟帖留言，大家一起讨论讨论。