Minio实现文件上传、下载、预览、删除 修改

2024-08-25 22:20
文章标签 实现 删除 下载 修改 预览 上传 minio

本文主要是介绍Minio实现文件上传、下载、预览、删除 修改，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

完成项目

AjaxResult 结果返回使用的 若依。

1. pom.xml

        <!-- MinIO Client --><dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.2.2</version></dependency>

2. application.yml

# Spring配置
spring:# minio配置servlet:multipart:enabled: true# 单个文件大小max-file-size: 100MB# 设置总上传的文件大小max-request-size: 200MBlocation: /usr/local/minio/data_file/temp_file/

　注意：配置的存放文件的路径。

# minio配置
minio:endpoint: http://120.服务器:9001accessKey: minioadminsecretKey: minioadminbucket: jx-file

　注意：endpoint- ip + 端口

　　　　账号 密码

　　　　bucket-创建的桶

3. Minio工具类

package com.ruoyi.xinzhi.utils;import io.minio.*;
import io.minio.http.Method;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;import java.io.InputStream;/*** MinIO 服务*/
@Component
public class MinIOUtil {// 指定MinIO服务的访问地址（包括协议、域名或IP以及端口）private static String endpoint;// MinIO的访问密钥（Access Key），用于身份验证private static String accessKey;// MinIO的秘密密钥（Secret Key），与访问密钥配对使用，也是认证的一部分。private static String secretKey;// 指定默认的存储桶（Bucket）名称，MinIO中用于组织和存储对象（文件）的基本容器。private static String bucket;@Value("${minio.endpoint}")public void setEndpoint(String endpoint) {MinIOUtil.endpoint = endpoint;}@Value("${minio.accessKey}")public void setAccessKey(String accessKey) {MinIOUtil.accessKey = accessKey;}@Value("${minio.secretKey}")public void setSecretKey(String secretKey) {MinIOUtil.secretKey = secretKey;}@Value("${minio.bucket}")public void setBucket(String bucket) {MinIOUtil.bucket = bucket;}/*** 创建并返回一个配置好的MinioClient实例* 用于与MinIO服务器交互,上传文件、下载文件、删除文件** @return 配置*/private static MinioClient getMinioClient() {return MinioClient.builder().endpoint(endpoint).credentials(accessKey, secretKey).build();}/*** 上传：将一个输入流中的文件上传到MinIO服务器上指定的存储桶（bucket）里** @param objectName  .object(objectName)指定了上传后对象的名称。* @param inputStream 转换为 流* @param size        文件大小* @param contentType 内容类型* @throws Exception 异常*/public static void uploadFile(String objectName, InputStream inputStream, long size, String contentType) throws Exception {MinioClient minioClient = getMinioClient();minioClient.putObject(// .bucket(bucket) 指定了目标存储桶的名称。.object(objectName)指定了上传后对象的名称。PutObjectArgs.builder().bucket(bucket).object(objectName).stream(inputStream, size, -1)// .contentType(contentType)指定了上传文件的内容类型。.contentType(contentType).build());}/*** 下载：从MinIO服务器下载指定存储桶（bucket）中的文件** @param objectName 指定要从MinIO下载的文件对象名称（即文件路径和文件名）。* @return 流 对象* @throws Exception 异常*/public static InputStream downloadFile(String objectName) throws Exception {MinioClient minioClient = getMinioClient();return minioClient.getObject(GetObjectArgs.builder()// .bucket(bucket)指定了文件所在的存储桶名称。.bucket(bucket)// .object(objectName)指定了要下载的对象名称。.object(objectName).build());}/*** 预览：生成一个预签名的URL，允许用户通过浏览器或其他HTTP客户端以GET方法访问MinIO存储桶中指定对象（文件）的临时链接** @param objectName 指定需要获取预览链接的文件对象名称（包括路径）。* @return 对象* @throws Exception .method(Method.GET)指定了请求的方法为GET，这是预览文件时的标准HTTP方法。*                   .bucket(bucket)指定了存储桶的名称。*                   .object(objectName)指定了对象（文件）的名称。*/public static String getPreviewUrl(String objectName) throws Exception {MinioClient minioClient = getMinioClient();return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().method(Method.GET).bucket(bucket).object(objectName).build());}/*** 删除：从MinIO服务器上的指定存储桶中删除一个文件** @param objectName 指定要删除的文件对象名称（包括路径和文件名）* @throws Exception*/public static void deleteFile(String objectName) throws Exception {MinioClient minioClient = getMinioClient();minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucket).object(objectName).build());}
}

4. 实体类

package com.ruoyi.xinzhi.dto;import com.baomidou.mybatisplus.annotation.TableId;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;/*** 文件的实体类*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class JxAttachment {/** 文件ID */@TableId(value = "fileId")private Integer fileId;/** 文件名称 */private String fileName;/** 文件大小 */private String fileSize;/** 上传人员 */private String uploadingStaff;/** 上传时间 */private String uploadTime;/** 文件新名词 */private String fileNewName;/** 文件地址 */private String fileAddress;/** 部门编号 */private String deptNumber;}


package com.ruoyi.xinzhi.dto;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;/*** 文件预览DTO*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class JxAttachmentPreviewDTO {/** 文件ID */private Integer fileId;/** 文件名称 */private String fileName;/** 文件大小 */private String fileSize;/** 上传人员 */private String uploadingStaff;/** 文件地址 */private String fileAddress;/** 文件新名词 */private String fileNewName;/** 上传时间 */private String uploadTime;}

 5. Mapper层

package com.ruoyi.xinzhi.mapper;import com.ruoyi.xinzhi.dto.JxAttachment;
import com.ruoyi.xinzhi.dto.JxAttachmentPreviewDTO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;import java.util.List;/*** 文件*/
@Mapper
public interface JxFileMapper {/** 添加上传信息 */int insertFiles(JxAttachment attachment);/** 部门编号 查询文件信息 */List<JxAttachmentPreviewDTO> previewFileByDeptNum(String deptNumber);/** 文件删除 */void deleteFile(@Param("fileName") String fileName, @Param("deptNumber") String deptNumber);/**修改**/int updateFile(@Param("fileId") Integer fileId,@Param("fileName") String fileName,@Param("deptNumber") String deptNumber);
}

6. Service业务层

　只需要实现类与Controller交互

package com.ruoyi.xinzhi.service.impl;import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.xinzhi.dto.JxAttachment;
import com.ruoyi.xinzhi.dto.JxAttachmentPreviewDTO;
import com.ruoyi.xinzhi.mapper.JxFileMapper;
import com.ruoyi.xinzhi.utils.MinIOUtil;
import org.apache.commons.io.FilenameUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;import java.io.File;
import java.io.InputStream;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;@Service
public class JxFileService {@Autowiredprivate JxFileMapper jxFileMapper;//    @Value("${spring.servlet.multipart.location}")
//    private String tempDir;@Transactionalpublic AjaxResult uploadFile(MultipartFile file, String deptNumber) throws Exception {String filename = file.getOriginalFilename();   // 获取文件名long size = file.getSize(); // 文件大小File tempDirectory = new File("/usr/local/minio/data_file");if (!tempDirectory.exists()) {tempDirectory.mkdir();}try (InputStream inputStream = file.getInputStream()) {// 获取文件扩展名String fileExtension = FilenameUtils.getExtension(filename);// 获取不带后缀文件名String baseName = FilenameUtils.getBaseName(filename);// 生成5位时间戳String timestamp = new SimpleDateFormat("ssSSS").format(new Date());// 生成唯一文件名String fileName = baseName + "_" + timestamp + "." + fileExtension;// 文件的路径String fileAddress = "/usr/local/minio/data_file/" + fileName;// 文件上传到 MinIO 客户端MinIOUtil.uploadFile(fileName, inputStream, size, file.getContentType());// 文件大小转换String fileSize = formatFileSize(size);// 信息存入数据库JxAttachment attachment = JxAttachment.builder().fileName(filename).fileSize(fileSize).uploadingStaff("TODO: Add Staff Name").uploadTime(formatDate(new Date())).fileNewName(fileName).fileAddress(fileAddress).deptNumber(deptNumber).build();jxFileMapper.insertFiles(attachment);return AjaxResult.success("上传成功");} catch (Exception e) {throw new RuntimeException("上传有误", e);}}public AjaxResult updateFile(Integer fileId, String fileName, String deptNumber) {try {int result = jxFileMapper.updateFile(fileId, fileName, deptNumber);if (result > 0) {return AjaxResult.success("文件更新成功");} else {return AjaxResult.error("文件更新失败");}} catch (Exception e) {return AjaxResult.error("文件更新过程中出现错误");}}public AjaxResult previewFile(String deptNumber) throws Exception {List<JxAttachmentPreviewDTO> attachments = jxFileMapper.previewFileByDeptNum(deptNumber);for (JxAttachmentPreviewDTO attachment : attachments) {String fileName = attachment.getFileNewName();String fileUrl = MinIOUtil.getPreviewUrl(fileName);attachment.setFileAddress(fileUrl);}return AjaxResult.success(attachments);}public AjaxResult deleteFile(String fileName, String deptNumber) {try {jxFileMapper.deleteFile(fileName, deptNumber);MinIOUtil.deleteFile(fileName);return AjaxResult.success("文件删除成功");} catch (Exception e) {return AjaxResult.error("文件删除失败");}}private String formatFileSize(long size) {DecimalFormat decimalFormat = new DecimalFormat("0.00");if (size < 1024) {return size + "B";} else if (size < 1024 * 1024) {return decimalFormat.format((double) size / 1024) + "KB";} else {return decimalFormat.format((double) size / (1024 * 1024)) + "MB";}}private String formatDate(Date date) {SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");return formatter.format(date);}
}

 7. Controller控制层

package com.ruoyi.xinzhi.controller;import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.xinzhi.service.impl.JxFileService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;@RestController
@RequestMapping("/file")
public class JxFileController {@Autowiredprivate JxFileService jxFileService;/** 文件上传 */@PostMapping("/upload")public AjaxResult uploadFile(@RequestParam("file") MultipartFile file,@RequestParam("deptNumber") String deptNumber) throws Exception {return jxFileService.uploadFile(file, deptNumber);}/** 文件预览 */@GetMapping("/preview")public AjaxResult previewFile(@RequestParam("deptNumber") String deptNumber) throws Exception {return jxFileService.previewFile(deptNumber);}/** 文件删除 */@DeleteMapping("/delete")public AjaxResult deleteFile(@RequestParam("fileName") String fileName,@RequestParam("deptNumber") String deptNumber) {return jxFileService.deleteFile(fileName, deptNumber);}
//    修改@PutMapping("/update")public AjaxResult updateFile(@RequestParam("fileId") Integer fileId,@RequestParam("file") MultipartFile file,@RequestParam("deptNumber") String deptNumber) {return jxFileService.updateFile(fileId, String.valueOf(file), deptNumber);}
}

sql语句chua

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ruoyi.xinzhi.mapper.JxFileMapper"><resultMap id="attachment" type="com.ruoyi.xinzhi.dto.JxAttachment"><id property="fileId" column="file_id"/><result property="fileName" column="file_name"/><result property="fileSize" column="file_size"/><result property="uploadingStaff" column="uploading_staff"/><result property="uploadTime" column="upload_time"/><result property="fileNewName" column="file_new_name"/><result property="fileAddress" column="file_address"/><result property="deptNumber" column="dept_number"/></resultMap><!-- 添加上传信息 --><insert id="insertFiles">insert into jx_attachment (file_id, file_name, file_size, uploading_staff, upload_time, file_new_name,file_address, dept_number)values (#{fileId}, #{fileName}, #{fileSize}, #{uploadingStaff}, #{uploadTime}, #{fileNewName}, #{fileAddress},#{deptNumber})</insert>
<!-- 修改   --><update id="updateFile">update jx_attachmentset file_name = #{fileName}where file_id = #{fileId} and dept_number = #{deptNumber};</update><!-- 部门编号 查询文件信息 --><select id="previewFileByDeptNum" resultType="com.ruoyi.xinzhi.dto.JxAttachmentPreviewDTO">select file_id         as fileId,file_name       as fileName,file_size       as fileSize,uploading_staff as uploadingStaff,file_address    as fileAddress,upload_time     as uploadTime,file_new_name   as fileNewNamefrom jx_attachmentwhere dept_number = #{deptNumber};</select><!-- 文件删除 --><delete id="deleteFile">delete from jx_attachment where dept_number = #{deptNumber} and file_new_name = #{fileName};</delete></mapper>

 表

CREATE TABLE `jx_attachment` (`file_id` int NOT NULL AUTO_INCREMENT COMMENT '文件ID',`file_name` varchar(255) NOT NULL COMMENT '文件名称',`file_size` varchar(50) DEFAULT NULL COMMENT '文件大小',`uploading_staff` varchar(100) DEFAULT NULL COMMENT '上传人员',`upload_time` datetime DEFAULT NULL COMMENT '上传时间',`file_new_name` varchar(255) DEFAULT NULL COMMENT '文件新名词',`file_address` varchar(255) DEFAULT NULL COMMENT '文件地址',`dept_number` varchar(50) DEFAULT NULL COMMENT '部门编号',PRIMARY KEY (`file_id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='文件表';
CREATE TABLE `JxAttachmentPreview` (`file_id` int NOT NULL AUTO_INCREMENT COMMENT '文件ID',`file_name` varchar(255) NOT NULL COMMENT '文件名称',`file_size` varchar(50) DEFAULT NULL COMMENT '文件大小',`uploading_staff` varchar(100) DEFAULT NULL COMMENT '上传人员',`file_address` varchar(255) DEFAULT NULL COMMENT '文件地址',`file_new_name` varchar(255) DEFAULT NULL COMMENT '文件新名称',`upload_time` datetime DEFAULT NULL COMMENT '上传时间',PRIMARY KEY (`file_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='JxAttachmentPreview 表，用于存储文件的相关信息';

这篇关于Minio实现文件上传、下载、预览、删除 修改的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1106805。

相关文章

idea中创建新类时自动添加注释的实现

idea中创建新类时自动添加注释的实现

《idea中创建新类时自动添加注释的实现》在每次使用idea创建一个新类时,过了一段时间发现看不懂这个类是用来干嘛的,为了解决这个问题,我们可以设置在创建一个新类时自动添加注释,帮助我们理解这个类的用... 目录前言：详细操作：步骤一：点击上方的 文件（File），点击&nbmyHIgsp;设置（Setti
阅读更多...
SpringBoot实现MD5加盐算法的示例代码

SpringBoot实现MD5加盐算法的示例代码

《SpringBoot实现MD5加盐算法的示例代码》加盐算法是一种用于增强密码安全性的技术,本文主要介绍了SpringBoot实现MD5加盐算法的示例代码,文中通过示例代码介绍的非常详细,对大家的学习... 目录一、什么是加盐算法二、如何实现加盐算法2.1 加盐算法代码实现2.2 注册页面中进行密码加盐2.
阅读更多...
MySQL大表数据的分区与分库分表的实现

MySQL大表数据的分区与分库分表的实现

《MySQL大表数据的分区与分库分表的实现》数据库的分区和分库分表是两种常用的技术方案,本文主要介绍了MySQL大表数据的分区与分库分表的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有... 目录1. mysql大表数据的分区1.1 什么是分区？1.2 分区的类型1.3 分区的优点1.4 分
阅读更多...
一文详解如何从零构建Spring Boot Starter并实现整合

一文详解如何从零构建Spring Boot Starter并实现整合

《一文详解如何从零构建SpringBootStarter并实现整合》SpringBoot是一个开源的Java基础框架,用于创建独立、生产级的基于Spring框架的应用程序,：本文主要介绍如何从... 目录一、Spring Boot Starter的核心价值二、Starter项目创建全流程2.1 项目初始化（
阅读更多...
Mysql删除几亿条数据表中的部分数据的方法实现

Mysql删除几亿条数据表中的部分数据的方法实现

《Mysql删除几亿条数据表中的部分数据的方法实现》在MySQL中删除一个大表中的数据时,需要特别注意操作的性能和对系统的影响,本文主要介绍了Mysql删除几亿条数据表中的部分数据的方法实现,具有一定... 目录1、需求2、方案1. 使用 DELETE 语句分批删除2. 使用 INPLACE ALTER T
阅读更多...
MySQL INSERT语句实现当记录不存在时插入的几种方法

MySQL INSERT语句实现当记录不存在时插入的几种方法

《MySQLINSERT语句实现当记录不存在时插入的几种方法》MySQL的INSERT语句是用于向数据库表中插入新记录的关键命令,下面：本文主要介绍MySQLINSERT语句实现当记录不存在时... 目录使用 INSERT IGNORE使用 ON DUPLICATE KEY UPDATE使用 REPLACE
阅读更多...
mysql数据库重置表主键id的实现

mysql数据库重置表主键id的实现

《mysql数据库重置表主键id的实现》在我们的开发过程中,难免在做测试的时候会生成一些杂乱无章的SQL主键数据,本文主要介绍了mysql数据库重置表主键id的实现,具有一定的参考价值,感兴趣的可以了... 目录关键语法演示案例在我们的开发过程中，难免在做测试的时候会生成一些杂乱无章的SQL主键数据，当我们
阅读更多...
SpringBoot配置Ollama实现本地部署DeepSeek

SpringBoot配置Ollama实现本地部署DeepSeek

《SpringBoot配置Ollama实现本地部署DeepSeek》本文主要介绍了在本地环境中使用Ollama配置DeepSeek模型,并在IntelliJIDEA中创建一个Sprin... 目录前言详细步骤一、本地配置DeepSeek二、SpringBoot项目调用本地DeepSeek前言随着人工智能技
阅读更多...
使用Java实现通用树形结构构建工具类

使用Java实现通用树形结构构建工具类

《使用Java实现通用树形结构构建工具类》这篇文章主要为大家详细介绍了如何使用Java实现通用树形结构构建工具类,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录完整代码一、设计思想与核心功能二、核心实现原理1. 数据结构准备阶段2. 循环依赖检测算法3. 树形结构构建4. 搜索子
阅读更多...
MySQL多列IN查询的实现

MySQL多列IN查询的实现

《MySQL多列IN查询的实现》多列IN查询是一种强大的筛选工具,它允许通过多字段组合快速过滤数据,本文主要介绍了MySQL多列IN查询的实现,具有一定的参考价值,感兴趣的可以了解一下... 目录一、基础语法：多列 IN 的两种写法1. 直接值列表2. 子查询二、对比传统 OR 的写法三、性能分析与优化1.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2