如何高效搭建基于MinIO的文件服务器?

2026-05-17 00:151阅读0评论SEO教程
  • 内容介绍
  • 文章标签
  • 相关推荐

本文共计1707个文字,预计阅读时间需要7分钟。

如何高效搭建基于MinIO的文件服务器?

1. 下载Minio官方文档选择Docker部署执行命令:docker pull minio/minio启动Minio服务:docker run -p 9000:9000 -p 9001:9001 --name minio1 -v ~\minio\data:/data -e MINIO_ROOT_USER=username -e MINIO_ROOT_PASSWORD=password -d quay.io

1 下载

minio官方文档
我选择的是docker部署

docker pull minio/minio

docker run \ -p 9000:9000 \ -p 9001:9001 \ --name minio1 \ -v ~/minio/data:/data \ -e "MINIO_ROOT_USER=username" \ -e "MINIO_ROOT_PASSWORD=password" \ -d \ quay.io/minio/minio server /data --console-address ":9001"

访问101.42.135.107:9001/ 进入控制台界面 ( 如果是云服务器记得打开9001端口)

2 上传文件到minio

创建名为hms的桶

然后上传一个图片

设置访问规则:

添加只读属性,前缀为 “*”,这样就可以浏览器访问了

访问:服务器ip:9000/桶名/文件名

2 SpringBoot整合 2.1 依赖,主启动

最开始用的8.3.7, 和我的jar包冲突了,又换成8.2.1

如何高效搭建基于MinIO的文件服务器?

<dependency> <groupId>io.minio</groupId> <artifactId>minio</artifactId> <version>8.2.1</version> </dependency> 2.2 配置文件

server: port: 9201 spring: application: name: file datasource: username: root password: 18170021 url: jdbc:mysql://localhost:3306/db_hms_file?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai driver-class-name: com.mysql.cj.jdbc.Driver cloud: nacos: server-addr: localhost:8848 # 配置文件大小限制 servlet: multipart: max-file-size: 100MB max-request-size: 100MB minio: # minio配置是自定义的配置,注意:一定加 endpoint: localhost:9000 accessKey: root secretKey: root18170021 bucketName: hms mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl 2.3 Minio客户端配置类

@Data @Configuration @ConfigurationProperties(prefix = "minio") public class MinioClientConfig { private String endpoint; private String accessKey; private String secretKey; @Bean public MinioClient minioClient() { MinioClient minioClient = MinioClient.builder() .endpoint(endpoint) .credentials(accessKey, secretKey) .build(); return minioClient; } } 2.4 工具类

不要被吓跑哦,我只用到其中的上传下载删除三个方法,不过以后可能会用到就都copy过来了

@Component public class MinioUtil { @Autowired private MinioClient minioClient; /** * 查看存储bucket是否存在 * @return boolean */ public Boolean bucketExists(String bucketName) { Boolean found; try { found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build()); } catch (Exception e) { return false; } return found; } /** * 创建存储bucket * @return Boolean */ public Boolean makeBucket(String bucketName) { try { minioClient.makeBucket(MakeBucketArgs.builder() .bucket(bucketName) .build()); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 删除存储bucket * @return Boolean */ public Boolean removeBucket(String bucketName) { try { minioClient.removeBucket(RemoveBucketArgs.builder() .bucket(bucketName) .build()); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 获取全部bucket */ public List<Bucket> getAllBuckets() { try { return minioClient.listBuckets(); } catch (Exception e) { e.printStackTrace(); } return null; } /** * 文件上传 * @param file 文件 * @return Boolean */ public Boolean upload(String bucketName, String fileName, MultipartFile file, InputStream inputStream) { try { PutObjectArgs objectArgs = PutObjectArgs.builder().bucket(bucketName).object(fileName) .stream(inputStream,file.getSize(),-1).contentType(file.getContentType()).build(); //文件名称相同会覆盖 minioClient.putObject(objectArgs); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 预览图片 * @param fileName * @return */ public String preview(String fileName,String bucketName){ // 查看文件地址 GetPresignedObjectUrlArgs build = GetPresignedObjectUrlArgs .builder().bucket(bucketName) .object(fileName) .method(Method.GET).build(); try { String url = minioClient.getPresignedObjectUrl(build); return url; } catch (Exception e) { e.printStackTrace(); } return null; } /** * 文件下载 * @param fileName 文件名称 * @param res response * @return Boolean */ public void download(String fileName,String bucketName, HttpServletResponse res) { GetObjectArgs objectArgs = GetObjectArgs.builder().bucket(bucketName) .object(fileName).build(); try (GetObjectResponse response = minioClient.getObject(objectArgs)){ 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(); } } /** * 查看文件对象 * @return 存储bucket内文件对象信息 */ public List<Item> listObjects(String bucketName) { Iterable<Result<Item>> results = minioClient.listObjects( ListObjectsArgs.builder().bucket(bucketName).build()); List<Item> items = new ArrayList<>(); try { for (Result<Item> result : results) { items.add(result.get()); } } catch (Exception e) { e.printStackTrace(); return null; } return items; } /** * 删除 * @param fileName * @return * @throws Exception */ public boolean remove(String fileName,String bucketName){ try { minioClient.removeObject( RemoveObjectArgs.builder().bucket(bucketName).object(fileName).build()); }catch (Exception e){ return false; } return true; } /** * 批量删除文件对象(没测试) * @param objects 对象名称集合 */ public Iterable<Result<DeleteError>> removeObjects(List<String> objects, String bucketName) { List<DeleteObject> dos = objects.stream().map(e -> new DeleteObject(e)).collect(Collectors.toList()); Iterable<Result<DeleteError>> results = minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(dos).build()); return results; } } 2.5 Controller

@RestController @RequestMapping("file") public class FileController { private static final Logger log = LogManager.getLogger(); @Autowired private FileItemServiceImpl fileItemService; @PostMapping("upload") public Result upload(@Valid @NotNull @RequestParam(value = "file") MultipartFile file, @Valid @NotNull Integer type) { Result result; try { FileItemVO fileItemVO = fileItemService.uploadFile(file, type); result = Result.success("文件上传成功!", fileItemVO); } catch (BcException e) { result = Result.error(e.getCode(), e.getMessage()); log.error(e.getMessage()); } return result; } @GetMapping("download") public void download(HttpServletResponse response, @Valid @RequestParam @NotBlank(message = "fileId不能为空") Integer fileId) { try { fileItemService.downloadFile(fileId, response); } catch (BcException e) { log.error(e.getMessage()); } } @GetMapping("delete") public Result<String> delete(@Valid @RequestParam @NotBlank(message = "fileId不能为空") Long fileId) { Result result; try { fileItemService.deleteFile(fileId); result = Result.success("删除附件成功!", fileId); } catch (BcException e) { result = Result.error(e.getCode(), e.getMessage()); } return result; } } 2.6 Service

service

public interface FileItemService { /** * 上传文件到服务器中 * @param file * @param type * @return */ FileItemVO uploadFile(MultipartFile file, Integer type); /** * 下载文件 * @param fileId * @param response */ void downloadFile(Integer fileId, HttpServletResponse response); /** * 删除文件 * @param fileId */ void deleteFile(Long fileId); }

serviceImpl

@Service public class FileItemServiceImpl implements FileItemService { @Resource private MinioUtil minioUtil; @Value("${minio.bucketName}") private String bucketName; @Value("${minio.endpoint}") private String endpoint; @Autowired private FileMapper fileMapper; private String[] fileFolders = new String[]{"doctorPhotos/", "report", "otherImage/"}; @Override @Transactional(rollbackFor = Exception.class) public FileItemVO uploadFile(MultipartFile file, Integer type) { FileItemVO fileItemVO = null; try { String fileName = file.getOriginalFilename(); String ext = fileName.substring(fileName.lastIndexOf(".")); String newFileName = fileFolders[type] + UUID.randomUUID().toString().replaceAll("-", "") + ext; InputStream inputStream = file.getInputStream(); Boolean flag = minioUtil.upload(bucketName, newFileName,file, inputStream); if(!flag) { throw new BcException(ErrorCode.file_upload_fail.getCode(), "文件上传失败"); } String url = getUrl(newFileName); fileItemVO = FileItemVO.builder() .newFileName(newFileName) .fileName(fileName) .ext(ext) .url(url) .build(); FileEntity fileEntity = new FileEntity(); BeanUtils.copyProperties(fileItemVO, fileEntity); fileEntity.setType(type); fileMapper.insert(fileEntity); fileItemVO.setFileId(fileEntity.getId()); } catch (Exception e) { throw new BcException(ErrorCode.file_upload_fail.getCode(), "文件上传失败"); } return fileItemVO; } @Transactional(readOnly = true) @Override public void downloadFile(Integer fileId, HttpServletResponse response) { FileEntity fileEntity = fileMapper.selectById(fileId); if(ObjectUtils.isEmpty(fileEntity)) { throw new BcException(ErrorCode.file_not_exit.getCode(), "文件不存在"); } try { minioUtil.download(fileEntity.getNewFileName(), bucketName, response); } catch (Exception e) { throw new BcException(ErrorCode.download_id_exception.getCode(), "文件下载失败"); } } @Transactional(rollbackFor = Exception.class) @Override public void deleteFile(Long fileId) { FileEntity fileEntity = fileMapper.selectById(fileId); if(ObjectUtils.isEmpty(fileEntity)) { throw new BcException(ErrorCode.file_not_exit.getCode(), "文件不存在"); } try { minioUtil.remove(fileEntity.getNewFileName(), bucketName); fileMapper.deleteById(fileId); } catch (Exception e) { throw new BcException(ErrorCode.download_id_exception.getCode(), "文件删除失败"); } } private String getUrl(String newFileName) { return endpoint + "/" + bucketName + "/" + newFileName; } } 2.7 实体和数据库

FileItemVO (上传文件后响应结果)

@Data @AllArgsConstructor @NoArgsConstructor @Builder public class FileItemVO { /** * 文件id */ private Long fileId; /** * 文件可访问URL */ private String url; /** * 文件的拓展名 */ private String ext; /** * 上传的源文件的文件名,带有拓展 */ private String fileName; /** * 上传后的文件名 */ private String newFileName; }

file表

DROP TABLE IF EXISTS `file`; CREATE TABLE `file` ( `id` bigint(0) NOT NULL AUTO_INCREMENT COMMENT 'id', `file_name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '用户上传文件的原始名称,带有文件拓展', `ext` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '文件拓展名', `type` int(0) NOT NULL COMMENT '文件类型:1医生照片 2其他图片 3体检报告', `url` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'url', `new_file_name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'minio里面的文件名', `created_time` datetime(0) NOT NULL COMMENT '创建时间', `modified_time` datetime(0) NOT NULL COMMENT '修改时间', `state` int(0) NOT NULL DEFAULT 0 COMMENT '状态', PRIMARY KEY (`id`) USING BTREE ) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic; SET FOREIGN_KEY_CHECKS = 1; 2.8 参考链接

参考链接:
www.cnblogs.com/shanheyongmu/p/15581961.html

本文共计1707个文字,预计阅读时间需要7分钟。

如何高效搭建基于MinIO的文件服务器?

1. 下载Minio官方文档选择Docker部署执行命令:docker pull minio/minio启动Minio服务:docker run -p 9000:9000 -p 9001:9001 --name minio1 -v ~\minio\data:/data -e MINIO_ROOT_USER=username -e MINIO_ROOT_PASSWORD=password -d quay.io

1 下载

minio官方文档
我选择的是docker部署

docker pull minio/minio

docker run \ -p 9000:9000 \ -p 9001:9001 \ --name minio1 \ -v ~/minio/data:/data \ -e "MINIO_ROOT_USER=username" \ -e "MINIO_ROOT_PASSWORD=password" \ -d \ quay.io/minio/minio server /data --console-address ":9001"

访问101.42.135.107:9001/ 进入控制台界面 ( 如果是云服务器记得打开9001端口)

2 上传文件到minio

创建名为hms的桶

然后上传一个图片

设置访问规则:

添加只读属性,前缀为 “*”,这样就可以浏览器访问了

访问:服务器ip:9000/桶名/文件名

2 SpringBoot整合 2.1 依赖,主启动

最开始用的8.3.7, 和我的jar包冲突了,又换成8.2.1

如何高效搭建基于MinIO的文件服务器?

<dependency> <groupId>io.minio</groupId> <artifactId>minio</artifactId> <version>8.2.1</version> </dependency> 2.2 配置文件

server: port: 9201 spring: application: name: file datasource: username: root password: 18170021 url: jdbc:mysql://localhost:3306/db_hms_file?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai driver-class-name: com.mysql.cj.jdbc.Driver cloud: nacos: server-addr: localhost:8848 # 配置文件大小限制 servlet: multipart: max-file-size: 100MB max-request-size: 100MB minio: # minio配置是自定义的配置,注意:一定加 endpoint: localhost:9000 accessKey: root secretKey: root18170021 bucketName: hms mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl 2.3 Minio客户端配置类

@Data @Configuration @ConfigurationProperties(prefix = "minio") public class MinioClientConfig { private String endpoint; private String accessKey; private String secretKey; @Bean public MinioClient minioClient() { MinioClient minioClient = MinioClient.builder() .endpoint(endpoint) .credentials(accessKey, secretKey) .build(); return minioClient; } } 2.4 工具类

不要被吓跑哦,我只用到其中的上传下载删除三个方法,不过以后可能会用到就都copy过来了

@Component public class MinioUtil { @Autowired private MinioClient minioClient; /** * 查看存储bucket是否存在 * @return boolean */ public Boolean bucketExists(String bucketName) { Boolean found; try { found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build()); } catch (Exception e) { return false; } return found; } /** * 创建存储bucket * @return Boolean */ public Boolean makeBucket(String bucketName) { try { minioClient.makeBucket(MakeBucketArgs.builder() .bucket(bucketName) .build()); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 删除存储bucket * @return Boolean */ public Boolean removeBucket(String bucketName) { try { minioClient.removeBucket(RemoveBucketArgs.builder() .bucket(bucketName) .build()); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 获取全部bucket */ public List<Bucket> getAllBuckets() { try { return minioClient.listBuckets(); } catch (Exception e) { e.printStackTrace(); } return null; } /** * 文件上传 * @param file 文件 * @return Boolean */ public Boolean upload(String bucketName, String fileName, MultipartFile file, InputStream inputStream) { try { PutObjectArgs objectArgs = PutObjectArgs.builder().bucket(bucketName).object(fileName) .stream(inputStream,file.getSize(),-1).contentType(file.getContentType()).build(); //文件名称相同会覆盖 minioClient.putObject(objectArgs); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 预览图片 * @param fileName * @return */ public String preview(String fileName,String bucketName){ // 查看文件地址 GetPresignedObjectUrlArgs build = GetPresignedObjectUrlArgs .builder().bucket(bucketName) .object(fileName) .method(Method.GET).build(); try { String url = minioClient.getPresignedObjectUrl(build); return url; } catch (Exception e) { e.printStackTrace(); } return null; } /** * 文件下载 * @param fileName 文件名称 * @param res response * @return Boolean */ public void download(String fileName,String bucketName, HttpServletResponse res) { GetObjectArgs objectArgs = GetObjectArgs.builder().bucket(bucketName) .object(fileName).build(); try (GetObjectResponse response = minioClient.getObject(objectArgs)){ 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(); } } /** * 查看文件对象 * @return 存储bucket内文件对象信息 */ public List<Item> listObjects(String bucketName) { Iterable<Result<Item>> results = minioClient.listObjects( ListObjectsArgs.builder().bucket(bucketName).build()); List<Item> items = new ArrayList<>(); try { for (Result<Item> result : results) { items.add(result.get()); } } catch (Exception e) { e.printStackTrace(); return null; } return items; } /** * 删除 * @param fileName * @return * @throws Exception */ public boolean remove(String fileName,String bucketName){ try { minioClient.removeObject( RemoveObjectArgs.builder().bucket(bucketName).object(fileName).build()); }catch (Exception e){ return false; } return true; } /** * 批量删除文件对象(没测试) * @param objects 对象名称集合 */ public Iterable<Result<DeleteError>> removeObjects(List<String> objects, String bucketName) { List<DeleteObject> dos = objects.stream().map(e -> new DeleteObject(e)).collect(Collectors.toList()); Iterable<Result<DeleteError>> results = minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(dos).build()); return results; } } 2.5 Controller

@RestController @RequestMapping("file") public class FileController { private static final Logger log = LogManager.getLogger(); @Autowired private FileItemServiceImpl fileItemService; @PostMapping("upload") public Result upload(@Valid @NotNull @RequestParam(value = "file") MultipartFile file, @Valid @NotNull Integer type) { Result result; try { FileItemVO fileItemVO = fileItemService.uploadFile(file, type); result = Result.success("文件上传成功!", fileItemVO); } catch (BcException e) { result = Result.error(e.getCode(), e.getMessage()); log.error(e.getMessage()); } return result; } @GetMapping("download") public void download(HttpServletResponse response, @Valid @RequestParam @NotBlank(message = "fileId不能为空") Integer fileId) { try { fileItemService.downloadFile(fileId, response); } catch (BcException e) { log.error(e.getMessage()); } } @GetMapping("delete") public Result<String> delete(@Valid @RequestParam @NotBlank(message = "fileId不能为空") Long fileId) { Result result; try { fileItemService.deleteFile(fileId); result = Result.success("删除附件成功!", fileId); } catch (BcException e) { result = Result.error(e.getCode(), e.getMessage()); } return result; } } 2.6 Service

service

public interface FileItemService { /** * 上传文件到服务器中 * @param file * @param type * @return */ FileItemVO uploadFile(MultipartFile file, Integer type); /** * 下载文件 * @param fileId * @param response */ void downloadFile(Integer fileId, HttpServletResponse response); /** * 删除文件 * @param fileId */ void deleteFile(Long fileId); }

serviceImpl

@Service public class FileItemServiceImpl implements FileItemService { @Resource private MinioUtil minioUtil; @Value("${minio.bucketName}") private String bucketName; @Value("${minio.endpoint}") private String endpoint; @Autowired private FileMapper fileMapper; private String[] fileFolders = new String[]{"doctorPhotos/", "report", "otherImage/"}; @Override @Transactional(rollbackFor = Exception.class) public FileItemVO uploadFile(MultipartFile file, Integer type) { FileItemVO fileItemVO = null; try { String fileName = file.getOriginalFilename(); String ext = fileName.substring(fileName.lastIndexOf(".")); String newFileName = fileFolders[type] + UUID.randomUUID().toString().replaceAll("-", "") + ext; InputStream inputStream = file.getInputStream(); Boolean flag = minioUtil.upload(bucketName, newFileName,file, inputStream); if(!flag) { throw new BcException(ErrorCode.file_upload_fail.getCode(), "文件上传失败"); } String url = getUrl(newFileName); fileItemVO = FileItemVO.builder() .newFileName(newFileName) .fileName(fileName) .ext(ext) .url(url) .build(); FileEntity fileEntity = new FileEntity(); BeanUtils.copyProperties(fileItemVO, fileEntity); fileEntity.setType(type); fileMapper.insert(fileEntity); fileItemVO.setFileId(fileEntity.getId()); } catch (Exception e) { throw new BcException(ErrorCode.file_upload_fail.getCode(), "文件上传失败"); } return fileItemVO; } @Transactional(readOnly = true) @Override public void downloadFile(Integer fileId, HttpServletResponse response) { FileEntity fileEntity = fileMapper.selectById(fileId); if(ObjectUtils.isEmpty(fileEntity)) { throw new BcException(ErrorCode.file_not_exit.getCode(), "文件不存在"); } try { minioUtil.download(fileEntity.getNewFileName(), bucketName, response); } catch (Exception e) { throw new BcException(ErrorCode.download_id_exception.getCode(), "文件下载失败"); } } @Transactional(rollbackFor = Exception.class) @Override public void deleteFile(Long fileId) { FileEntity fileEntity = fileMapper.selectById(fileId); if(ObjectUtils.isEmpty(fileEntity)) { throw new BcException(ErrorCode.file_not_exit.getCode(), "文件不存在"); } try { minioUtil.remove(fileEntity.getNewFileName(), bucketName); fileMapper.deleteById(fileId); } catch (Exception e) { throw new BcException(ErrorCode.download_id_exception.getCode(), "文件删除失败"); } } private String getUrl(String newFileName) { return endpoint + "/" + bucketName + "/" + newFileName; } } 2.7 实体和数据库

FileItemVO (上传文件后响应结果)

@Data @AllArgsConstructor @NoArgsConstructor @Builder public class FileItemVO { /** * 文件id */ private Long fileId; /** * 文件可访问URL */ private String url; /** * 文件的拓展名 */ private String ext; /** * 上传的源文件的文件名,带有拓展 */ private String fileName; /** * 上传后的文件名 */ private String newFileName; }

file表

DROP TABLE IF EXISTS `file`; CREATE TABLE `file` ( `id` bigint(0) NOT NULL AUTO_INCREMENT COMMENT 'id', `file_name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '用户上传文件的原始名称,带有文件拓展', `ext` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '文件拓展名', `type` int(0) NOT NULL COMMENT '文件类型:1医生照片 2其他图片 3体检报告', `url` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'url', `new_file_name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT 'minio里面的文件名', `created_time` datetime(0) NOT NULL COMMENT '创建时间', `modified_time` datetime(0) NOT NULL COMMENT '修改时间', `state` int(0) NOT NULL DEFAULT 0 COMMENT '状态', PRIMARY KEY (`id`) USING BTREE ) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic; SET FOREIGN_KEY_CHECKS = 1; 2.8 参考链接

参考链接:
www.cnblogs.com/shanheyongmu/p/15581961.html