ak/file
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

OSS下载失败问题修复

Browse Source
This commit is contained in:
马超 2021-03-31 00:08:28 +08:00
parent 0cc730efc2
commit 876391678c
4 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
file-common/src/main/java/com/qiwenshare/common/domain/DownloadFile.java
View File

@ -5,5 +5,5 @@ import lombok.Data;
@Data @Data
public class DownloadFile { public class DownloadFile {
private String fileUrl; private String fileUrl;
private String timeStampName; // private String timeStampName;
} }

3
file-common/src/main/java/com/qiwenshare/common/operation/download/product/AliyunOSSDownloader.java
View File

@ -27,7 +27,8 @@ public class AliyunOSSDownloader extends Downloader {
byte[] buffer = new byte[1024]; byte[] buffer = new byte[1024];
OSS ossClient = createOSSClient(qiwenFileConfig.getAliyun().getOss()); OSS ossClient = createOSSClient(qiwenFileConfig.getAliyun().getOss());
OSSObject ossObject = ossClient.getObject(qiwenFileConfig.getAliyun().getOss().getBucketName(), downloadFile.getTimeStampName()); OSSObject ossObject = ossClient.getObject(qiwenFileConfig.getAliyun().getOss().getBucketName(),
downloadFile.getFileUrl().substring(1));
InputStream inputStream = ossObject.getObjectContent(); InputStream inputStream = ossObject.getObjectContent();
try { try {
bis = new BufferedInputStream(inputStream); bis = new BufferedInputStream(inputStream);

10
file-common/src/main/java/com/qiwenshare/common/operation/upload/product/LocalStorageUploader.java
View File

@ -46,14 +46,14 @@ public class LocalStorageUploader extends Uploader {
if (!isMultipart) { if (!isMultipart) {
throw new UploadGeneralException("未包含文件上传域"); throw new UploadGeneralException("未包含文件上传域");
} }
DiskFileItemFactory dff = new DiskFileItemFactory();//1、创建工厂 //DiskFileItemFactory dff = new DiskFileItemFactory();//1、创建工厂
String savePath = getSaveFilePath(); String savePath = getSaveFilePath();
dff.setRepository(new File(savePath)); //dff.setRepository(new File(savePath));
try { try {
ServletFileUpload sfu = new ServletFileUpload(dff);//2、创建文件上传解析器 //ServletFileUpload sfu = new ServletFileUpload(dff);//2、创建文件上传解析器
sfu.setSizeMax(this.maxSize * 1024L); //sfu.setSizeMax(this.maxSize * 1024L);
sfu.setHeaderEncoding("utf-8");//3、解决文件名的中文乱码 // sfu.setHeaderEncoding("utf-8");//3、解决文件名的中文乱码
Iterator<String> iter = standardMultipartHttpServletRequest.getFileNames(); Iterator<String> iter = standardMultipartHttpServletRequest.getFileNames();
while (iter.hasNext()) { while (iter.hasNext()) {
saveUploadFileList = doUpload(standardMultipartHttpServletRequest, savePath, iter, uploadFile); saveUploadFileList = doUpload(standardMultipartHttpServletRequest, savePath, iter, uploadFile);

2
file-web/src/main/java/com/qiwenshare/file/service/FiletransferService.java
View File

@ -146,7 +146,7 @@ public class FiletransferService implements IFiletransferService {
} }
DownloadFile uploadFile = new DownloadFile(); DownloadFile uploadFile = new DownloadFile();
uploadFile.setFileUrl(fileBean.getFileUrl()); uploadFile.setFileUrl(fileBean.getFileUrl());
uploadFile.setTimeStampName(fileBean.getTimeStampName()); // uploadFile.setTimeStampName(fileBean.getTimeStampName());
downloader.download(httpServletResponse, uploadFile); downloader.download(httpServletResponse, uploadFile);
} }