圖片存儲解決方案
學習自黑馬：視頻地址
開發一個圖片上傳服務，需要有存儲的支持，那么我們的解決方案將有：
- 直接將圖片保存到服務的硬盤
- 優點：開發便捷，成本低
- 缺點：擴容困難
- 使用分布式文件系統進行存儲
- 優點：容易實現擴容
- 缺點：開發復雜度稍大（尤其是開發復雜的功能）
- 使用nfs做存儲
- 優點：開發較為便捷
- 缺點：需要有一定的運維知識進行部署和維護
- 使用第三方的存儲服務
- 優點：開發簡單，擁有強大功能，免維護
- 缺點：付費
阿里雲oss存儲
什么是oss服務？
地址：視頻
海量、安全、低成本、高可靠的雲存儲服務，提供99.999999999%的數據可靠性。使用RESTful API 可以在
互聯網任何位置存儲和訪問，容量和處理能力彈性擴展，多種存儲類型供選擇全面優化存儲成本。
購買服務
使用第三方服務最大的缺點就是需要付費，下面，我們看下如何購買開通服務。
購買下行流量包
說明：OSS的上行流量是免費的，但是下行流量是需要購買的，一般我們的使用購買最低的流量以及存儲，就可以
了，以目前的價格來看，是需要65元人民幣。
開始使用oss
創建Bucket
使用OSS，首先需要創建Bucket，Bucket翻譯成中文是水桶的意思，把存儲的圖片資源看做是水，想要盛水必須得有桶，就是這個意思了。
進入控制台，https://oss.console.aliyun.com/overview
創建完成后，在左側可以看到已經創建好的Bucket：
選擇Bucket后，即可看到對應的信息，如：url、消耗流量等
管理文件
可以通過在線的方式進行管理文件：
實現圖片上傳
1. 導入依賴
<dependency>
<groupId>com.aliyun.oss</groupId> <artifactId>aliyun-sdk-oss</artifactId> <version>2.8.3</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.4</version>
</dependency>
<dependency>
<groupId>joda-time</groupId>
<artifactId>joda-time</artifactId>
<version>2.9.9</version>
</dependency>
2. 編寫aliyun.properties配置文件
aliyun.endpoint=oss-cn-qingdao.aliyuncs.com
aliyun.accessKeyId=LTAIfC7fUsPj7Rfq
aliyun.accessKeySecret=c2Vo3q1AmivtY8lxFnfsCfkO2
c2HCk
aliyun.bucketName=itcast-haoke
aliyun.urlPrefix=http://itcast-haoke.oss-cn-
qingdao.aliyuncs.com/
accessKeyId以及accessKeySecret獲取參考官方文檔:
https://help.aliyun.com/knowledge_detail/48699.html
3.編寫AliyunConfig
package cn.itcast.haoke.dubbo.api.config;
import com.aliyun.oss.OSSClient;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
@Configuration
@PropertySource("classpath:aliyun.properties")
@ConfigurationProperties(prefix = "aliyun")
@Data
public class AliyunConfig {
private String endpoint;
private String accessKeyId;
private String accessKeySecret;
private String bucketName;
private String urlPrefix;
@Bean
public OSSClient oSSClient() {
return new OSSClient(endpoint, accessKeyId, accessKeySecret);
}
}
4. 編寫PicUploadResult
該類用於返回給前端的數據結構定義。
package cn.itcast.haoke.dubbo.api.vo;
import lombok.Data;
@Data
public class PicUploadResult {
// 文件唯一標識
private String uid;
// 文件名
private String name;
// 狀態有：uploading done error removed
private String status;
// 服務端響應內容，如：'{"status": "success"}'
private String response;
}
5. 編寫PicUploadService
具體的上傳邏輯實現，在該類中調用了OSS客戶端的API。
package cn.itcast.haoke.dubbo.api.service;
import cn.itcast.haoke.dubbo.api.config.AliyunConfig;
import cn.itcast.haoke.dubbo.api.vo.PicUploadResult;
import com.aliyun.oss.OSSClient;
import org.apache.commons.lang3.RandomUtils;
import org.apache.commons.lang3.StringUtils;
import org.joda.time.DateTime;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import java.io.ByteArrayInputStream;
@Service
public class PicUploadService {
// 允許上傳的格式
private static final String[] IMAGE_TYPE = new String[]{".bmp", ".jpg",
".jpeg", ".gif", ".png"};
@Autowired
private OSSClient ossClient;
@Autowired
private AliyunConfig aliyunConfig;
public PicUploadResult upload(MultipartFile uploadFile) {
PicUploadResult fileUploadResult = new PicUploadResult();
//圖片做校驗，對后綴名
boolean isLegal = false;
for (String type : IMAGE_TYPE) {
if (StringUtils.endsWithIgnoreCase(uploadFile.getOriginalFilename(),
type)) {
isLegal = true;
break;
}
}
if (!isLegal) {
fileUploadResult.setStatus("error");
return fileUploadResult;
}
// 文件新路徑
String fileName = uploadFile.getOriginalFilename();
String filePath = getFilePath(fileName);
// 上傳到阿里雲
try {
// 目錄結構：images/2018/12/29/xxxx.jpg
ossClient.putObject(aliyunConfig.getBucketName(), filePath, new
ByteArrayInputStream(uploadFile.getBytes()));
} catch (Exception e) {
e.printStackTrace();
//上傳失敗
fileUploadResult.setStatus("error");
return fileUploadResult;
}
// 上傳成功
fileUploadResult.setStatus("done");
fileUploadResult.setName(this.aliyunConfig.getUrlPrefix() + filePath);
fileUploadResult.setUid(String.valueOf(System.currentTimeMillis()));
return fileUploadResult;
}
private String getFilePath(String sourceFileName) {
DateTime dateTime = new DateTime();
return "images/" + dateTime.toString("yyyy")
+ "/" + dateTime.toString("MM") + "/"
+ dateTime.toString("dd") + "/" + System.currentTimeMillis() +
RandomUtils.nextInt(100, 9999) + "." +
StringUtils.substringAfterLast(sourceFileName, ".");
}
}
**6.編寫PicUploadController **
package cn.itcast.haoke.dubbo.api.controller;
import cn.itcast.haoke.dubbo.api.service.PicUploadFileSystemService;
import cn.itcast.haoke.dubbo.api.service.PicUploadService;
import cn.itcast.haoke.dubbo.api.vo.PicUploadResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;
@RequestMapping("pic/upload")
@Controller
public class PicUploadController {
@Autowired
private PicUploadService picUploadService;
// @Autowired
// private PicUploadFileSystemService picUploadService;
@PostMapping
@ResponseBody
public PicUploadResult upload(@RequestParam("file") MultipartFile multipartFile) {
return this.picUploadService.upload(multipartFile);
}
}
==7.測試 ==
根據name中的url進行訪問
添加水印
OSS提供了在線添加水印功能，下面我們來體驗下該功能：
自定義規則：
本地文件系統存儲
1.編寫PicUploadFileSystemService
package cn.itcast.haoke.dubbo.api.service;
import cn.itcast.haoke.dubbo.api.vo.PicUploadResult;
import org.apache.commons.lang3.RandomUtils;
import org.apache.commons.lang3.StringUtils;
import org.joda.time.DateTime;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import java.io.File;
import java.io.IOException;
import java.util.Date;
@Service
public class PicUploadFileSystemService {
// 允許上傳的格式
private static final String[] IMAGE_TYPE = new String[]{".bmp", ".jpg",
".jpeg", ".gif", ".png"};
public PicUploadResult upload(MultipartFile uploadFile) {
// 校驗圖片格式
boolean isLegal = false;
for (String type : IMAGE_TYPE) {
if (StringUtils.endsWithIgnoreCase(uploadFile.getOriginalFilename(),
type)) {
isLegal = true;
break;
}
}
PicUploadResult fileUploadResult = new PicUploadResult();
if (!isLegal) {
fileUploadResult.setStatus("error");
return fileUploadResult;
}
String fileName = uploadFile.getOriginalFilename();
String filePath = getFilePath(fileName);
// 生成圖片的絕對引用地址
String picUrl = StringUtils.replace(StringUtils.substringAfter(filePath,
"F:\\code\\itcast-haoke\\haoke-upload"),
"\\", "/");
fileUploadResult.setName("http://image.haoke.com" + picUrl);
File newFile = new File(filePath);
// 寫文件到磁盤
try {
uploadFile.transferTo(newFile);
} catch (IOException e) {
e.printStackTrace();
//上傳失敗
fileUploadResult.setStatus("error");
return fileUploadResult;
}
fileUploadResult.setStatus("done");
fileUploadResult.setUid(String.valueOf(System.currentTimeMillis()));
return fileUploadResult;
}
private String getFilePath(String sourceFileName) {
String baseFolder = "F:\\code\\itcast-haoke\\haoke-upload" + File.separator
+ "images";
Date nowDate = new Date();
// yyyy/MM/dd
String fileFolder = baseFolder + File.separator + new
DateTime(nowDate).toString("yyyy")
+ File.separator + new DateTime(nowDate).toString("MM") +
File.separator
+ new DateTime(nowDate).toString("dd");
File file = new File(fileFolder);
if (!file.isDirectory()) {
// 如果目錄不存在，則創建目錄
file.mkdirs();
}
// 生成新的文件名
String fileName = new DateTime(nowDate).toString("yyyyMMddhhmmssSSSS")
+ RandomUtils.nextInt(100, 9999) + "." +
StringUtils.substringAfterLast(sourceFileName, ".");
return fileFolder + File.separator + fileName;
}
}
2.修改Controller中的引用
@RequestMapping("pic/upload")
@Controller
public class PicUploadController {
@Autowired
private PicUploadService picUploadService;
// @Autowired
// private PicUploadFileSystemService picUploadService;
@PostMapping
@ResponseBody
public PicUploadResult upload(@RequestParam("file") MultipartFile multipartFile) {
return this.picUploadService.upload(multipartFile);
}
}
如果想訪問到本地的圖片通過網絡
用Nginx
注意修改root的路經；