目录
1 图片存储方案1.1 介绍1.2 七牛云存储1.2.1 注册、登录1.2.2 新建存储空间1.2.3 查看存储空间信息1.2.4 开发者中心1.2.5 鉴权1.2.6 Java SDK操作七牛云1.2.7 封装工具类小结2 阿里云OSS图片上传2.1 图片存储解决方案2.2 阿里云OSS存储2.2.1 什么是OSS服务？2.2.2 购买服务2.2.3 创建Bucket2.2.4、创建用户2.3 导入依赖2.4 OSS配置2.5 PicUploadService2.6 PicUploadController1 图片存储方案
1.1 介绍
在实际开发中，我们会有很多处理不同功能的服务器。例如：
应用服务器：负责部署我们的应用
数据库服务器：运行我们的数据库
应用和数据库服务器 一般 内网
文件服务器：负责存储用户上传文件的服务器
分服务器处理的目的是让服务器各司其职，从而提高我们项目的运行效率。
常见的图片存储方案：
方案一：使用nginx(反向代理服务器)搭建图片服务器，网络资源
nginx对静态资源 处理非常好，图片服务器nginx可以配置指向静态文件目录的映射 80nginx（可以做负载均衡的） + tomcat（多个）
方案二：使用开源的分布式文件存储系统，例如Fastdfs、HDFS等
上万台服务器，存储图片文件存储的时候，是按照一定格式存储的，有优化，检索速度快，索引
方案三：使用云存储，例如阿里云、七牛云等
分布式文件存储系统
为什么要使用云存储？
我们的应用服务器带宽是有限的，如果将头像都存储在应用服务器上，如果很多用户同时下载头像，那么我们的应用服务器就会造成网络拥堵（比如你的舍友和你共同使用一个宽带，你正在玩游戏，你的舍友正在用迅雷下载，你玩游戏的时候就会觉得有点卡）。
一旦造成网络拥堵，就会造成应用服务器别的服务不可用，用户在使用应用的时候就会觉得卡顿，进而流失用户，老板破产，你的工资也拿不到了~~，好尴尬！！
解决方案就是将图片单独存储，用户直接访问图片服务器，比如微信的用户头像，抖音的视频，微博的图片，都是存储在单独的图片服务器上，提供独立的访问地址。
如果图片数量很少，我们可以使用nginx搭建图片服务器，如果图片数量很多，那么我们就要搭建分布式的文件存储服务器，这就涉及到一个问题，带宽是很贵的，非常贵（一个直观的例子，抖音的每日付出的流量费用就达到了上千万），所以对于中小公司来说，自建图片存储服务器就显得没有必要了，成本太高。
云储存是按使用空间和流量付费，云存储服务提供商因为可以最大限度的利用带宽资源，所以使用者付出的成本远远低于自建。
1.2 七牛云存储
七牛云（隶属于上海七牛信息技术有限公司）是国内领先的以视觉智能和数据智能为核心的企业级云计算服务商，同时也是国内知名智能视频云服务商，累计为 70 多万家企业提供服务，覆盖了国内80%网民。围绕富媒体场景推出了对象存储、融合 CDN 加速、容器云、大数据平台、深度学习平台等产品、并提供一站式智能视频云解决方案。为各行业及应用提供可持续发展的智能视频云生态，帮助企业快速上云，创造更广阔的商业价值。
golang语言
官网：/
通过七牛云官网介绍我们可以知道其提供了多种服务，我们主要使用的是七牛云提供的对象存储服务来存储图片。
1.2.1 注册、登录
要使用七牛云的服务，首先需要注册成为会员。地址：/signup
注册完成后就可以使用刚刚注册的邮箱和密码登录到七牛云：
登录成功后点击页面右上角管理控制台：
注意：登录成功后还需要进行实名认证才能进行相关操作。
1.2.2 新建存储空间
要进行图片存储，我们需要在七牛云管理控制台新建存储空间。点击管理控制台首页对象存储下的立即添加按钮，页面跳转到新建存储空间页面：
可以创建多个存储空间，各个存储空间是相互独立的。
1.2.3 查看存储空间信息
存储空间创建后，会在左侧的存储空间列表菜单中展示创建的存储空间名称，点击存储空间名称可以查看当前存储空间的相关信息
1.2.4 开发者中心
使用第三方工具：
1. 看文档2. 看文档3. 看文档
可以通过七牛云提供的开发者中心学习如何操作七牛云服务，地址：/
点击对象存储，跳转到对象存储开发页面，地址：/kodo
七牛云提供了多种方式操作对象存储服务，本项目采用Java SDK方式，地址：/kodo/sdk/1239/java
使用Java SDK操作七牛云需要导入如下maven坐标：
<dependency><groupId>com.qiniu</groupId><artifactId>qiniu-java-sdk</artifactId><version>7.2.0</version></dependency>
1.2.5 鉴权
Java SDK的所有的功能，都需要合法的授权。授权凭证的签算需要七牛账号下的一对有效的Access Key和Secret Key，这对密钥可以在七牛云管理控制台的个人中心（/user/key）获得，如下图：
AccessKey是用户端持有的，用于加密传输内容，SecretKey是服务端持有的，用于校验AccessKey是否合法
1.2.6 Java SDK操作七牛云
本章节我们就需要使用七牛云提供的Java SDK完成图片上传和删除，我们可以参考官方提供的例子。
//构造一个带指定Zone对象的配置类Configuration cfg = new Configuration(Zone.zone0());//...其他参数参考类注释UploadManager uploadManager = new UploadManager(cfg);//...生成上传凭证，然后准备上传String accessKey = "your access key";String secretKey = "your secret key";String bucket = "your bucket name";//如果是Windows情况下，格式是 D:\\qiniu\\test.pngString localFilePath = "/home/qiniu/test.png";//默认不指定key的情况下，以文件内容的hash值作为文件名String key = null;Auth auth = Auth.create(accessKey, secretKey);String upToken = auth.uploadToken(bucket);try {Response response = uploadManager.put(localFilePath, key, upToken);//解析上传成功的结果DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);System.out.println(putRet.key);System.out.println(putRet.hash);} catch (QiniuException ex) {Response r = ex.response;System.err.println(r.toString());try {System.err.println(r.bodyString());} catch (QiniuException ex2) {//ignore}}//构造一个带指定Zone对象的配置类Configuration cfg = new Configuration(Zone.zone0());//...其他参数参考类注释String accessKey = "your access key";String secretKey = "your secret key";String bucket = "your bucket name";String key = "your file key";Auth auth = Auth.create(accessKey, secretKey);BucketManager bucketManager = new BucketManager(auth, cfg);try {bucketManager.delete(bucket, key);} catch (QiniuException ex) {//如果遇到异常，说明删除失败System.err.println(ex.code());System.err.println(ex.response.toString());}
1.2.7 封装工具类
为了方便操作七牛云存储服务，我们可以将官方提供的案例简单改造成一个工具类，在我们的项目中直接使用此工具类来操作就可以：
package com.oldlu.utils;import com.google.gson.Gson;import mon.QiniuException;import mon.Zone;import com.qiniu.http.Response;import com.qiniu.storage.BucketManager;import com.qiniu.storage.Configuration;import com.qiniu.storage.UploadManager;import com.qiniu.storage.model.DefaultPutRet;import com.qiniu.util.Auth;import java.io.File;import java.io.FileInputStream;import java.io.InputStream;/*** 七牛云工具类*/public class QiniuUtils {public static String accessKey = "dulF9Wze9bxujtuRvu3yyYb9JX1Sp23jzd3tO708";public static String secretKey = "vZkhW7iot3uWwcWz9vXfbaP4JepdWADFDHVLMZOe";public static String bucket = "qiniutest";public static void upload2Qiniu(String filePath,String fileName){//构造一个带指定Zone对象的配置类Configuration cfg = new Configuration(Zone.zone0());UploadManager uploadManager = new UploadManager(cfg);Auth auth = Auth.create(accessKey, secretKey);String upToken = auth.uploadToken(bucket);try {Response response = uploadManager.put(filePath, fileName, upToken);//解析上传成功的结果DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);} catch (QiniuException ex) {Response r = ex.response;try {System.err.println(r.bodyString());} catch (QiniuException ex2) {//ignore}}}//上传文件public static void upload2Qiniu(byte[] bytes, String fileName){//构造一个带指定Zone对象的配置类Configuration cfg = new Configuration(Zone.zone0());//...其他参数参考类注释UploadManager uploadManager = new UploadManager(cfg);//默认不指定key的情况下，以文件内容的hash值作为文件名String key = fileName;Auth auth = Auth.create(accessKey, secretKey);String upToken = auth.uploadToken(bucket);try {Response response = uploadManager.put(bytes, key, upToken);//解析上传成功的结果DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);System.out.println(putRet.key);System.out.println(putRet.hash);} catch (QiniuException ex) {Response r = ex.response;System.err.println(r.toString());try {System.err.println(r.bodyString());} catch (QiniuException ex2) {//ignore}}}//删除文件public static void deleteFileFromQiniu(String fileName){//构造一个带指定Zone对象的配置类Configuration cfg = new Configuration(Zone.zone0());String key = fileName;Auth auth = Auth.create(accessKey, secretKey);BucketManager bucketManager = new BucketManager(auth, cfg);try {bucketManager.delete(bucket, key);} catch (QiniuException ex) {//如果遇到异常，说明删除失败System.err.println(ex.code());System.err.println(ex.response.toString());}}}
将此工具类放在health_common工程中，后续会使用到。
小结
图片等静态资源和服务分开存放，以此来减少服务器的压力，架构设计使用第三方服务的时候，要多看文档，一般都会提供示例程序，先从示例程序开始，做成自己的工具包。2 阿里云OSS图片上传
2.1 图片存储解决方案
实现图片上传服务，需要有存储的支持，那么我们的解决方案将以下几种：
直接将图片保存到服务的硬盘 优点：开发便捷，成本低缺点：扩容困难 使用分布式文件系统进行存储 优点：容易实现扩容缺点：开发复杂度稍大（有成熟的产品可以使用，比如：FastDFS） 使用nfs做存储 优点：开发较为便捷缺点：需要有一定的运维知识进行部署和维护 使用第三方的存储服务 优点：开发简单，拥有强大功能，免维护缺点：付费
在本套课程中选用阿里云的OSS服务进行图片存储。
2.2 阿里云OSS存储
2.2.1 什么是OSS服务？
地址：/product/oss
2.2.2 购买服务
使用第三方服务最大的缺点就是需要付费，下面，我们看下如何购买开通服务。
购买下行流量包： （不购买也可以使用，按照流量付费）
说明：OSS的上行流量是免费的，但是下行流量是需要购买的。
2.2.3 创建Bucket
使用OSS，首先需要创建Bucket，Bucket翻译成中文是水桶的意思，把存储的图片资源看做是水，想要盛水必须得有桶，就是这个意思了。
进入控制台，https://oss./overview
选择Bucket后，即可看到对应的信息，如：url、消耗流量等 :
文件管理：
查看文件：
2.2.4、创建用户
创建用户的方式与短信接口中的方式一样，需要设置oss权限。
2.3 导入依赖
<dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId><version>2.8.3</version></dependency><dependency><groupId>joda-time</groupId><artifactId>joda-time</artifactId><version>2.5</version></dependency>
2.4 OSS配置
aliyun.properties：
aliyun.endpoint = http://oss-cn-aliyun.accessKeyId = LTAI4FuH6QpFxcsEb6boSRn2aliyun.accessKeySecret = 5fmPjtxxCPfIBznMzN5KE0wz9p0t1Baliyun.bucketName= oldlu-devaliyun.urlPrefix=http://oldlu-dev.oss-cn-/
AliyunConfig：
package com.oldlu.sso.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")@Datapublic class AliyunConfig {private String endpoint;private String accessKeyId;private String accessKeySecret;private String bucketName;private String urlPrefix;@Beanpublic OSSClient oSSClient() {return new OSSClient(endpoint, accessKeyId, accessKeySecret);}}
2.5 PicUploadService
package com.oldlu.sso.service;import com.aliyun.oss.OSSClient;import com.oldlu.sso.config.AliyunConfig;import com.oldlu.sso.vo.PicUploadResult;import mons.lang3.RandomUtils;import mons.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;@Servicepublic class PicUploadService {// 允许上传的格式private static final String[] IMAGE_TYPE = new String[]{".bmp", ".jpg",".jpeg", ".gif", ".png"};@Autowiredprivate OSSClient ossClient;@Autowiredprivate 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//12/29/xxxx.jpgossClient.putObject(aliyunConfig.getBucketName(), filePath, newByteArrayInputStream(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, ".");}}
所需其他的代码：
PicUploadResult:
package com.oldlu.sso.vo;import lombok.Data;@Datapublic class PicUploadResult {// 文件唯一标识private String uid;// 文件名private String name;// 状态有：uploading done error removedprivate String status;// 服务端响应内容，如：'{"status": "success"}'private String response;}
2.6 PicUploadController
package com.oldlu.sso.controller;import com.oldlu.sso.service.PicUploadService;import com.oldlu.sso.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")@Controllerpublic class PicUploadController {@Autowiredprivate PicUploadService picUploadService;@PostMapping@ResponseBodypublic PicUploadResult upload(@RequestParam("file") MultipartFile multipartFile) {return this.picUploadService.upload(multipartFile);}}
