阿里云對象存儲 阿里云官網(wǎng)點擊

阿里云對象存儲OSS（Object Storage Service）是一款海量、安全、低成本、高可靠的云存儲服務(wù)，提供99.9999999999%(12個9)的數(shù)據(jù)持久性，99.995%的數(shù)據(jù)可用性。多種存儲類型供選擇，全面優(yōu)化存儲成本。【源于官網(wǎng)】

首先來看注冊和手動申請阿里云OSS倉庫

1 點擊進(jìn)入管理控制臺

2 控制臺頁面

3 創(chuàng)建自己的Bucket

4 按照下面的方式創(chuàng)建Bucket

5 點擊確定即可，經(jīng)過以上過程，即成功申請了阿里云OSS云存儲倉庫

下面介紹使用Java API 操作 OSS

1 配置依賴，參考

java 8及以下，使用Maven在pom.xml中引入

<dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId><version>3.10.2</version> </dependency>

如果是Java9及以上或者用Eclipse開發(fā)具體可參見官方文檔

2 Java API操作OSS

多種編程語言的API 點擊進(jìn)入
使用Java API操作OSS其實有官方文檔可以借鑒，點擊JavaAPI文檔，在文檔中，不難發(fā)現(xiàn)，每一個功能前面都有一系列的Access賬號的認(rèn)證，如下圖所示

下面說說賬號怎么設(shè)置

1 點擊進(jìn)入 OSS 控制臺 進(jìn)入
選擇訪問控制 RAM 進(jìn)入，其實AccessKey也可以，但是主要影響整個倉庫的安全性，所以推薦使用 箭頭指向的那個

2 點擊進(jìn)去，創(chuàng)建用戶

3 創(chuàng)建完用戶后，進(jìn)行權(quán)限設(shè)置

4 在搜索框中輸入 oss 將四個 OSS的權(quán)限，都加進(jìn)去。

如果加入成功，加入過的會變灰

使用程序進(jìn)行訪問OSS

1 將上面的用戶信息配置到項目的 application.yml


加入下面的代碼段

alioss:endpoint: oss-cn-your location.aliyuncs.comaccessKeyId: your AccessKeyIdaccessKeySecret: your AccessKeySecretbucketName: your bucket name

其中endpoint在

2 創(chuàng)建OSS實體類

import org.springframework.stereotype.Component; /* Data：set get 方法 Component: Spring 掃描 ConfigurationProperties: 與 application.yml中的屬性名保持一致*/ @ConfigurationProperties(prefix= "alioss") @Component @Data public class OssEntity {private String endpoint;private String accessKeyId;private String accessKeySecret;private String bucketName; }

3 創(chuàng)建Service 接口

import java.io.IOException;public interface AliOssService {/*** 創(chuàng)建存儲空間*/void createBucket();/*** 上傳文件* @param file 文件對象* @return*/String upload(MultipartFile file);/*** 下載文件* @throws IOException*/void download(String fileName) throws IOException;/*** 列舉文件*/void listFile();/*** 刪除文件*/void deleteFile(String fileName); }

4 ServiceImpl類
可借鑒OSS Java API 開發(fā)文檔

import com.aliyun.oss.OSS; import com.aliyun.oss.OSSClientBuilder; import com.aliyun.oss.model.*; import com.s.system.entity.OssEntity; import com.s.system.service.AliOssService; import net.sf.jsqlparser.expression.DateTimeLiteralExpression; import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile;import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.util.Date; import java.util.UUID; //在創(chuàng)建AliOssServiceImpl類的時候?qū)傩灾捣庋b @Service public class AliOssServiceImpl implements AliOssService, InitializingBean {@Autowiredprivate OssEntity ossEntity;//存放endpoint地址private String endpoint;private String accessKeyId;private String accessKeySecret;private String bucketName;@Overridepublic void createBucket() {// 創(chuàng)建OSSClient實例。OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);if (ossClient.doesBucketExist(bucketName)) {throw new RuntimeException(bucketName + "在對象存儲的Bucket列表中已經(jīng)存在");}// 創(chuàng)建存儲空間。ossClient.createBucket(bucketName);// 關(guān)閉OSSClient。ossClient.shutdown();}@Overridepublic String upload(MultipartFile file) {//上傳地址String uploadUrl = null;try {//判斷oss實例是否存在：如果不存在則創(chuàng)建，如果存在則獲取// 創(chuàng)建OSSClient實例。OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);if (!ossClient.doesBucketExist(bucketName)) {//創(chuàng)建bucketossClient.createBucket(bucketName);//設(shè)置oss實例的訪問權(quán)限：公共讀ossClient.setBucketAcl(bucketName, CannedAccessControlList.PublicRead);}//獲取上傳文件流InputStream inputStream = file.getInputStream();//構(gòu)建日期路徑：avatar/2020/07/31/文件名String datePath = new DateTimeLiteralExpression.DateTime().toString("yyyy/MM/dd");//文件名：uuid.擴展名//獲取上傳文件的全名稱String original = file.getOriginalFilename();//去掉uuid中生成的-String fileName = UUID.randomUUID().toString().replaceAll("-", "");//截取掉文件獲得擴展名String fileType = original.substring(original.lastIndexOf("."));//uuid+.jpg/.pngString newName = fileName + fileType;// yyyy/MM/dd+/uuid+.jpg/.pngfileName = datePath + "/" + newName;//如果想要實現(xiàn)圖片的預(yù)覽效果,一定要設(shè)置一下幾個點//1.設(shè)置文件 ACL為反正不能為私有 要么是公共讀,要么是公共讀寫//2.一定要設(shè)置文本類型為(image/jpg)ObjectMetadata objectMetadata = new ObjectMetadata();//設(shè)置公共讀權(quán)限objectMetadata.setObjectAcl(CannedAccessControlList.PublicRead);//設(shè)置類型objectMetadata.setContentType(getcontentType(fileName.substring(fileName.lastIndexOf("."))));//文件上傳至阿里云ossClient.putObject(bucketName, fileName, inputStream, objectMetadata);// 關(guān)閉OSSClient。ossClient.shutdown();//默認(rèn)十年不過期Date expiration = new Date(System.currentTimeMillis() + 3600L * 1000 * 24 * 365 * 10);//bucket名稱 文件名 過期時間uploadUrl = ossClient.generatePresignedUrl(bucketName, fileName, expiration).toString();//獲取url地址//uploadUrl = "https://" + bucketName + "." + endPoint + "/" + fileName;} catch (IOException e) {e.printStackTrace();}return uploadUrl.substring(0, uploadUrl.indexOf("?"));//return uploadUrl;}@Overridepublic void download(String fileName) throws IOException {// <yourObjectName>從OSS下載文件時需要指定包含文件后綴在內(nèi)的完整路徑，例如abc/efg/123.jpg。String objectName = fileName;// 創(chuàng)建OSSClient實例。OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);// 調(diào)用ossClient.getObject返回一個OSSObject實例，該實例包含文件內(nèi)容及文件元信息。OSSObject ossObject = ossClient.getObject(bucketName, objectName);// 調(diào)用ossObject.getObjectContent獲取文件輸入流，可讀取此輸入流獲取其內(nèi)容。InputStream content = ossObject.getObjectContent();if (content != null) {BufferedReader reader = new BufferedReader(new InputStreamReader(content));while (true) {String line = reader.readLine();if (line == null) {break;}System.out.println("\n" + line);}// 數(shù)據(jù)讀取完成后，獲取的流必須關(guān)閉，否則會造成連接泄漏，導(dǎo)致請求無連接可用，程序無法正常工作。content.close();}// 關(guān)閉OSSClient。ossClient.shutdown();}@Overridepublic void listFile() {// 創(chuàng)建OSSClient實例。OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);// ossClient.listObjects返回ObjectListing實例，包含此次listObject請求的返回結(jié)果。ObjectListing objectListing = ossClient.listObjects(bucketName);// objectListing.getObjectSummaries獲取所有文件的描述信息。for (OSSObjectSummary objectSummary : objectListing.getObjectSummaries()) {System.out.println(" - " + objectSummary.getKey() + " " +"(size = " + objectSummary.getSize() + ")");}// 關(guān)閉OSSClient。ossClient.shutdown();}@Overridepublic void deleteFile(String fileName) {// <yourObjectName>從OSS下載文件時需要指定包含文件后綴在內(nèi)的完整路徑，例如abc/efg/123.jpg。String objectName = fileName;// 創(chuàng)建OSSClient實例。OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);// 刪除文件。ossClient.deleteObject(bucketName, objectName);// 關(guān)閉OSSClient。ossClient.shutdown();}//初始化Bean之后需要進(jìn)行的操作@Overridepublic void afterPropertiesSet() throws Exception { Endpoint以杭州為例，其它Region請按實際情況填寫。endpoint = ossEntity.getEndpoint(); 阿里云主賬號AccessKey擁有所有API的訪問權(quán)限，風(fēng)險很高。強烈建議您創(chuàng)建并使用RAM賬號進(jìn)行API訪問或日常運維，請登錄RAM控制臺創(chuàng)建RAM賬號。accessKeyId = ossEntity.getAccessKeyId();accessKeySecret = ossEntity.getAccessKeySecret();bucketName = ossEntity.getBucketName();}/*** Description: 判斷OSS服務(wù)文件上傳時文件的contentType** @param FilenameExtension 文件后綴* @return String*/public static String getcontentType(String FilenameExtension) {if (FilenameExtension.equalsIgnoreCase(".bmp")) {return "image/bmp";}if (FilenameExtension.equalsIgnoreCase(".gif")) {return "image/gif";}if (FilenameExtension.equalsIgnoreCase(".jpeg") ||FilenameExtension.equalsIgnoreCase(".jpg") ||FilenameExtension.equalsIgnoreCase(".png")) {return "image/jpg";}if (FilenameExtension.equalsIgnoreCase(".html")) {return "text/html";}if (FilenameExtension.equalsIgnoreCase(".txt")) {return "text/plain";}if (FilenameExtension.equalsIgnoreCase(".vsd")) {return "application/vnd.visio";}if (FilenameExtension.equalsIgnoreCase(".pptx") ||FilenameExtension.equalsIgnoreCase(".ppt")) {return "application/vnd.ms-powerpoint";}if (FilenameExtension.equalsIgnoreCase(".docx") ||FilenameExtension.equalsIgnoreCase(".doc")) {return "application/msword";}if (FilenameExtension.equalsIgnoreCase(".xml")) {return "text/xml";}return "image/jpg";} }

5 測試

import com.s.system.entity.OssEntity; import com.s.system.service.AliOssService; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest;@SpringBootTest public class OssTest {@Autowiredprivate OssEntity ossEntity;@Autowiredprivate AliOssService aliOssService;@Testpublic void contextLoads(){aliOssService.createBucket();System.out.println(ossEntity.toString());}}

測試通過后，可以發(fā)現(xiàn)，這個錯誤主要是在 aplication.yml 中已經(jīng)存在了 該 bucket，可以自行再將 application.yml 中的 bucketName: your bucket name 定義一個新的名字，就可以通過了。這也就說明OSS Demo 測試通過，可以進(jìn)行下面的開發(fā)了。

總結(jié)

以上是生活随笔為你收集整理的【测试Demo】JavaAPI操作阿里云对象存储(OSS)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。