Spring Boot使用七牛云

一、引入和配置

//maven配置
<dependency>
    <groupId>com.qiniu</groupId>
    <artifactId>qiniu-java-sdk</artifactId>
    <version>7.7.0</version>
</dependency>
1
2
3
4
5
6

#七牛云application.yml配置 
qiniu:
    # 配置accessKey
    accessKey: "xxx"
    # 配置secretKey
    secretKey: "xxx"
    # 配置空间名称
    bucket: "xxx"
    # 配置域名
    url: "xxx"
1
2
3
4
5
6
7
8
9
10

二、上传文件

//1、获取文件上传的流
byte[] fileBytes = multipartFile.getBytes();

//3、获取文件名
String originalFilename = multipartFile.getOriginalFilename();
String suffix = originalFilename.substring(originalFilename.lastIndexOf("."));
String filename = "file/" + datePath+"/"+ multipartFile.getOriginalFilename();

//4.构造一个带指定 Region 对象的配置类
//Region.南(根据自己的对象空间的地址选
Configuration cfg = new Configuration(Region.huanan());
UploadManager uploadManager = new UploadManager(cfg);

//5.获取七牛云提供的 token
Auth auth = Auth.create(accessKey, accessSecretKey);
String upToken = auth.uploadToken(bucket, filename);
System.out.println("文件名：" + multipartFile.getOriginalFilename());
Response response = uploadManager.put(fileBytes,filename,upToken);
int code = response.statusCode;
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

三、删除文件

    public boolean deleteFile(String key)
    {
        try {
            Configuration cfg = new Configuration(Region.huanan());
            BucketManager bucketManager = new BucketManager(Auth.create(accessKey, accessSecretKey), cfg);
            Response response = bucketManager.delete(bucket, key);
            int code = response.statusCode;
            return code == 200 ? true : false;
        } catch (IOException e) {
            e.printStackTrace();
        }

        return true;
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14

四、检测文件是否存在

    public FileInfo checkFile(String key)
    {
        FileInfo fileInfo = null;
        try {
            Configuration cfg = new Configuration(Region.huanan());
            BucketManager bucketManager = new BucketManager(Auth.create(accessKey, accessSecretKey), cfg);
            fileInfo = bucketManager.stat(bucket, key);
            System.out.println(key);
            System.out.println(fileInfo.status);
        } catch (IOException e) {
            e.getCause();
        }
        return fileInfo;
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14

五、完整代码

package com.xx.file;

import com.alibaba.fastjson.JSONObject;
import com.qiniu.http.Response;
import com.qiniu.storage.*;
import com.qiniu.storage.model.FileInfo;
import com.qiniu.util.Auth;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import com.qiniu.storage.BucketManager;

@Component
public class QiniuUtils {

    @Value("${qiniu.accessKey}")
    private String accessKey;      //公钥

    @Value("${qiniu.secretKey}")
    private  String accessSecretKey;   //私钥

    @Value("${qiniu.bucket}")
    private  String bucket;   // 存储空间

    @Value("${qiniu.url}")//# 域名/路径
    private String url;

    /**
     * 上传图片到七牛云
     * @param multipartFile
     * @return
     */
    public JSONObject uploadImageQiniu(MultipartFile multipartFile)
    {
        JSONObject jsonObject = new JSONObject();

        try {
            //1、获取文件上传的流
            byte[] fileBytes = multipartFile.getBytes();

            //2、创建日期目录分隔
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd");
            String datePath = dateFormat.format(new Date());

            //3、获取文件名
            String originalFilename = multipartFile.getOriginalFilename();
            String suffix = originalFilename.substring(originalFilename.lastIndexOf("."));
            String filename = "file/" + datePath+"/"+ multipartFile.getOriginalFilename();

            //4.构造一个带指定 Region 对象的配置类
            //Region.南(根据自己的对象空间的地址选
            Configuration cfg = new Configuration(Region.huanan());
            UploadManager uploadManager = new UploadManager(cfg);

            //5.获取七牛云提供的 token
            Auth auth = Auth.create(accessKey, accessSecretKey);
            String upToken = auth.uploadToken(bucket, filename);
            System.out.println("文件名：" + multipartFile.getOriginalFilename());
            Response response = uploadManager.put(fileBytes,filename,upToken);
            int code = response.statusCode;

            if (code == 200){
                //jsonObject.put("name", multipartFile.getOriginalFilename());
            } else {
                jsonObject.put("url", "");
            }

        } catch (IOException e) {
            e.printStackTrace();
        }

        return jsonObject;
    }

    /**
     * 删除文件
     * @param key
     * @return
     */
    public boolean deleteFile(String key)
    {
        try {
            Configuration cfg = new Configuration(Region.huanan());
            BucketManager bucketManager = new BucketManager(Auth.create(accessKey, accessSecretKey), cfg);
            Response response = bucketManager.delete(bucket, key);
            int code = response.statusCode;
            return code == 200 ? true : false;
        } catch (IOException e) {
            e.printStackTrace();
        }

        return true;
    }

    /**
     * 检测文件是否存在
     * @param key
     * @return
     */
    public FileInfo checkFile(String key)
    {
        FileInfo fileInfo = null;
        try {
            Configuration cfg = new Configuration(Region.huanan());
            BucketManager bucketManager = new BucketManager(Auth.create(accessKey, accessSecretKey), cfg);
            fileInfo = bucketManager.stat(bucket, key);
            System.out.println(key);
            System.out.println(fileInfo.status);
        } catch (IOException e) {
            e.getCause();
        }
        return fileInfo;
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

六、上传同名文件不刷新问题解决