【技术积累】腾讯/阿里云对象存储上传+删除

腾讯/阿里云对象存储上传+删除

• 创建储存桶 （后面会用到 储存库名称、访问域名、以及region） region（地域和访问域名）的查询参考： https://cloud.tencent.com/document/product/436/6224
  
• https://www.aliyun.com/product/oss
  

常用的阿里云、腾讯云

2.创建Api密钥 （后面会用到 secretId、secretKey）

application.yml

1. qcloud:
2.   path: 域名地址
3.   bucketName: 储存库名称
4.   secretId: 密钥生成的secretId
5.   secretKey: 密钥生成的secretKey
6.   region: 地域简称
7.   prefix: /images/

复制代码

工具类：

1. import com.qcloud.cos.COSClient;
2. import com.qcloud.cos.ClientConfig;
3. import com.qcloud.cos.auth.BasicCOSCredentials;
4. import com.qcloud.cos.auth.COSCredentials;
5. import com.qcloud.cos.exception.CosClientException;
6. import com.qcloud.cos.exception.CosServiceException;
7. import com.qcloud.cos.model.PutObjectRequest;
8. import com.qcloud.cos.model.PutObjectResult;
9. import com.qcloud.cos.region.Region;
10. import lombok.Data;
11. import org.springframework.web.multipart.MultipartFile;
13. import java.io.File;
14. import java.io.IOException;
15. import java.util.UUID;
17. /**
18. * @author
19. * @date 2021/6/6 19:31
20. * @role
21. */
22. @Data
23. public class QCloudCosUtils {
24.     //API密钥secretId
25.     private String secretId;
26.     //API密钥secretKey
27.     private String secretKey;
28.     //存储桶所属地域
29.     private String region;
30.     //存储桶空间名称
31.     private String bucketName;
32.     //存储桶访问域名
33.     private String path;
34.     //上传文件前缀路径(eg:/images/)
35.     private String prefix;
37.     /**
38.      * 上传File类型的文件
39.      *
40.      * @param file
41.      * @return 上传文件在存储桶的链接
42.      */
43.     public String upload(File file) {
44.         //生成唯一文件名
45.         String newFileName = generateUniqueName(file.getName());
46.         //文件在存储桶中的key
47.         String key = prefix + newFileName;
48.         //声明客户端
49.         COSClient cosClient = null;
50.         try {
51.             //初始化用户身份信息(secretId,secretKey)
52.             COSCredentials cosCredentials = new BasicCOSCredentials(secretId, secretKey);
53.             //设置bucket的区域
54.             ClientConfig clientConfig = new ClientConfig(new Region(region));
55.             //生成cos客户端
56.             cosClient = new COSClient(cosCredentials, clientConfig);
57.             //创建存储对象的请求
58.             PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, key, file);
59.             //执行上传并返回结果信息
60.             PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
61.             return path + key;
62.         } catch (CosClientException e) {
63.             e.printStackTrace();
64.         } finally {
65.             cosClient.shutdown();
66.         }
67.         return null;
68.     }
70.     /**
71.      * upload()重载方法
72.      *
73.      * @param multipartFile
74.      * @return 上传文件在存储桶的链接
75.      */
76.     public String upload(MultipartFile multipartFile) {
77.         System.out.println(multipartFile);
78.         //生成唯一文件名
79.         String newFileName = generateUniqueName(multipartFile.getOriginalFilename());
80.         //文件在存储桶中的key
81.         String key = prefix + newFileName;
82.         //声明客户端
83.         COSClient cosClient = null;
84.         //准备将MultipartFile类型转为File类型
85.         File file = null;
86.         try {
87.             //生成临时文件
88.             file = File.createTempFile("temp", null);
89.             //将MultipartFile类型转为File类型
90.             multipartFile.transferTo(file);
91.             //初始化用户身份信息(secretId,secretKey)
92.             COSCredentials cosCredentials = new BasicCOSCredentials(secretId, secretKey);
93.             //设置bucket的区域
94.             ClientConfig clientConfig = new ClientConfig(new Region(region));
95.             //生成cos客户端
96.             cosClient = new COSClient(cosCredentials, clientConfig);
97.             //创建存储对象的请求
98.             PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, key, file);
99.             //执行上传并返回结果信息
100.             PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
101.             return path + key;
102.         } catch (IOException e) {
103.             e.printStackTrace();
104.         } finally {
105.             cosClient.shutdown();
106.         }
107.         return null;
108.     }
110.     /**
111.      * 根据UUID生成唯一文件名
112.      *
113.      * @param originalName
114.      * @return
115.      */
116.     public String generateUniqueName(String originalName) {
117.         return UUID.randomUUID() + originalName.substring(originalName.lastIndexOf("."));
118.     }
119.     /**
120.      * 删除文件
121.      */
122.     public boolean deleteFile(String fileName) {
123.         String key = prefix + fileName;
124.         COSClient cosclient = null;
125.         try {
126.             //初始化用户身份信息(secretId,secretKey)
127.             COSCredentials cosCredentials = new BasicCOSCredentials(secretId, secretKey);
128.             //设置bucket的区域
129.             ClientConfig clientConfig = new ClientConfig(new Region(region));
130.             // 生成cos客户端
131.             cosclient = new COSClient(cosCredentials, clientConfig);
132.             // 指定要删除的 bucket 和路径
133.             cosclient.deleteObject(bucketName, key);
134.             // 关闭客户端(关闭后台线程)
135.             cosclient.shutdown();
136.         }catch (CosClientException e) {
137.             e.printStackTrace();
138.         }
139.         return true;
140.     }
141. }

复制代码

1. import org.springframework.boot.context.properties.ConfigurationProperties;
2. import org.springframework.context.annotation.Bean;
3. import org.springframework.context.annotation.Configuration;
4. import studio.banner.officialwebsite.util.QCloudCosUtils;
5. /**
6. * 腾讯云对象存储
7. */
8. @Configuration
9. public class QCloudCosUtilsConfig {
10.     @ConfigurationProperties(prefix = "qcloud")
11.     @Bean
12.     public QCloudCosUtils qcloudCosUtils() {
13.         return new QCloudCosUtils();
14.     }
15. }

复制代码

1. import io.swagger.annotations.Api;
2. import io.swagger.annotations.ApiImplicitParam;
3. import io.swagger.annotations.ApiOperation;
4. import org.slf4j.Logger;
5. import org.slf4j.LoggerFactory;
6. import org.springframework.beans.factory.annotation.Autowired;
7. import org.springframework.web.bind.annotation.*;
8. import org.springframework.web.multipart.MultipartFile;
9. import studio.banner.officialwebsite.entity.RespBean;
10. import studio.banner.officialwebsite.service.IFileUploadService;
12. /**
13. * @author
14. * @date 2021/6/6 19:42
15. * @role
16. */
17. @RestController
18. @Api(tags = "腾讯云上传接口", value = "TencentPhotoController")
19. public class TencentPhotoController {
20.     protected static final Logger logger = LoggerFactory.getLogger(TencentPhotoController.class);
21.     @Autowired
22.     private IFileUploadService iFileUploadService;
23.     @PostMapping(value = "/upload")
24.     @ApiOperation(value = "腾讯云上传接口",notes = "上传图片不能为空",httpMethod = "POST")
25.     public RespBean upload(@RequestPart MultipartFile multipartFile) {
26.         String url = iFileUploadService.upload(multipartFile);
27.         return RespBean.ok("上传成功",url);
28.     }
29.     @DeleteMapping("delete")
30.     @ApiOperation(value = "腾讯云删除接口",httpMethod = "DELETE")
31.     @ApiImplicitParam(name = "fileName",value = "图片名",dataTypeClass = String.class)
32.     public RespBean delete(@RequestParam String  fileName) {
33.         if (iFileUploadService.delete(fileName)){
34.             return RespBean.ok("删除成功");
35.         }
36.         return RespBean.error("删除失败");
38.     }
40. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。