java實現上傳檔案到oss(阿里雲)功能示例
阿新 • • 發佈:2020-01-07
本文例項講述了java實現上傳檔案到oss(阿里雲)功能。分享給大家供大家參考,具體如下:
做這個功能之前我們需要匯入阿里雲OSS官方提供的工具包
aliyun-sdk-oss-2.5.0.jar 這個檔案 如果有最新版的話就下載最新版
aliyun.upload.AliyunConfig package aliyun.upload; public final class AliyunConfig { //你的oss所在域,要加http:// 不明白可以對照你的檔案引用地址 public static String endpoint = "http://oss-cn-shenzhen.aliyuncs.com"; //密匙keyId 可以在阿里雲獲取到 public static String accessKeyId = "xxxxxxx"; //密匙keySecret 可以在阿里雲獲取到 public static String accessKeySecret = ""; //你的bucketName 名稱 即是你的OSS物件名稱 不明白查oss開發文件專業術語 public static String bucketName = ""; }
aliyun.upload.IAliyunUpload package aliyun.upload; public interface IAliyunUpload { /** * @param * String filePathName 本地圖片路徑(D:/xxxx/xxxx....../xx/xx.jgp|xx.png|..) * String savePathName 將要儲存到OSS上的路徑地址 * */ public String uploadFile(String filePathName,String savePathName); }
aliyun.upload.AliyunUploadVersion1 package aliyun.upload; import java.io.File; import java.io.IOException; import com.aliyun.oss.ClientException; import com.aliyun.oss.OSSClient; import com.aliyun.oss.OSSException; import com.aliyun.oss.model.CompleteMultipartUploadResult; import com.aliyun.oss.model.UploadFileRequest; import com.aliyun.oss.model.UploadFileResult; import Log.Log; /** * 阿里雲檔案上傳 - 簡易版 * */ public class AliyunUploadVersion1 implements IAliyunUpload { /** * 斷點續傳 * */ @Override public String uploadFile(String uploadFile,String savePathName) { OSSClient ossClient = new OSSClient(AliyunConfig.endpoint,AliyunConfig.accessKeyId,AliyunConfig.accessKeySecret); try { UploadFileRequest uploadFileRequest = new UploadFileRequest(AliyunConfig.bucketName,savePathName); // 待上傳的本地檔案 uploadFileRequest.setUploadFile(uploadFile); // 設定併發下載數,預設1 uploadFileRequest.setTaskNum(5); // 設定分片大小,預設100KB uploadFileRequest.setPartSize(1024 * 1024 * 1); // 開啟斷點續傳,預設關閉 uploadFileRequest.setEnableCheckpoint(true); UploadFileResult uploadResult = ossClient.uploadFile(uploadFileRequest); CompleteMultipartUploadResult multipartUploadResult = uploadResult.getMultipartUploadResult(); return multipartUploadResult.getLocation(); } catch (OSSException oe) { Log.e("*************************************************OSS upload file error create_date " + tool.Tool.getDate() + "*************************************"); Log.e("Caught an OSSException,which means your request made it to OSS," + "but was rejected with an error response for some reason."); Log.e("Error Message: " + oe.getErrorCode()); Log.e("Error Code: " + oe.getErrorCode()); Log.e("Request ID: " + oe.getRequestId()); Log.e("Host ID: " + oe.getHostId()); Log.e("*************************************************OSS upload file error*************************************"); } catch (ClientException ce) { Log.e("Caught an ClientException,which means the client encountered " + "a serious internal problem while trying to communicate with OSS," + "such as not being able to access the network."); Log.e("Error Message: " + ce.getMessage()); } catch (Throwable e) { e.printStackTrace(); } finally { ossClient.shutdown(); } return null; } }
檔案上傳容器
package aliyun.upload; import org.springframework.stereotype.Repository; @Repository("aliyun_upload") public class AliyunUpload extends AliyunUploadVersion1 { /** * 上傳檔案 * */ @Override public String uploadFile(String filePath,String savePathName) { return super.uploadFile(filePath,savePathName); } }
spring.beans.service.UploadService 檔案上傳服務
package spring.beans.service; import java.io.File; import java.io.IOException; import java.util.Date; import javax.servlet.http.HttpServletRequest; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import aliyun.upload.AliyunUpload; import tool.RandomNumStr; import tool.Tool; @Service(value="upload_service") public class UploadService { //預設 本地儲存路徑 private final String save_local_path = "D:/java_class/Company/WebRoot/"; //預設 檔案儲存路徑 private String save_context_path = "Upload/images/"; public void setSavePath(String savePath) { this.save_context_path = savePath; } /** * 阿里雲檔案上傳 * @param * MultipartFile file 檔案流 * @return * String 檔案引用路徑 如 String filePath = "http://aliyun.xxxx.xxxx/xxxx/xxxx/xxxx.jpg" * */ public String aliyunUploadFile(MultipartFile file) { //獲取檔名稱 String fileName = file.getOriginalFilename(); //生成儲存路徑 String save_handler_path = save_local_path + save_context_path; //獲得檔案字尾 String prefix=fileName.substring(fileName.lastIndexOf(".")); //儲存目錄 File parentDir = new File(save_handler_path); //儲存目錄是否存在 if(!parentDir.exists()) { parentDir.mkdirs(); } //生成檔案儲存名稱 String fileSaveName = RandomNumStr.createRandomString(7) + String.valueOf(new Date().getTime()) + prefix; try{ File saveFile = new File(save_handler_path,fileSaveName); //移動臨時檔案 file.transferTo(saveFile); //新增阿里雲檔案上傳 AliyunUpload aliyunUpload = new AliyunUpload(); String fileUrl = aliyunUpload.uploadFile(save_handler_path+fileSaveName,save_context_path+fileSaveName); saveFile.delete(); return fileUrl; }catch(IOException e) { return null; } } /** * 檔案儲存 * @param * MyltipartFile file 檔案資源 * @return * 檔案檔案儲存地址 * */ public String localUploadFile(MultipartFile file,HttpServletRequest request) { //獲取檔名稱 String fileName = file.getOriginalFilename(); //生成儲存路徑 String save_handler_path = save_local_path + save_context_path; //獲得檔案字尾 String prefix=fileName.substring(fileName.lastIndexOf(".")); //儲存目錄 File parentDir = new File(save_handler_path); //儲存目錄是否存在 if(!parentDir.exists()) { parentDir.mkdirs(); } //生成檔案儲存名稱 String fileSaveName = RandomNumStr.createRandomString(7) + String.valueOf(new Date().getTime()) + prefix; try{ //移動臨時檔案 file.transferTo(new File(save_handler_path,fileSaveName)); //檔案地址 return Tool.getDomain(request) + save_context_path + fileSaveName; }catch(IOException e) { return null; } } }
更多關於java演算法相關內容感興趣的讀者可檢視本站專題:《Java檔案與目錄操作技巧彙總》、《Java資料結構與演算法教程》、《Java操作DOM節點技巧總結》和《Java快取操作技巧彙總》
希望本文所述對大家java程式設計有所幫助。