springboot整合minio实现文件上传与下载且支持链接永久访问
短信预约 -IT技能 免费直播动态提醒
1、minio部署
1.1 拉取镜像
docker pull minio/minio
1.2 创建数据目录
mkdir -p /home/guanz/minio
mkdir -p /home/guanz/minio/midata
1.3 启动minio
docker run -d -p 9000:9000 -p 9001:9001 --restart=always -e MINIO_ACCESS_KEY=guanz -e MINIO_SECRET_KEY=guanz@123 -v $PWD/midata:/data minio/minio server /data --console-address "192.168.1.139:9001"
2、项目搭建
2.1 引入jar
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>8.0.3</version>
</dependency>
2.2 application-dev.yml
spring
minio:
# Minio服务器地址
endpoint: http://192.168.1.139:9000
port: 9001
create-bucket: true
bucketName: push-test
# Minio服务器账号
accessKey: guanz
# Minio服务器密码
secretKey: guanz@123
secure: false
configDir: /home/push
# 文件大小 单位M
maxFileSize: 10
expires: 604800
2.4 MinioConfig.java
package com.pavis.app.saasbacken.config;
import io.minio.MinioClient;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;
@Data
@Component
@ConfigurationProperties(prefix = "minio")
@Slf4j
@Configuration
public class MinioConfig {
@ApiModelProperty("endPoint是一个URL，域名，IPv4或者IPv6地址")
@Value("${spring.minio.endpoint}")
private String endpoint;
@ApiModelProperty("TCP/IP端口号")
@Value("${spring.minio.port}")
private int port;
@ApiModelProperty("accessKey类似于用户ID，用于唯一标识你的账户")
@Value("${spring.minio.accessKey}")
private String accessKey;
@ApiModelProperty("secretKey是你账户的密码")
@Value("${spring.minio.secretKey}")
private String secretKey;
@ApiModelProperty("如果是true，则用的是https而不是http,默认值是true")
@Value("${spring.minio.secure}")
private Boolean secure;
@ApiModelProperty("默认存储桶")
@Value("${spring.minio.bucketName}")
private String bucketName;
@ApiModelProperty("配置目录")
@Value("${spring.minio.configDir}")
private String configDir;
@ApiModelProperty("文件大小")
@Value("${spring.minio.maxFileSize}")
private Integer maxFileSize;
@ApiModelProperty("签名有效时间")
@Value("${spring.minio.expires}")
private Integer expires;
@Bean
public MinioClient minioClient(){
log.info("endpoint:{},port:{},accessKey:{},secretKey:{},secure:{}",endpoint, port, accessKey, secretKey,secure);
return MinioClient.builder()
.endpoint(endpoint)
.credentials(accessKey, secretKey)
.build();
}
}3、文件上传
3.1 关键代码
MinioController.java
@PostMapping("/upload")
public Map<String, Object> upload(MultipartFile file){
return minioService.upload(file);
}MinioServiceImpl.java
@Override
public Map<String, Object> upload(MultipartFile file) {
Map<String, Object> res = new HashMap<>();
try {
BucketExistsArgs bucketArgs = BucketExistsArgs.builder().bucket(bucketName).build();
// todo 检查bucket是否存在。
boolean found = minioClient.bucketExists(bucketArgs);
PutObjectArgs objectArgs = PutObjectArgs.builder().object(file.getOriginalFilename())
.bucket(bucketName)
.contentType(file.getContentType())
.stream(file.getInputStream(), file.getSize(), -1).build();
ObjectWriteResponse objectWriteResponse = minioClient.putObject(objectArgs);
System.out.println(objectWriteResponse.etag());
res.put("code", "1");
res.put("mess", "ok");
return res;
} catch (Exception e) {
e.printStackTrace();
log.info(e.getMessage());
}
res.put("code", "0");
return res;
}4、文件下载
@Override
public void download(String filename, HttpServletResponse res) throws IOException, InvalidKeyException, InvalidResponseException, InsufficientDataException, NoSuchAlgorithmException, ServerException, InternalException, XmlParserException, ErrorResponseException {
BucketExistsArgs bucketArgs = BucketExistsArgs.builder().bucket(bucketName).build();
boolean bucketExists = minioClient.bucketExists(bucketArgs);
log.info("bucketExists:{}", bucketExists);
GetObjectArgs objectArgs = GetObjectArgs.builder().bucket(bucketName)
.object(filename).build();
System.err.println("objectArgs:" + JSON.toJSONString(objectArgs));
try (GetObjectResponse response = minioClient.getObject(objectArgs)) {
System.err.println("response:" + JSON.toJSONString(response));
byte[] buf = new byte[1024];
int len;
try (FastByteArrayOutputStream os = new FastByteArrayOutputStream()) {
while ((len = response.read(buf)) != -1) {
os.write(buf, 0, len);
}
os.flush();
byte[] bytes = os.toByteArray();
res.setCharacterEncoding("utf-8");
res.setContentType("application/force-download");// 设置强制下载不打开
res.addHeader("Content-Disposition", "attachment;fileName=" + filename);
try (ServletOutputStream stream = res.getOutputStream()) {
stream.write(bytes);
stream.flush();
}
}
} catch (Exception e) {
e.printStackTrace();
}
}下载地址：
5、文件永久链接下载
5.1 配置
5.2 关键代码
public String presignedGetObject(String bucketName, String objectName, Integer expires) throws IOException, InvalidKeyException, InvalidResponseException, InsufficientDataException, NoSuchAlgorithmException, ServerException, InternalException, XmlParserException, ErrorResponseException {
BucketExistsArgs bucketArgs = BucketExistsArgs.builder().bucket(bucketName).build();
boolean bucketExists = minioClient.bucketExists(bucketArgs);
// boolean flag = bucketExists(bucketName);
String url = "";
if (bucketExists) {
try {
if (expires == null){
expires = 604800;
}
GetPresignedObjectUrlArgs getPresignedObjectUrlArgs = GetPresignedObjectUrlArgs.builder()
.method(Method.GET)
.bucket(bucketName)
.object(objectName)
// .expiry(expires)
.build();
url = minioClient.getPresignedObjectUrl(getPresignedObjectUrlArgs);
log.info("*******url2:{}",url);
} catch (Exception e) {
log.info("presigned get object fail:{}",e);
}
}
return url;
}下载地址：http://192.168.1.139:9000/push-test/qiyeku.jpg
至此，springboot+minio 结束。
到此这篇关于springboot整合minio实现文件上传与下载且支持链接永久访问的文章就介绍到这了,更多相关springboot minio 文件上传下载 内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
