做這個(gè)功能之前我們需要導(dǎo)入阿里云OSS官方提供的工具包
aliyun-sdk-oss-2.5.0.jar 這個(gè)文件 如果有最新版的話就下載最新版
?
aliyun.upload.AliyunConfig
?
package aliyun.upload;
?
public final class AliyunConfig
{
??? //你的oss所在域肠仪，要加http://?? 不明白可以對(duì)照你的文件引用地址
??? public static Stringendpoint = "http://oss-cn-shenzhen.aliyuncs.com";
?
??? //密匙keyId 可以在阿里云獲取到
??? public static StringaccessKeyId = "xxxxxxx";
?
??? //密匙keySecret 可以在阿里云獲取到
??? public static StringaccessKeySecret = "";
?
??? //你的bucketName 名稱(chēng)?? 即是你的OSS對(duì)象名稱(chēng)? 不明白查oss開(kāi)發(fā)文檔專(zhuān)業(yè)術(shù)語(yǔ)
??? public static StringbucketName = "";
}
aliyun.upload.IAliyunUpload
?
package aliyun.upload;
?
public interface IAliyunUpload
{
??? /**
???? * @param
???? * StringfilePathName 本地圖片路徑（D:/xxxx/xxxx....../xx/xx.jgp|xx.png|..）
???? * StringsavePathName 將要保存到OSS上的路徑地址
???? * */
??? public StringuploadFile(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;
importcom.aliyun.oss.model.CompleteMultipartUploadResult;
importcom.aliyun.oss.model.UploadFileRequest;
importcom.aliyun.oss.model.UploadFileResult;
?
import Log.Log;
?
/**
?* 阿里云文件上傳 - 簡(jiǎn)易版
?* */
public class AliyunUploadVersion1implements IAliyunUpload
{
?
??? /**
???? * 斷點(diǎn)續(xù)傳
???? * */
??? @Override
??? public StringuploadFile(String uploadFile,String savePathName)
??? {
???????OSSClient ossClient = new OSSClient(AliyunConfig.endpoint,AliyunConfig.accessKeyId, AliyunConfig.accessKeySecret);
?
???????try {
???????????UploadFileRequest uploadFileRequest = newUploadFileRequest(AliyunConfig.bucketName,savePathName);
???????????// 待上傳的本地文件
???????????uploadFileRequest.setUploadFile(uploadFile);
?
???????????// 設(shè)置并發(fā)下載數(shù)懈费，默認(rèn)1
???????????uploadFileRequest.setTaskNum(5);
???????????// 設(shè)置分片大小，默認(rèn)100KB
???????????uploadFileRequest.setPartSize(1024 * 1024 * 1);
???????????// 開(kāi)啟斷點(diǎn)續(xù)傳技羔，默認(rèn)關(guān)閉
???????????uploadFileRequest.setEnableCheckpoint(true);
?
???????????UploadFileResult uploadResult = ossClient.uploadFile(uploadFileRequest);
?
???????????CompleteMultipartUploadResult multipartUploadResult =
???????????????????uploadResult.getMultipartUploadResult();
???????????return multipartUploadResult.getLocation();
???????} catch (OSSException oe) {
?
???????????Log.e("*************************************************OSS upload fileerror? 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("HostID:?????????? " +oe.getHostId());
???????????Log.e("*************************************************OSS upload fileerror*************************************");
???????} 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;
?
importorg.springframework.stereotype.Repository;
?
@Repository("aliyun_upload")
public class AliyunUpload extendsAliyunUploadVersion1
{
?
??? /**
???? * 上傳文件
???? * */
??? @Override
??? public StringuploadFile(String filePath,String savePathName)
??? {
???????return super.uploadFile(filePath,savePathName);
??? }
?
}??
spring.beans.service.UploadService 文件上傳服務(wù)
?
package spring.beans.service;
?
import java.io.File;
import java.io.IOException;
import java.util.Date;
?
importjavax.servlet.http.HttpServletRequest;
?
importorg.springframework.stereotype.Service;
importorg.springframework.web.multipart.MultipartFile;
?
import aliyun.upload.AliyunUpload;
import tool.RandomNumStr;
import tool.Tool;
?
@Service(value="upload_service")
public class UploadService
{
??? //默認(rèn) 本地存儲(chǔ)路徑
??? private final Stringsave_local_path = "D:/java_class/Company/WebRoot/";
?
??? //默認(rèn)? 文件保存路徑
??? private Stringsave_context_path = "Upload/images/";
?
??? public voidsetSavePath(String savePath)
??? {
???????this.save_context_path = savePath;
??? }
?
??? /**
???? * 阿里云文件上傳
???? * @param
???? * MultipartFilefile 文件流
???? * @return
???? * String 文件引用路徑 如 String filePath ="http://aliyun.xxxx.xxxx/xxxx/xxxx/xxxx.jpg"
???? * */
??? public StringaliyunUploadFile(MultipartFile file)
??? {
???????//獲取文件名稱(chēng)
???????String fileName = file.getOriginalFilename();
?
???????//生成存儲(chǔ)路徑
???????String save_handler_path = save_local_path + save_context_path;
?
???????//獲得文件后綴
???????String prefix=fileName.substring(fileName.lastIndexOf("."));
?
???????//存儲(chǔ)目錄
???????File parentDir = new File(save_handler_path);
?
???????//存儲(chǔ)目錄是否存在
???????if(!parentDir.exists())
???????{
???????????parentDir.mkdirs();
???????}
?
???????//生成文件存儲(chǔ)名稱(chēng)
???????String fileSaveName = RandomNumStr.createRandomString(7) + String.valueOf(newDate().getTime()) + prefix;
?
???????try{
???????????File saveFile = new File(save_handler_path,fileSaveName);
???????????//移動(dòng)臨時(shí)文件
???????????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;
???????}
??? }
?
??? /**
???? * 文件存儲(chǔ)
???? * @param
???? * MyltipartFilefile 文件資源
???? * @return
???? * 文件文件存儲(chǔ)地址
???? * */
??? public StringlocalUploadFile(MultipartFile file,HttpServletRequest request)
??? {
???????//獲取文件名稱(chēng)
???????String fileName = file.getOriginalFilename();
?
???????//生成存儲(chǔ)路徑
??????? Stringsave_handler_path = save_local_path + save_context_path;
?
???????//獲得文件后綴
???????String prefix=fileName.substring(fileName.lastIndexOf("."));
?
???????//存儲(chǔ)目錄
???????File parentDir = new File(save_handler_path);
?
???????//存儲(chǔ)目錄是否存在
???????if(!parentDir.exists())
???????{
???????????parentDir.mkdirs();
???????}
?
???????//生成文件存儲(chǔ)名稱(chēng)
???????String fileSaveName = RandomNumStr.createRandomString(7) + String.valueOf(newDate().getTime()) + prefix;
?
???????try{
???????????//移動(dòng)臨時(shí)文件
???????????file.transferTo(new File(save_handler_path,fileSaveName));
?
???????????//文件地址
???????????return Tool.getDomain(request) + save_context_path + fileSaveName;
???????}catch(IOException e)
???????{
???????????return null;
???????}
??? }
}
?
