为什么要使用七牛云

一直以来很多公司，都在自己的服务器来存储自己的照片,这样非常的耗费带宽，同时每一次服务器迁移都会出现图片找不到的情况，七牛云就刚好的帮我们解决了这个问题，我们只需要给图片的URL存储到我们的数据库中，就可以做到高效且快速的图片浏览，节约我们的服务器的带宽。

七牛云的控制台

1.首先我们要在七牛云上设置我们空间，设置秘钥，通过他们的JAR包，集成到项目就可以调用七牛云的端口啦。

代码基于springBoot 2.0的。Java8

先写一个上传的工具类

package com.keelon.job.util;

import com.google.gson.Gson;

import com.qiniu.common.QiniuException;

import com.qiniu.common.Zone;

import com.qiniu.http.Response;

import com.qiniu.storage.Configuration;

import com.qiniu.storage.UploadManager;

import com.qiniu.storage.model.DefaultPutRet;

import com.qiniu.util.Auth;

//import org.apache.log4j.Logger;

import org.springframework.web.multipart.MultipartFile;

import java.io.ByteArrayInputStream;

import java.io.File;

import java.io.IOException;

import java.io.UnsupportedEncodingException;

import java.util.UUID;

public class QiniuUtil {

//设置好账号的ACCESS_KEY和SECRET_KEY

final String ACCESS_KEY = "aObyrVTNwP0MP0kg0IyFrkB92q7cboWSZL4LggKn";

final String SECRET_KEY = "Ua3zlnAE-2Tu99IRIAoyfCw3J4O1u-IB9dpSCFQu";

//要上传的空间

final String BUCKET_NAME = "51job";

/**

* 七牛云上传图片

* @param localFilePath

* @return

*/

public String uoloapQiniu (File localFilePath,String fileName){

//构造一个带指定Zone对象的配置类

Configuration cfg;

cfg = new Configuration(Zone.zone2());

//...其他参数参考类注释

UploadManager uploadManager = new UploadManager(cfg);

//...生成上传凭证，然后准备上传

String accessKey = ACCESS_KEY;

String secretKey = SECRET_KEY;

String bucket = BUCKET_NAME;

//如果是Windows情况下，格式是 D:23912475_130759767000_2.jpg

// String localFilePath = "D:23912475_130759767000_2.jpg";

// String localFilePath = "/home/qiniu/test.png";

//默认不指定key的情况下，以文件内容的hash值作为文件名

String key = "images/"+fileName+"tId="+System.currentTimeMillis();

Auth auth = Auth.create(accessKey, secretKey);

String upToken = auth.uploadToken(bucket);

String result = null;

try {

Response response = uploadManager.put(localFilePath, key, upToken);

//解析上传成功的结果

DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);

//logger.info("{七牛图片上传key: "+ putRet.key+",七牛图片上传hash: "+ putRet.hash+"}");

result =

"http://pw9sd0p5d.bkt.clouddn.com/"+putRet.key;

} catch (QiniuException ex) {

Response r = ex.response;

System.err.println(r.toString());

try {

System.err.println(r.bodyString());

} catch (QiniuException ex2) {

//ignore

}

result = null;

}

return result;

}

}

第二步写一个文件上传的service

package com.keelon.job.Service.ServiceImpl;

import com.keelon.job.Service.FileService;

import com.keelon.job.util.QiniuUtil;

import org.springframework.stereotype.Service;

import org.springframework.util.StringUtils;

import org.springframework.web.multipart.MultipartFile;

import tk.mybatis.mapper.util.StringUtil;

//import tk.mybatis.mapper.util.StringUtil;

import java.io.*;

import java.util.HashMap;

import java.util.LinkedList;

import java.util.List;

import java.util.Map;

/**

* @author 创建人:< Chenmq>

* @project 项目:

* @date 创建时间:< 2017/9/2>

* @comments: 说明:< //文件上传 >

*/

@Service

public class FileServiceImpl implements FileService {

@Override

public Map> uploadImgs(MultipartFile[] file) {

Map> resultMap = new HashMap<>();

List list = new LinkedList<>();

String result = null;

for (int i = 0; i < file.length; i++) {

String fileName = file[i].getOriginalFilename();

// 创建一个临时目录文件

String tempFiles = "temp/"+fileName;

File dest = new File(tempFiles);

if (!dest.getParentFile().exists()) {

dest.getParentFile().mkdirs();

}

BufferedOutputStream out = null;

QiniuUtil qn = new QiniuUtil();

try {

out = new BufferedOutputStream(new FileOutputStream(dest));

out.write(file[i].getBytes());

result = qn.uoloapQiniu(dest,fileName);

// StringUtil.isNotEmpty()

if (StringUtil.isNotEmpty(result)) {

list.add(result);

}

} catch (FileNotFoundException e) {

e.printStackTrace();

} catch (IOException e1) {

e1.getMessage();

} finally{

try {

if (null != out) {

out.flush();

out.close();

}

} catch (IOException e) {

e.printStackTrace();

}

if (dest.getParentFile().exists()) {

dest.delete();

}

}

}

// logger.info("imagesList == " + list);

System.out.println("imagesList == " + list);

if (list.isEmpty()) {

list.add("error");

}

resultMap.put("result",list);

return resultMap;

}

}

第三步我们编写我们的Controller

import com.keelon.job.VO.ResultVO;

import com.keelon.job.util.ResultVOUtil;

import org.springframework.web.bind.annotation.*;

import org.springframework.web.multipart.MultipartFile;

import tk.mybatis.mapper.util.StringUtil;

import javax.annotation.Resource;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

@RestController

@RequestMapping("/admin/webServer")

public class WebServerController {

@Resource

private FileService fileService;

@RequestMapping(value="/imgs", method = RequestMethod.POST)

public ResultVO uploadImg(@RequestParam("file") MultipartFile[] files) {

// 返回类型可以自己定义

ResultVO serviceResult = new ResultVO();

// 验证非空

if (StringUtil.isEmpty(files[0].getOriginalFilename())) {

serviceResult = ResultVOUtil.error(-1,"照片为空");

} else {

Map> map = new HashMap<>();

map = fileService.uploadImgs(files);

List resultList = map.get("result");

System.out.println("图片上传返回结果:"+resultList);

if ("error".equals(resultList.get(0))) {

serviceResult = ResultVOUtil.error(-2,"上传失败");

} else {

//上传成功。返回地址。

serviceResult = ResultVOUtil.success(resultList);

}

}

return serviceResult;

}

}

第四部：我们用postman测试一下刚才写的接口。服务器已经返回，证明我们测试以及OK了

下面我们进入七牛云的

后台看看，我们上传的图片

通过以上代码来看，我们照片的存储是不是很简单呢。既然七牛云可以上传我们照片。那么是不是做一个图片的分享或者照片的分享app呢。当然七牛云，存储容量非常大的时候，还是需要付费，但是价格还是能够接受的。