java實現(xiàn)上傳文件到oss(阿里云)功能示例
本文實例講述了java實現(xiàn)上傳文件到oss(阿里云)功能。分享給大家供大家參考,具體如下:
做這個功能之前我們需要導(dǎo)入阿里云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開發(fā)文檔專業(yè)術(shù)語
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
{
/**
* 斷點續(xù)傳
* */
@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);
// 設(shè)置并發(fā)下載數(shù),默認1
uploadFileRequest.setTaskNum(5);
// 設(shè)置分片大小,默認100KB
uploadFileRequest.setPartSize(1024 * 1024 * 1);
// 開啟斷點續(xù)傳,默認關(guān)閉
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 文件上傳服務(wù)
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;
}
}
}
更多關(guān)于java算法相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《Java文件與目錄操作技巧匯總》、《Java數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Java操作DOM節(jié)點技巧總結(jié)》和《Java緩存操作技巧匯總》
希望本文所述對大家java程序設(shè)計有所幫助。
相關(guān)文章
Java實戰(zhàn)花店商城系統(tǒng)的實現(xiàn)流程
只學(xué)書上的理論是遠遠不夠的,只有在實戰(zhàn)中才能獲得能力的提升,本篇文章手把手帶你用java+Springboot+Maven+mybatis+Vue+Mysql實現(xiàn)一個花店商城系統(tǒng),大家可以在過程中查缺補漏,提升水平2022-01-01

