通过官方SDK对腾讯云、阿里云、七牛云文件上传和本地存储文件上传，自由切换

avatar 2019年05月19日11:08:41 8 7279 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此
因为博主之前七牛云被刷了波流量，损失惨重，目前不考虑使用七牛云了，会考虑阿里云、腾讯云和本地上传。

本文介绍 SpringBoot下，实现多种上传方式。

一、设计思路


现在的设计是想在后台可以设置文件存储位置，支持动态切换。

界面如下，管理员在系统设置里可以选择系统文件上传位置。



实现思路，存储当前上传方式(本地，七牛云，阿里云，腾讯云)，如选择了腾讯云，填好了bucket、地域、ak、sk、访问域名后，将该配置信息记录在redis中，当然也可以考虑持久化到 mysql 中。

当用户上传文件，如上传头像，调用上传通用接口，如 /upload/file 接口，在该方法内判断当前存储方式，查到是腾讯云，调用腾讯云的上传Service接口。



下面一一介绍这几种实现，只贴核心代码，有开发经验的朋友应该能直接看懂。


二、腾讯云OSS创建


1.开通COS，创建bucket

进入腾讯云后台，在云产品下拉选择项里选择对象存储(简称OSS或COS)，然后开通COS。

创建存储桶(bucket)，名称自定义，所属地域可以选择离自己近的地方，访问权限如果需要对外访问可以选择公有读私有写。直达链接



2.查看空间名称(bucket)和访问域名(endpoint)



如 bucket 为 test-123456789

endpoint 为 test-1253316749.cos.ap-shanghai.myqcloud.com



3.创建密钥

在侧边栏有密钥管理，直达链接，在云密钥里创建和查看密钥，需要里面的SecretId和SecretKey

如SecretId：SWhswSWjswwnjSW21SWjswhuwHswhusswhu2

SecretKey：1swhuwjisn2hshu0-swnsw-1nswjswjko2s3





七牛云和阿里云以前介绍过，这里就不写了，步骤都差不多，目的都是需要有 bucket 名称，访问域名，sk，sk 等。

需要注意几点：

① 地域很重要，需要和配置里对应，因为不同的地域的标识是不一样的

② 如果访问不了文件，可能是访问权限的问题

③ ak 和 sk不要暴露


三、代码实战


1.上传入口类，UploadController.java
  1. package cn.exrick.xboot.modules.base.controller;
  3. import com.liuyanzhao.sens.common.constant.CommonConstant;
  4. importcom.liuyanzhao.sens.common.constant.SettingConstant;
  5. import com.liuyanzhao.senscommon.utils.*;
  6. import com.liuyanzhao.sens.common.vo.Result;
  7. import com.liuyanzhao.sens.modules.base.entity.File;
  8. import cn.hutool.core.util.StrUtil;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.data.redis.core.StringRedisTemplate;
  12. import org.springframework.web.bind.annotation.RequestMapping;
  13. import org.springframework.web.bind.annotation.RequestMethod;
  14. import org.springframework.web.bind.annotation.RequestParam;
  15. import org.springframework.web.bind.annotation.RestController;
  16. import org.springframework.web.multipart.MultipartFile;
  18. import javax.servlet.http.HttpServletRequest;
  19. import java.io.InputStream;
  21. /**
  22.  * @author saysky
  23.  */
  24. @Slf4j
  25. @RestController
  26. @RequestMapping("/upload")
  27. public class UploadController {
  29.     @Autowired
  30.     private QiniuUtil qiniuUtil;
  32.     @Autowired
  33.     private AliOssUtil aliOssUtil;
  35.     @Autowired
  36.     private TencentOssUtil tencentOssUtil;
  38.     @Autowired
  39.     private FileUtil fileUtil;
  41.     @Autowired
  42.     private StringRedisTemplate redisTemplate;
  45.     @RequestMapping(value = "/file", method = RequestMethod.POST)
  46.     public Result<Object> upload(@RequestParam(required = false) MultipartFile file,
  47.                                  @RequestParam(required = false) String base64,
  48.                                  HttpServletRequest request) {
  50.         String used = redisTemplate.opsForValue().get(SettingConstant.OSS_USED);
  51.         if(StrUtil.isBlank(used)) {
  52.             return new ResultUtil<Object>().setErrorMsg(501, "您还未配置OSS服务");
  53.         }
  54.         if(StrUtil.isNotBlank(base64)){
  55.             // base64上传
  56.             file = Base64DecodeMultipartFile.base64Convert(base64);
  57.         }
  58.         String result = "";
  59.         //重命名文件，UUID+后缀
  60.         String fKey = CommonUtil.renamePic(file.getOriginalFilename());
  61.         File f = new File();
  62.         try {
  63.             InputStream inputStream = file.getInputStream();
  64.             // 上传至第三方云服务或服务器
  65.             if(used.equals(SettingConstant.QINIU_OSS)){
  66.                 //七牛云上传
  67.                 result = qiniuUtil.qiniuInputStreamUpload(inputStream, fKey);
  68.                 f.setLocation(CommonConstant.OSS_QINIU);
  69.             }else if(used.equals(SettingConstant.ALI_OSS)){
  70.                 //阿里云上传
  71.                 result = aliOssUtil.aliInputStreamUpload(inputStream, fKey);
  72.                 f.setLocation(CommonConstant.OSS_ALI);
  73.             }else if(used.equals(SettingConstant.TENCENT_OSS)){
  74.                 //腾讯云上传
  75.                 result = tencentOssUtil.tencentInputStreamUpload(file, inputStream, fKey);
  76.                 f.setLocation(CommonConstant.OSS_TENCENT);
  77.             }else if(used.equals(SettingConstant.LOCAL_OSS)){
  78.                 //本地上传
  79.                 result = fileUtil.localUpload(file, fKey);
  80.                 f.setLocation(CommonConstant.OSS_LOCAL);
  81.             }
  82.             // 文件信息保存数据信息至数据库
  83.             //略
  84.         } catch (Exception e) {
  85.             log.error(e.toString());
  86.             return new ResultUtil<Object>().setErrorMsg(e.toString());
  87.         }
  88.         return new ResultUtil<Object>().setData(result);
  89.     }
  90. }



2.后台保存OSS配置接口 SettingController.java
  1. @RequestMapping(value = "/oss/set", method = RequestMethod.POST)
  2.    @ApiOperation(value = "OSS配置")
  3.    public Result<Object> ossSet(@ModelAttribute OssSetting ossSetting) {
  5.        if(ossSetting.getServiceName().equals(SettingConstant.QINIU_OSS)){
  6.            // 七牛
  7.            String v = redisTemplate.opsForValue().get(SettingConstant.QINIU_OSS);
  8.            if(StrUtil.isNotBlank(v)&&!ossSetting.getChanged()){
  9.                String secrectKey = new Gson().fromJson(v, OssSetting.class).getSecretKey();
  10.                ossSetting.setSecretKey(secrectKey);
  11.            }
  12.            redisTemplate.opsForValue().set(SettingConstant.QINIU_OSS, new Gson().toJson(ossSetting));
  13.            redisTemplate.opsForValue().set(SettingConstant.OSS_USED, SettingConstant.QINIU_OSS);
  14.        }else if(ossSetting.getServiceName().equals(SettingConstant.ALI_OSS)){
  15.            // 阿里
  16.            String v = redisTemplate.opsForValue().get(SettingConstant.ALI_OSS);
  17.            if(StrUtil.isNotBlank(v)&&!ossSetting.getChanged()){
  18.                String secrectKey = new Gson().fromJson(v, OssSetting.class).getSecretKey();
  19.                ossSetting.setSecretKey(secrectKey);
  20.            }
  21.            redisTemplate.opsForValue().set(SettingConstant.ALI_OSS, new Gson().toJson(ossSetting));
  22.            redisTemplate.opsForValue().set(SettingConstant.OSS_USED, SettingConstant.ALI_OSS);
  23.        }else if(ossSetting.getServiceName().equals(SettingConstant.TENCENT_OSS)){
  24.            // 腾讯
  25.            String v = redisTemplate.opsForValue().get(SettingConstant.TENCENT_OSS);
  26.            if(StrUtil.isNotBlank(v)&&!ossSetting.getChanged()){
  27.                String secrectKey = new Gson().fromJson(v, OssSetting.class).getSecretKey();
  28.                ossSetting.setSecretKey(secrectKey);
  29.            }
  30.            redisTemplate.opsForValue().set(SettingConstant.TENCENT_OSS, new Gson().toJson(ossSetting));
  31.            redisTemplate.opsForValue().set(SettingConstant.OSS_USED, SettingConstant.TENCENT_OSS);
  32.        }else if(ossSetting.getServiceName().equals(SettingConstant.LOCAL_OSS)){
  33.            // 本地
  34.            redisTemplate.opsForValue().set(SettingConstant.LOCAL_OSS, new Gson().toJson(ossSetting));
  35.            redisTemplate.opsForValue().set(SettingConstant.OSS_USED, SettingConstant.LOCAL_OSS);
  36.        }
  37.        return new ResultUtil<Object>().setData(null);
  38.    }



OSS配置封装类 OssSetting.java
  1. package com.liuyanzhao.sens.modules.base.vo;
  3. import lombok.Data;
  5. import java.io.Serializable;
  7. /**
  8.  * @author saysky
  9.  */
  10. @Data
  11. public class OssSetting implements Serializable{
  13.     private String serviceName;
  15.     private String accessKey;
  17.     private String secretKey;
  19.     private String endpoint;
  21.     private String bucket;
  23.     private String http;
  25.     private Integer zone;
  27.     private String bucketRegion;
  29.     private String filePath;
  31.     private Boolean changed;
  32. }



变量接口 SettingConstant.java
  1. package com.liuyanzhao.sens.common.constant;
  3. /**
  4.  * @author saysky
  5.  */
  6. public interface SettingConstant {
  8.     /**
  9.      * 当前使用OSS
  10.      */
  11.     String OSS_USED = "OSS_USED";
  13.     /**
  14.      * 七牛OSS配置
  15.      */
  16.     String QINIU_OSS = "QINIU_OSS";
  18.     /**
  19.      * 七牛云存储区域 自动判断
  20.      */
  21.     Integer ZONE_AUTO = -1;
  23.     /**
  24.      * 七牛云存储区域 华东
  25.      */
  26.     Integer ZONE_ZERO = 0;
  28.     /**
  29.      * 七牛云存储区域 华北
  30.      */
  31.     Integer ZONE_ONE = 1;
  33.     /**
  34.      * 七牛云存储区域 华南
  35.      */
  36.     Integer ZONE_TWO = 2;
  38.     /**
  39.      * 七牛云存储区域 北美
  40.      */
  41.     Integer ZONE_THREE = 3;
  43.     /**
  44.      * 七牛云存储区域 东南亚
  45.      */
  46.     Integer ZONE_FOUR = 4;
  48.     /**
  49.      * 阿里OSS配置
  50.      */
  51.     String ALI_OSS = "ALI_OSS";
  53.     /**
  54.      * 腾讯COS配置
  55.      */
  56.     String TENCENT_OSS = "TENCENT_OSS";
  58.     /**
  59.      * 本地OSS配置
  60.      */
  61.     String LOCAL_OSS = "LOCAL_OSS";
  62. }



3.具体的上传实现接口

① 七牛云 QiniuUtil.java
  1. package com.liuyanzhao.sens.common.utils;
  3. import com.liuyanzhao.sens.common.constant.SettingConstant;
  4. import com.liuyanzhao.sens.modules.base.vo.OssSetting;
  5. import com.liuyanzhao.sens.common.exception.SensException;
  6. import cn.hutool.core.util.StrUtil;
  7. import com.google.gson.Gson;
  8. import com.qiniu.common.QiniuException;
  9. import com.qiniu.common.Zone;
  10. import com.qiniu.http.Response;
  11. import com.qiniu.storage.BucketManager;
  12. import com.qiniu.storage.Configuration;
  13. import com.qiniu.storage.UploadManager;
  14. import com.qiniu.storage.model.DefaultPutRet;
  15. import com.qiniu.util.Auth;
  16. import lombok.extern.slf4j.Slf4j;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.data.redis.core.StringRedisTemplate;
  19. import org.springframework.stereotype.Component;
  21. import java.io.InputStream;
  23. /**
  24.  * @author saysky
  25.  */
  26. @Slf4j
  27. @Component
  28. public class QiniuUtil {
  30.     @Autowired
  31.     private StringRedisTemplate redisTemplate;
  33.     public OssSetting getOssSetting(){
  35.         String v = redisTemplate.opsForValue().get(SettingConstant.QINIU_OSS);
  36.         if(StrUtil.isBlank(v)){
  37.             throw new SensException("您还未配置七牛云OSS");
  38.         }
  39.         return new Gson().fromJson(v, OssSetting.class);
  40.     }
  42.     public Configuration getConfiguration(Integer zone){
  44.         Configuration cfg = null;
  45.         if(zone.equals(SettingConstant.ZONE_ZERO)){
  46.             cfg = new Configuration(Zone.zone0());
  47.         }else if(zone.equals(SettingConstant.ZONE_ONE)){
  48.             cfg = new Configuration(Zone.zone1());
  49.         }else if(zone.equals(SettingConstant.ZONE_TWO)){
  50.             cfg = new Configuration(Zone.zone2());
  51.         }else if(zone.equals(SettingConstant.ZONE_THREE)){
  52.             cfg = new Configuration(Zone.zoneNa0());
  53.         }else if(zone.equals(SettingConstant.ZONE_FOUR)){
  54.             cfg = new Configuration(Zone.zoneAs0());
  55.         }else {
  56.             cfg = new Configuration(Zone.autoZone());
  57.         }
  58.         return cfg;
  59.     }
  61.     public UploadManager getUploadManager(Configuration cfg){
  63.         UploadManager uploadManager = new UploadManager(cfg);
  64.         return uploadManager;
  65.     }
  67.     /**
  68.      * 文件路径上传
  69.      * @param filePath
  70.      * @param key 文件名
  71.      * @return
  72.      */
  73.     public String qiniuUpload(String filePath, String key) {
  75.         OssSetting os = getOssSetting();
  76.         Auth auth = Auth.create(os.getAccessKey(), os.getSecretKey());
  77.         String upToken = auth.uploadToken(os.getBucket());
  78.         try {
  79.             Response response = getUploadManager(getConfiguration(os.getZone())).put(filePath, key, upToken);
  80.             DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);
  81.             return os.getHttp() + os.getEndpoint() + "/" + putRet.key;
  82.         } catch (QiniuException ex) {
  83.             Response r = ex.response;
  84.             throw new SensException("上传文件出错，请检查七牛云配置，" + r.toString());
  85.         }
  86.     }
  88.     /**
  89.      * 文件流上传
  90.      * @param inputStream
  91.      * @param key  文件名
  92.      * @return
  93.      */
  94.     public String qiniuInputStreamUpload(InputStream inputStream, String key) {
  96.         OssSetting os = getOssSetting();
  97.         Auth auth = Auth.create(os.getAccessKey(), os.getSecretKey());
  98.         String upToken = auth.uploadToken(os.getBucket());
  99.         try {
  100.             Response response = getUploadManager(getConfiguration(os.getZone())).put(inputStream, key, upToken, null, null);
  101.             DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);
  102.             return os.getHttp() + os.getEndpoint() + "/" + putRet.key;
  103.         } catch (QiniuException ex) {
  104.             Response r = ex.response;
  105.             throw new SensException("上传文件出错，请检查七牛云配置，" + r.toString());
  106.         }
  107.     }
  109.     /**
  110.      * 重命名
  111.      * @param fromKey
  112.      * @param toKey
  113.      */
  114.     public String renameFile(String fromKey, String toKey){
  116.         OssSetting os = getOssSetting();
  117.         Auth auth = Auth.create(os.getAccessKey(), os.getSecretKey());
  118.         BucketManager bucketManager = new BucketManager(auth, getConfiguration(os.getZone()));
  119.         try {
  120.             bucketManager.move(os.getBucket(), fromKey, os.getBucket(), toKey);
  121.             return os.getHttp() + os.getEndpoint() + "/" + toKey;
  122.         } catch (QiniuException ex) {
  123.             throw new SensException("重命名文件失败，" + ex.response.toString());
  124.         }
  125.     }
  127.     /**
  128.      * 复制文件
  129.      * @param fromKey
  130.      */
  131.     public String copyFile(String fromKey, String toKey){
  133.         OssSetting os = getOssSetting();
  134.         Auth auth = Auth.create(os.getAccessKey(), os.getSecretKey());
  135.         BucketManager bucketManager = new BucketManager(auth, getConfiguration(os.getZone()));
  136.         try {
  137.             bucketManager.copy(os.getBucket(), fromKey, os.getBucket(), toKey);
  138.             return os.getHttp() + os.getEndpoint() + "/" + toKey;
  139.         } catch (QiniuException ex) {
  140.             throw new SensException("复制文件失败，" + ex.response.toString());
  141.         }
  142.     }
  144.     /**
  145.      * 删除文件
  146.      * @param key
  147.      */
  148.     public void deleteFile(String key){
  150.         OssSetting os = getOssSetting();
  151.         Auth auth = Auth.create(os.getAccessKey(), os.getSecretKey());
  152.         BucketManager bucketManager = new BucketManager(auth, getConfiguration(os.getZone()));
  153.         try {
  154.             bucketManager.delete(os.getBucket(), key);
  155.         } catch (QiniuException ex) {
  156.             throw new SensException("删除文件失败，" + ex.response.toString());
  157.         }
  158.     }
  159. }



② 阿里云 AliOssUtil.java
  1. package com.liuyanzhao.sens.common.utils;
  3. import com.liuyanzhao.sens.common.constant.SettingConstant;
  4. import com.liuyanzhao.sens.modules.base.vo.OssSetting;
  5. import com.liuyanzhao.sens.common.exception.SensException;
  6. import cn.hutool.core.util.StrUtil;
  7. import com.aliyun.oss.OSSClient;
  8. import com.google.gson.Gson;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.data.redis.core.StringRedisTemplate;
  12. import org.springframework.stereotype.Component;
  14. import java.io.*;
  16. /**
  17.  * @author saysky
  18.  */
  19. @Component
  20. @Slf4j
  21. public class AliOssUtil {
  23.     @Autowired
  24.     private StringRedisTemplate redisTemplate;
  26.     public OssSetting getOssSetting(){
  28.         String v = redisTemplate.opsForValue().get(SettingConstant.ALI_OSS);
  29.         if(StrUtil.isBlank(v)){
  30.             throw new SensException("您还未配置阿里云OSS");
  31.         }
  32.         return new Gson().fromJson(v, OssSetting.class);
  33.     }
  35.     /**
  36.      * 文件路径上传
  37.      * @param filePath
  38.      * @param key
  39.      * @return
  40.      */
  41.     public String aliUpload(String filePath, String key) {
  43.         OssSetting os = getOssSetting();
  44.         OSSClient ossClient = new OSSClient(os.getHttp() + os.getEndpoint(), os.getAccessKey(), os.getSecretKey());
  45.         ossClient.putObject(os.getBucket(), key, new File(filePath));
  46.         ossClient.shutdown();
  47.         return os.getHttp() + os.getBucket() + "." + os.getEndpoint() + "/" + key;
  48.     }
  50.     /**
  51.      * 文件流上传
  52.      * @param inputStream
  53.      * @param key
  54.      * @return
  55.      */
  56.     public String aliInputStreamUpload(InputStream inputStream, String key) {
  58.         OssSetting os = getOssSetting();
  59.         OSSClient ossClient = new OSSClient(os.getHttp() + os.getEndpoint(), os.getAccessKey(), os.getSecretKey());
  60.         ossClient.putObject(os.getBucket(), key, inputStream);
  61.         ossClient.shutdown();
  62.         return os.getHttp() + os.getBucket() + "." + os.getEndpoint() + "/" + key;
  63.     }
  65.     /**
  66.      * 重命名
  67.      * @param fromKey
  68.      * @param toKey
  69.      */
  70.     public String renameFile(String fromKey, String toKey){
  72.         OssSetting os = getOssSetting();
  73.         copyFile(fromKey, toKey);
  74.         deleteFile(fromKey);
  75.         return os.getHttp() + os.getBucket() + "." + os.getEndpoint() + "/" + toKey;
  76.     }
  78.     /**
  79.      * 复制文件
  80.      * @param fromKey
  81.      */
  82.     public String copyFile(String fromKey, String toKey){
  84.         OssSetting os = getOssSetting();
  85.         OSSClient ossClient = new OSSClient(os.getHttp() + os.getEndpoint(), os.getAccessKey(), os.getSecretKey());
  86.         ossClient.copyObject(os.getBucket(), fromKey, os.getBucket(), toKey);
  87.         ossClient.shutdown();
  88.         return os.getHttp() + os.getBucket() + "." + os.getEndpoint() + "/" + toKey;
  89.     }
  91.     /**
  92.      * 删除文件
  93.      * @param key
  94.      */
  95.     public void deleteFile(String key){
  97.         OssSetting os = getOssSetting();
  98.         OSSClient ossClient = new OSSClient(os.getHttp() + os.getEndpoint(), os.getAccessKey(), os.getSecretKey());
  99.         ossClient.deleteObject(os.getBucket(), key);
  100.         ossClient.shutdown();
  101.     }
  102. }



③ 腾讯云 TencentOssUtil.java
  1. package com.liuyanzhao.sens.common.utils;
  3. import com.liuyanzhao.sens.common.constant.SettingConstant;
  4. import com.liuyanzhao.sens.modules.base.vo.OssSetting;
  5. import com.liuyanzhao.sens.common.exception.SensException;
  6. import cn.hutool.core.util.StrUtil;
  7. import com.google.gson.Gson;
  8. import com.qcloud.cos.COSClient;
  9. import com.qcloud.cos.ClientConfig;
  10. import com.qcloud.cos.auth.BasicCOSCredentials;
  11. import com.qcloud.cos.auth.COSCredentials;
  12. import com.qcloud.cos.model.*;
  13. import com.qcloud.cos.region.Region;
  14. import com.qcloud.cos.transfer.Copy;
  15. import com.qcloud.cos.transfer.TransferManager;
  16. import lombok.extern.slf4j.Slf4j;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.data.redis.core.StringRedisTemplate;
  19. import org.springframework.stereotype.Component;
  20. import org.springframework.web.multipart.MultipartFile;
  22. import java.io.File;
  23. import java.io.InputStream;
  25. /**
  26.  * @author saysky
  27.  */
  28. @Component
  29. @Slf4j
  30. public class TencentOssUtil {
  32.     @Autowired
  33.     private StringRedisTemplate redisTemplate;
  35.     public OssSetting getOssSetting(){
  37.         String v = redisTemplate.opsForValue().get(SettingConstant.TENCENT_OSS);
  38.         if(StrUtil.isBlank(v)){
  39.             throw new SensException("您还未配置腾讯云COS");
  40.         }
  41.         return new Gson().fromJson(v, OssSetting.class);
  42.     }
  44.     /**
  45.      * 文件路径上传
  46.      * @param filePath
  47.      * @param key
  48.      * @return
  49.      */
  50.     public String tencentUpload(String filePath, String key) {
  52.         OssSetting os = getOssSetting();
  54.         COSCredentials cred = new BasicCOSCredentials(os.getAccessKey(), os.getSecretKey());
  55.         ClientConfig clientConfig = new ClientConfig(new Region(os.getBucketRegion()));
  56.         COSClient cosClient = new COSClient(cred, clientConfig);
  58.         PutObjectRequest putObjectRequest = new PutObjectRequest(os.getBucket(), key, new File(filePath));
  59.         PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
  60.         cosClient.shutdown();
  61.         return os.getHttp() + os.getEndpoint() + "/" + key;
  62.     }
  64.     /**
  65.      * 文件流上传
  66.      * 
  67.      * @param file 文件
  68.      * @param inputStream 输入流
  69.      * @param key 文件名
  70.      * @return
  71.      */
  72.     public String tencentInputStreamUpload(MultipartFile file, InputStream inputStream, String key) {
  74.         OssSetting os = getOssSetting();
  76.         COSCredentials cred = new BasicCOSCredentials(os.getAccessKey(), os.getSecretKey());
  77.         ClientConfig clientConfig = new ClientConfig(new Region(os.getBucketRegion()));
  78.         COSClient cosClient = new COSClient(cred, clientConfig);
  80.         ObjectMetadata objectMetadata = new ObjectMetadata();
  81.         objectMetadata.setContentLength(file.getSize());
  82.         objectMetadata.setContentType(file.getContentType());
  84.         PutObjectRequest putObjectRequest = new PutObjectRequest(os.getBucket(), key, inputStream, objectMetadata);
  85.         PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
  86.         cosClient.shutdown();
  87.         return os.getHttp() + os.getEndpoint() + "/" + key;
  88.     }
  90.     /**
  91.      * 重命名
  92.      * @param fromKey 原名
  93.      * @param toKey 目标名
  94.      */
  95.     public String renameFile(String fromKey, String toKey){
  97.         OssSetting os = getOssSetting();
  98.         copyFile(fromKey, toKey);
  99.         deleteFile(fromKey);
  100.         return os.getHttp() + os.getEndpoint() + "/" + toKey;
  101.     }
  103.     /**
  104.      * 复制文件
  105.      * 
  106.      * @param fromKey 原名
  107.      * @param fromKey 目标名
  108.      */
  109.     public String copyFile(String fromKey, String toKey){
  111.         OssSetting os = getOssSetting();
  113.         COSCredentials cred = new BasicCOSCredentials(os.getAccessKey(), os.getSecretKey());
  114.         ClientConfig clientConfig = new ClientConfig(new Region(os.getBucketRegion()));
  115.         COSClient cosClient = new COSClient(cred, clientConfig);
  117.         CopyObjectRequest copyObjectRequest = new CopyObjectRequest(os.getBucket(), fromKey, os.getBucket(), toKey);
  119.         TransferManager transferManager = new TransferManager(cosClient);
  120.         try {
  121.             Copy copy = transferManager.copy(copyObjectRequest, cosClient, null);
  122.             CopyResult copyResult = copy.waitForCopyResult();
  123.         } catch (Exception e) {
  124.             e.printStackTrace();
  125.             throw new SensException("复制文件失败");
  126.         }
  127.         transferManager.shutdownNow();
  128.         cosClient.shutdown();
  129.         return os.getHttp() + os.getEndpoint() + "/" + toKey;
  130.     }
  132.     /**
  133.      * 删除文件
  134.      * 
  135.      * @param key 原名
  136.      */
  137.     public void deleteFile(String key){
  139.         OssSetting os = getOssSetting();
  141.         COSCredentials cred = new BasicCOSCredentials(os.getAccessKey(), os.getSecretKey());
  142.         ClientConfig clientConfig = new ClientConfig(new Region(os.getBucketRegion()));
  143.         COSClient cosClient = new COSClient(cred, clientConfig);
  145.         cosClient.deleteObject(os.getBucket(), key);
  146.         cosClient.shutdown();
  147.     }
  148. }



④ 本地 FileUtil.java
  1. package com.liuyanzhao.sens.common.utils;
  3. import com.liuyanzhao.sens.common.constant.SettingConstant;
  4. import com.liuyanzhao.sens.modules.base.vo.OssSetting;
  5. import com.liuyanzhao.sens.common.exception.SensException;
  6. import cn.hutool.core.date.DateUtil;
  7. import cn.hutool.core.util.StrUtil;
  8. import com.google.gson.Gson;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.data.redis.core.StringRedisTemplate;
  12. import org.springframework.stereotype.Component;
  13. import org.springframework.web.multipart.MultipartFile;
  15. import javax.servlet.http.HttpServletResponse;
  16. import java.io.*;
  18. /**
  19.  * @author saysky
  20.  */
  21. @Component
  22. @Slf4j
  23. public class FileUtil {
  25.     @Autowired
  26.     private StringRedisTemplate redisTemplate;
  28.     public OssSetting getOssSetting(){
  30.         String v = redisTemplate.opsForValue().get(SettingConstant.LOCAL_OSS);
  31.         if(StrUtil.isBlank(v)){
  32.             throw new SensException("您还未配置本地文件存储服务");
  33.         }
  34.         return new Gson().fromJson(v, OssSetting.class);
  35.     }
  37.     /**
  38.      * 文件路径上传
  39.      * @param file
  40.      * @param key
  41.      * @return
  42.      */
  43.     public String localUpload(MultipartFile file, String key) {
  45.         OssSetting os = getOssSetting();
  46.         String day = DateUtil.format(DateUtil.date(), "yyyyMMdd");
  47.         String path = os.getFilePath() + "/" + day;
  48.         File dir = new File(path);
  49.         if(!dir.exists()){
  50.             dir.mkdirs();
  51.         }
  52.         File f = new File(path + "/" + key);
  53.         if(f.exists()){
  54.             throw new SensException("文件名已存在");
  55.         }
  56.         try {
  57.             file.transferTo(f);
  58.             return path + "/" + key;
  59.         } catch (IOException e) {
  60.             log.error(e.toString());
  61.             throw new SensException("上传文件出错");
  62.         }
  63.     }
  65.     /**
  66.      * 读取文件
  67.      * @param url
  68.      * @param response
  69.      */
  70.     public void view(String url, HttpServletResponse response){
  72.         File file = new File(url);
  73.         FileInputStream i = null;
  74.         OutputStream o = null;
  76.         try {
  77.             i = new FileInputStream(file);
  78.             o = response.getOutputStream();
  80.             byte[] buf = new byte[1024];
  81.             int bytesRead;
  83.             while ((bytesRead = i.read(buf))>0){
  84.                 o.write(buf, 0, bytesRead);
  85.                 o.flush();
  86.             }
  88.             i.close();
  89.             o.close();
  90.         } catch (IOException e) {
  91.             log.error(e.toString());
  92.             throw new SensException("读取文件出错");
  93.         }
  94.     }
  96.     /**
  97.      * 重命名
  98.      * @param url
  99.      * @param toKey
  100.      * @return
  101.      */
  102.     public String renameFile(String url, String toKey){
  104.         String result = copyFile(url, toKey);
  105.         deleteFile(url);
  106.         return result;
  107.     }
  109.     /**
  110.      * 复制文件
  111.      * @param url
  112.      * @param toKey
  113.      */
  114.     public String copyFile(String url, String toKey){
  116.         File file = new File(url);
  117.         FileInputStream i = null;
  118.         FileOutputStream o = null;
  120.         try {
  121.             i = new FileInputStream(file);
  122.             o = new FileOutputStream(new File(file.getParentFile() + "/" + toKey));
  124.             byte[] buf = new byte[1024];
  125.             int bytesRead;
  127.             while ((bytesRead = i.read(buf))>0){
  128.                 o.write(buf, 0, bytesRead);
  129.             }
  131.             i.close();
  132.             o.close();
  133.             return file.getParentFile() + "/" + toKey;
  134.         } catch (IOException e) {
  135.             log.error(e.toString());
  136.             throw new SensException("复制文件出错");
  137.         }
  138.     }
  140.     /**
  141.      * 删除文件
  142.      * @param url
  143.      */
  144.     public void deleteFile(String url){
  146.         File file = new File(url);
  147.         file.delete();
  148.     }
  149. }



4.Maven依赖 pom.xml
  1. <!-- 七牛云SDK -->
  2. <dependency>
  3.     <groupId>com.qiniu</groupId>
  4.     <artifactId>qiniu-java-sdk</artifactId>
  5.     <version>[7.2.0, 7.2.99]</version>
  6. </dependency>
  7. <!-- 阿里云OSS -->
  8. <dependency>
  9.     <groupId>com.aliyun.oss</groupId>
  10.     <artifactId>aliyun-sdk-oss</artifactId>
  11.     <version>2.8.3</version>
  12. </dependency>
  13. <!-- 腾讯云COS -->
  14. <dependency>
  15.     <groupId>com.qcloud</groupId>
  16.     <artifactId>cos_api</artifactId>
  17.     <version>5.4.6</version>
  18. </dependency>
  20. <!-- Gson -->
  21. <dependency>
  22.     <groupId>com.google.code.gson</groupId>
  23.     <artifactId>gson</artifactId>
  24.     <version>2.8.5</version>
  25. </dependency>
  26. <!-- Hutool工具包 -->
  27. <dependency>
  28.     <groupId>cn.hutool</groupId>
  29.     <artifactId>hutool-all</artifactId>
  30.     <version>4.5.7</version>
  31. </dependency>
  32. <!-- Lombok -->
  33. <dependency>
  34.     <groupId>org.projectlombok</groupId>
  35.     <artifactId>lombok</artifactId>
  36.     <version>1.18.4</version>
  37. </dependency>


四、文末


前端这里就不贴了，毕竟大家都是后端开发。

有问题，可以在下方留言或者联系博主



官方文档

阿里云OSS上传文件

腾讯云COS上传文件

七牛云OSS上传文件
历史上的今天
五月
19日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：1   待审核评论数：0
  1. avatar 匿名
    回复 2020年04月18日 11:54:48

    啥年代了还用富文本，markdown不会吗？文字全部挤到一坨了 难看

    • avatar 言曌
      回复 2020年05月02日 13:09:22

      是不是 word 文档未来要被淘汰，全民使用命令来编辑文本？