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。

相关文章

hdu1043（八数码问题，广搜 + hash（实现状态压缩） ）

hdu1043（八数码问题，广搜 + hash（实现状态压缩） ）

利用康拓展开将一个排列映射成一个自然数，然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu
阅读更多...
电脑桌面文件删除了怎么找回来？别急，快速恢复攻略在此

电脑桌面文件删除了怎么找回来？别急，快速恢复攻略在此

在日常使用电脑的过程中，我们经常会遇到这样的情况：一不小心，桌面上的某个重要文件被删除了。这时，大多数人可能会感到惊慌失措，不知所措。 其实，不必过于担心，因为有很多方法可以帮助我们找回被删除的桌面文件。下面，就让我们一起来了解一下这些恢复桌面文件的方法吧。 一、使用撤销操作 如果我们刚刚删除了桌面上的文件，并且还没有进行其他操作，那么可以尝试使用撤销操作来恢复文件。在键盘上同时按下“C
阅读更多...
【C++】_list常用方法解析及模拟实现

【C++】_list常用方法解析及模拟实现

相信自己的力量，只要对自己始终保持信心，尽自己最大努力去完成任何事，就算事情最终结果是失败了，努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一：什么是list？ •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二：list常用接口 •🌰1.默认成员函数 🔥构造函数（⭐） 🔥析构函数 •🌰2.list对象
阅读更多...
【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯，先赞后看哦~🎈🎈 🏆 作者简介：景天科技苑 🏆《头衔》：大厂架构师，华为云开发者社区专家博主，阿里云开发者社区专家博主，CSDN全栈领域优质创作者，掘金优秀博主，51CTO博客专家等。 🏆《博客》：Python全栈，前后端开发，小程序开发，人工智能，js逆向，App逆向，网络系统安全，数据分析，Django，fastapi
阅读更多...
常用的jdk下载地址

常用的jdk下载地址

jdk下载地址 安装方式可以看之前的博客： mac安装jdk oracle 版本：https://www.oracle.com/java/technologies/downloads/ Eclipse Temurin版本：https://adoptium.net/zh-CN/temurin/releases/ 阿里版本： github：https://github.com/
阅读更多...
让树莓派智能语音助手实现定时提醒功能

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现，因为rasa本身是带有remindschedule模块的。不过经过一番折腾后，忽然发现，chatbot上实现的定时，语音助手不一定会有响应。因为，我目前语音助手的代码设置了长时间无应答会结束对话，这样一来，chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢？ 我最后选择的方法是用threading.Time
阅读更多...
Android实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸： 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  （注意不能是bmp格式） 替换默认锁屏壁纸： 将图片资源放入vendo
阅读更多...
C#实战|大乐透选号器[6]：实现实时显示已选择的红蓝球数量

C#实战|大乐透选号器[6]：实现实时显示已选择的红蓝球数量

哈喽，你好啊，我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记，这是第6篇； 接下来实现实时显示当前选中红球数量，蓝球数量； 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时，在对应的位置显示实时已选择的红球、蓝球的数量； 02 标签名称 分别设置Label标签名称为：lblRedCount、lblBlueCount
阅读更多...
Kubernetes PodSecurityPolicy：PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy：PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy：PSP能实现的5种主要安全策略 1. 特权模式限制2. 宿主机资源隔离3. 用户和组管理4. 权限提升控制5. SELinux配置 💖The Begin💖点点关注，收藏不迷路💖 Kubernetes的PodSecurityPolicy（PSP）是一个关键的安全特性，它在Pod创建之前实施安全策略，确保P
阅读更多...
工厂ERP管理系统实现源码（JAVA）

工厂ERP管理系统实现源码（JAVA）

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本，并实时掌握各环节的运营状况。 在采购管理方面，系统能够处理采购订单、供应商管理和采购入库等流程，确保采购过程的透明和高效。仓库管理方面，实现库存的精准管理，包括入库、出库、盘点等操作，确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2