作者热门文章
- VisualStudio2022插件的安装及使用-编程手把手系列文章
- pprof-在现网场景怎么用
- C#实现的下拉多选框,下拉多选树,多级节点
- 【学习笔记】基础数据结构:猫树
1、拉取镜像 docker pull minio/minio 2、启动镜像 。
docker run -p 9000:9000 -p 9001:9001 --name minio -d --restart=always -e "MINIO_ACCESS_KEY=admin" -e "MINIO_SECRET_KEY=admin123456" -v /home/data:/data -v /home/config:/root/.minio minio/minio server --console-address ":9000" --address ":9001" /data
重要:
命令参数及选项说明:
浏览器输入http://ip:9000/login 。
1、创建桶 。
2、设置权限 。
3、获取accessKey 和 secretKey 。
注意:创建__accessKey 和 secretKey的时候,要注意保存好.
1、添加依赖 。
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>8.2.1</version>
</dependency>
2、demo 。
import io.minio.BucketExistsArgs;
import io.minio.MakeBucketArgs;
import io.minio.MinioClient;
import io.minio.UploadObjectArgs;
import io.minio.errors.MinioException;
import java.io.IOException;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
public class FileUploader {
// minio的api 端口(不是图形界面)
public static String endPoint = "http://xxx.xxx.xxx.xxx:9001/";
public static String accessKey = "YLCS8UYJFX02E70OV7MK";
public static String secretKey = "不能外露";
public static void main(String[] args) throws IOException, NoSuchAlgorithmException, InvalidKeyException {
try {
// 创建minioClient, 使用上面的endpoint,ak,sk
MinioClient minioClient =
MinioClient.builder()
.endpoint(endPoint)
.credentials(accessKey, secretKey)
.build();
// 如果指定的bucket不存在,则创建,否则使用已有bucket
// 指定bucket名称
String bucketName = "test";
boolean found =
minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
if (!found) {
minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
} else {
System.out.println("Bucket '" + bucketName + "' already exists.");
}
// 文件来自哪里
String filePath = "C:\\Users\\DELL\\Pictures\\Saved Pictures\\2.jpg";
// 存储后的文件名
String fileName = "minio_test_text.png";
// 执行文件上传
minioClient.uploadObject(
UploadObjectArgs.builder()
.bucket(bucketName)
.object(fileName)
.filename(filePath)
.build());
System.out.println("'" + filePath + "' 成功上传对象 '" + fileName + "' 到 bucket '" + bucketName + "'.");
} catch (MinioException e) {
System.out.println("Error occurred: " + e);
System.out.println("HTTP trace: " + e.httpTrace());
}
}
}
1、配置文件 。
chuangyue:
minio:
# 访问的url
endpoint: http://xxx.xxx.xxx.xxx
# API的端口
port: 9001
# 秘钥
accessKey: YLCS8UYJFX02E70OV7MK
secretKey: 不能看
secure: false
bucket-name: test # 桶名 我这是给出了一个默认桶名
image-size: 10485760 # 我在这里设定了 图片文件的最大大小
file-size: 1073741824 # 此处是设定了文件的最大大小
2、属性配置类 。
@Component
@ConfigurationProperties(prefix = "chuangyue.minio")
@Data
public class MinioProperties {
// 访问的 api 的url
private String endpoint;
// api端口号
private String port;
// 密钥
private String accessKey;
private String secretKey;
private Boolean secure;
// 桶名
private String bucketName;
// 图片文件的最大大小
private long imageSize;
// 文件的最大大小
private long fileSize;
}
3、工具类 。
package com.zyp.utils;
import io.minio.*;
import io.minio.errors.MinioException;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.util.UUID;
@Component
@Slf4j
public class MinioUtil {
/**
* @ description 上传
* @param file 文件
* @param endPoint 访问的地址
* @param port 端口号
* @param accessKey 密钥
* @param secretKey 密钥
* @param bucketName 桶名称
* @ return java.lang.String
* @ author DELL
*/
public static String upload(MultipartFile file, String endPoint, String port, String accessKey, String secretKey, String bucketName) throws IOException, NoSuchAlgorithmException, InvalidKeyException {
try {
// 创建minioClient
MinioClient minioClient =
MinioClient.builder()
.endpoint(endPoint + ":" + port)
.credentials(accessKey, secretKey)
.build();
// 如果指定的bucket不存在,则创建,否则使用已有bucket
boolean found =
minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
if (!found) {
minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
} else {
log.info("Bucket {} already exists", bucketName);
}
// 获取文件原始名称
String oringinalName = file.getOriginalFilename();
// 获取后缀
String suffix = oringinalName.substring(oringinalName.lastIndexOf('.'));
// 拼接存储后的文件名
String fileName = UUID.randomUUID().toString() + suffix;
PutObjectArgs putObjectArgs = PutObjectArgs.builder()
.bucket(bucketName)
.object(fileName)
.stream(file.getInputStream(), file.getSize(), -1)
.contentType(file.getContentType())
.build();
minioClient.putObject(putObjectArgs);
log.info("文件上传成功");
// 拼接url并返回
return endPoint + ":" + port + "/" + bucketName + "/" + fileName;
} catch (MinioException e) {
System.out.println("Error occurred: " + e);
System.out.println("HTTP trace: " + e.httpTrace());
return "error";
}
}
}
4、使用,定义一个文件上传的接口 。
@RestController
@Slf4j
public class FileUploadController {
@Autowired
private MinioProperties minioProperties;
/**
* @ description 文件上传
* @param file
* @ return com.zyp.pojo.Result<java.lang.String>
* @ author DELL
*/
@PostMapping("/upload")
public Result<String> upload(MultipartFile file) throws Exception {
String url = MinioUtil.upload(file, minioProperties.getEndpoint(), minioProperties.getPort(), minioProperties.getAccessKey(), minioProperties.getSecretKey(), minioProperties.getBucketName());
log.info("url= {}",url);
if(url.isEmpty() || url.equals("error")){
throw new UploadErrorException("文件上传失败");
}else{
return Result.success(url);
}
}
}
1、tomcat限制了文件上传或者下载的大小 解决:修改配置文件 。
spring:
servlet:
multipart:
max-file-size: 50MB
max-request-size: 50MB
最后此篇关于初步搭建一个自己的对象存储服务---Minio的文章就讲到这里了,如果你想了解更多关于初步搭建一个自己的对象存储服务---Minio的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我是一名优秀的程序员,十分优秀!