Java实现minio

配置Dapplication.yml

minio:access-key: minioadminsecret-key: minioadminbucket-name: file #指定桶名称endpoint: http://localhost:9000

实现代码minioContriller.java

package com.setsail.setsailcusserver.controller;import com.alibaba.fastjson.JSONObject;
import com.setsail.setsailcusserver.service.UserRegisService;
import com.setsail.setsailcusserver.uatils.MinioUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;/*** @Description:* @Title: UserRegisController* @Author hello* @Date: 2023/4/10 9:49* @Version 1.0*/
@Slf4j
@RestController
@RequestMapping("/minio")
public class minioController {@Resourceprivate MinioUtils minioUtils;@Value("${minio.bucket-name}")private String bucketName;/*** 上传* @param file* @throws Exception*/@GetMapping("uploadFile")public void uploadFile(@RequestParam(name = "file", required = false) MultipartFile file, HttpServletRequest request) throws Exception{// 桶名称String bucketNameParam = request.getParameter("bucketName");// 如果没有传同名称默认系统配置桶if (StringUtils.isBlank(bucketNameParam)){bucketNameParam=bucketName;}else {if (!minioUtils.createIsBucket(bucketNameParam)){return;}}JSONObject jsonObject = minioUtils.uploadFile(file, bucketNameParam);}/*** 桶是否存在* @param* @throws Exception*/@GetMapping("createIsBucket")public void createIsBucket(@RequestParam String bucketName) throws Exception{System.out.println(minioUtils.createIsBucket(bucketName));}/*** 删除* @param fileName* @throws Exception*/@GetMapping("deleteObject")public void deleteObject(@RequestParam String  fileName,@RequestParam String  bucketNameParam) throws Exception{// 桶不存在if (!minioUtils.createIsBucket(bucketNameParam)){return;}minioUtils.deleteObject(fileName,bucketNameParam);}/*** 下载*  reakFileName 需要带后缀名* @param response* @throws Exception*/@GetMapping("downLoad")public void downLoad(HttpServletRequest request, HttpServletResponse response) throws Exception{String bucketNameParam = request.getParameter("bucketName");if (!minioUtils.createIsBucket(bucketNameParam)){return;}String fileName = request.getParameter("fileName");minioUtils.downLoad(fileName,fileName,response,request);}/*** 下载图片*  reakFileName 需要带后缀名* @param response* @throws Exception*/@GetMapping("downloadImg")public void downloadImg( HttpServletResponse response,HttpServletRequest request) throws Exception{String bucketNameParam = request.getParameter("bucketName");String fileName = request.getParameter("fileName");if (StringUtils.isBlank(bucketNameParam)){bucketNameParam=bucketName;}else{if (!minioUtils.createIsBucket(bucketNameParam)){return;}}minioUtils.downloadImg(fileName,fileName,response,bucketNameParam);}/***查看图片* @param response* @throws Exception*/@GetMapping("getImage")public void getImage( HttpServletResponse response,HttpServletRequest request) throws Exception{String bucketNameParam = request.getParameter("bucketName");if (!minioUtils.createIsBucket(bucketNameParam)){return;}String fileName = request.getParameter("fileName");// 检查该桶下是否存在该图片boolean objectExist = minioUtils.isObjectExist(bucketNameParam, fileName);if (!objectExist){return;}minioUtils.getImage(fileName,response,request);}/*** 获取权限策略* @param* @throws Exception*/@GetMapping("getStrategy")public void getStrategy() throws Exception{minioUtils.getStrategy();}
}

MinioUtils工具类
package com.setsail.setsailcusserver.uatils;import com.alibaba.fastjson.JSONObject;
import com.alibaba.nacos.common.util.UuidUtils;
import io.minio.*;
import io.minio.errors.MinioException;
import io.minio.messages.Item;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.net.URLEncoder;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;/*** @Author smallhou* @Date 2022-08-15 14:31* @Version V1.0*/
@Slf4j
@Component
public class MinioUtils {@Autowiredprivate  MinioClient minioClient;@Value("${minio.bucket-name}")private String bucketName;/*** @Author smallhou* @Description //TODO 判断桶存在不存在，不存在创建桶* @Date 10:49 2022-08-16* @Param [bucketName]* @return void**/@SneakyThrowspublic void createBucket(String bucketName) {if (!minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) {minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());}}/*** @Description //TODO 判断桶是否存在* @Param [bucketName]* @return void**/@SneakyThrowspublic boolean createIsBucket(String bucketName) {return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());}@SneakyThrowspublic InputStream getObjectInputStream(String objectName,String bucketName){GetObjectArgs getObjectArgs = GetObjectArgs.builder().bucket(bucketName).object(objectName).build();return minioClient.getObject(getObjectArgs);}/*** 上传文件** @param file       文件* @param bucketName 存储桶* @return*/public JSONObject uploadFile(MultipartFile file, String bucketName) throws Exception {JSONObject res = new JSONObject();res.put("code", 0);// 判断上传文件是否为空if (null == file || 0 == file.getSize()) {res.put("msg", "上传文件不能为空");return res;}try {// 判断存储桶是否存在createBucket(bucketName);// 文件名String originalFilename = file.getOriginalFilename();// 新的文件名 = 存储桶名称_时间戳.后缀名String fileName = bucketName + "_" + System.currentTimeMillis() + originalFilename.substring(originalFilename.lastIndexOf("."));InputStream inputStream = file.getInputStream();PutObjectArgs putObjectArgs = PutObjectArgs.builder().bucket(bucketName).object(fileName).contentType(  file.getContentType()).stream(inputStream, inputStream.available(), -1).build();this.minioClient.putObject(putObjectArgs);// 开始上传res.put("code", 1);res.put("msg",  bucketName + "/" + fileName);res.put("bucket", bucketName);res.put("fileName", fileName);return res;}  catch (Exception e) {log.error("上传文件失败：{}", e.getMessage());}res.put("msg", "上传失败");return res;}public JSONObject uploadFile(JSONObject fileObj) throws Exception {JSONObject res = new JSONObject();res.put("code", 0);// 判断上传文件是否为空if (null == fileObj ) {res.put("msg", "上传文件不能为空");return res;}InputStream is=null;try {// 判断存储桶是否存在createBucket(bucketName);// 文件名String originalFilename = fileObj.getString("originalFilename");// 新的文件名 = 存储桶名称_时间戳.后缀名String fileName = bucketName + "_" + UuidUtils.generateUuid() + originalFilename.substring(originalFilename.lastIndexOf("."));// 开始上传 文件的绝对路径is=new FileInputStream(fileObj.getString("inputStream"));PutObjectArgs putObjectArgs = PutObjectArgs.builder().bucket(bucketName).object(fileName).contentType(fileObj.getString("contentType")).stream(is, is.available(), -1).build();this.minioClient.putObject(putObjectArgs);res.put("code", 1);res.put("msg",  bucketName + "/" + fileName);res.put("bucket", bucketName);res.put("fileName", fileName);return res;}  catch (Exception e) {e.printStackTrace();log.error("上传文件失败：{}", e.getMessage());}finally {is.close();}res.put("msg", "上传失败");return res;}public void downLoad(String fileName,String realFileName, HttpServletResponse response, HttpServletRequest request) {InputStream is=null;OutputStream os =null;String bucketNameParam = request.getParameter("bucketName");if (StringUtils.isBlank(bucketNameParam)){bucketNameParam=bucketName;}try {is=getObjectInputStream(fileName,bucketNameParam);if(is!=null){byte buf[] = new byte[1024];int length = 0;String codedfilename = "";String agent = request.getHeader("USER-AGENT");System.out.println("agent:" + agent);if ((null != agent && -1 != agent.indexOf("MSIE")) || (null != agent && -1 != agent.indexOf("Trident"))) {String name = URLEncoder.encode(realFileName, "UTF8");codedfilename = name;} else if (null != agent && -1 != agent.indexOf("Mozilla")) {codedfilename = new String(realFileName.getBytes("UTF-8"), "iso-8859-1");} else {codedfilename = new String(realFileName.getBytes("UTF-8"), "iso-8859-1");}response.reset();response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(realFileName.substring(realFileName.lastIndexOf("/") + 1), "UTF-8"));response.setContentType("application/x-msdownload");response.setCharacterEncoding("UTF-8");os = response.getOutputStream();// 输出文件while ((length = is.read(buf)) > 0) {os.write(buf, 0, length);}// 关闭输出流os.close();}else{log.error("下载失败");}}catch (Exception e){e.printStackTrace();log.error("错误："+e.getMessage());}finally {if(is!=null){try {is.close();} catch (IOException e) {e.printStackTrace();}}if(os!=null){try {os.close();} catch (IOException e) {e.printStackTrace();}}}}public void downloadImg(String fileName,String realFileName, HttpServletResponse httpResponse,String bucketNameParam) {try{//imgBucket--桶名称  filename-- 图片名称InputStream files = minioClient.getObject(bucketNameParam, fileName);InputStream ism = new BufferedInputStream(files);// 调用statObject()来判断对象是否存在。// 如果不存在, statObject()抛出异常,// 否则则代表对象存在minioClient.statObject(bucketNameParam, fileName);byte buf[] = new byte[1024];int length = 0;httpResponse.reset();//Content-disposition 是 MIME 协议的扩展，MIME 协议指示 MIME 用户代理如何显示附加的文件。// Content-disposition其实可以控制用户请求所得的内容存为一个文件的时候提供一个默认的文件名，// 文件直接在浏览器上显示或者在访问时弹出文件下载对话框。httpResponse.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(realFileName, "UTF-8"));httpResponse.setContentType("application/x-msdownload");httpResponse.setCharacterEncoding("utf-8");OutputStream osm = new BufferedOutputStream(httpResponse.getOutputStream());while ((length = ism.read(buf))>0) {osm.write(buf,0, length);}//关闭流osm.close();} catch (MinioException ex) {ex.printStackTrace();}  catch (NoSuchAlgorithmException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} catch (InvalidKeyException e) {e.printStackTrace();} catch (Exception e) {e.printStackTrace();}}/***  图片查看* @param fileName* @param response* @throws IOException*/public void getImage( String fileName, HttpServletResponse response,HttpServletRequest request) throws IOException {InputStream in = null;String bucketNameParam = request.getParameter("bucketName");if (StringUtils.isBlank(bucketNameParam)){bucketNameParam=bucketName;}try {in = minioClient.getObject(GetObjectArgs.builder().bucket(bucketNameParam).object(fileName).build());} catch (Exception e) {e.printStackTrace();}if (in == null){response.sendError(404, "未能找到图片");}//图片类型String[] fileArr = fileName.split("\\.");String contentType = "";StringBuilder originalFileName = new StringBuilder();if (fileArr.length > 1){contentType = "image/" + fileArr[fileArr.length - 1];for (int i = 0; i < fileArr.length - 1; i++) {originalFileName.append(fileArr[i]);if (i != fileArr.length - 2){originalFileName.append(".");}}}else {contentType = "application/octet-stream";originalFileName = new StringBuilder(fileName);}try {response.addHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept");response.addHeader("X-Original-File-Name", originalFileName.toString());response.setContentType(contentType);ServletOutputStream outputStream = response.getOutputStream();IOUtils.copy(in, outputStream);outputStream.flush();outputStream.close();} catch (IOException e) {e.printStackTrace();}}public void deleteObject(String fileName,String bucketNameParam) {if (StringUtils.isBlank(bucketNameParam)){bucketNameParam = bucketName;}try {RemoveObjectArgs removeObjectArgs = RemoveObjectArgs.builder().bucket(bucketNameParam).object(fileName).build();minioClient.removeObject(removeObjectArgs);}catch (Exception e){log.error("错误："+e.getMessage());}}public void getStrategy() {try {String bucketPolicy = minioClient.getBucketPolicy(GetBucketPolicyArgs.builder().bucket(bucketName).build());System.out.println(bucketPolicy);}catch (Exception e){log.error("错误："+e.getMessage());}}/*** 判断文件是否存在* @param bucketName 存储桶* @param objectName 文件名* @return*/public  Boolean isObjectExist(String bucketName, String objectName) {boolean exist = true;try {minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(objectName).build());} catch (Exception e) {exist = false;}return exist;}/*** 判断文件夹是否存在** @param bucketName 桶名称* @param folderName 文件夹名称* @return true存在, 反之*/public Boolean checkFolderIsExist(String bucketName, String folderName) {try {Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(folderName).recursive(false).build());for (Result<Item> result : results) {Item item = result.get();if (item.isDir() && folderName.equals(item.objectName())) {return true;}}} catch (Exception e) {return false;}return true;}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/213393.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

万界星空科技五金家具行业MES解决方案

万界星空科技五金家具行业MES解决方案

MES系统如何与家具企业生产相匹配&#xff1f;相较于其它大多数工业软件&#xff0c;MES系统无疑是受企业欢迎的软件之一。MES系统处于制造生产企业信息化的核心领域&#xff0c;有着承上启下的作用。那MES系统如何与家具企业生产相匹配&#xff1f; 五金家具行业的工艺特点&am…
阅读更多...
最简单的pixel刷机和安装面具、lsposed

最简单的pixel刷机和安装面具、lsposed

一 下载手机对应的系统 1&#xff0c;手机usb连接然后重启进入Fastboot模式&#xff1a;adb reboot bootloader2&#xff0c;找到你下载的系统&#xff0c;Windows 系统 直接运行 flash-all.bat上图 &#xff1a;左边就是安卓11和12的系统&#xff0c;右边是对应的手机型号 下…
阅读更多...
mysql:修改整数字段的显式长度不生效

mysql:修改整数字段的显式长度不生效

例如&#xff0c;我使用mysql 8.2.0版本&#xff0c;想修改整数字段的显式长度&#xff0c;不会生效&#xff0c;提醒整数的显示长度已经废弃&#xff0c;会在将来某个版本去掉&#xff1a; mysql官网中也有说明&#xff1a; https://dev.mysql.com/doc/refman/8.2/en/numeric…
阅读更多...
带阻滤波器：原理、应用及性能分析？|深圳比创达电子EMC

带阻滤波器：原理、应用及性能分析？|深圳比创达电子EMC

在现代电子技术和通信领域中&#xff0c;滤波器是一种常见的电路元件&#xff0c;用于处理信号&#xff0c;去除不需要的频率成分或者增强感兴趣的频率成分。本文将重点探讨带阻滤波器&#xff0c;它是一种特殊类型的滤波器&#xff0c;具有在特定频率范围内抑制信号的功能。我…
阅读更多...
SSD自己也能复制粘贴？浅谈NVMe 2.0 Copy Command命令

SSD自己也能复制粘贴？浅谈NVMe 2.0 Copy Command命令

复制粘贴&#xff08;CtrlC/V&#xff09;作为现代打工人日常办公的必备生存技能&#xff0c;想必大家都非常熟悉。但你知道吗&#xff0c;其实SSD自身也能进行这个非常实用的操作。可能有的读者要说了&#xff1a;这有什么稀奇&#xff0c;复制粘贴这么简单的功能&#xff0c;…
阅读更多...
腾讯字节常考的linux命令

腾讯字节常考的linux命令

1 ps 1.1 ps -ef 有哪些字段 ps -ef 命令在Unix/Linux系统中用于显示当前运行的进程。输出的字段通常包括&#xff1a; UID&#xff1a;启动进程的用户ID。PID&#xff1a;进程ID。PPID&#xff1a;父进程ID。C&#xff1a;CPU利用率。STIME&#xff1a;进程启动时间。TTY&a…
阅读更多...
安卓上比iOS快捷指令更强大的工具——MacroDroid

安卓上比iOS快捷指令更强大的工具——MacroDroid

使用 MacroDroid (Android) 自动化您的日常生活——一个简单的自动化应用程序&#xff0c;用于在 Android 上自动执行任务以及如何在其上自动执行任务。 iOS 和 Android 之间的区别? iOS和Android是两种不同的移动操作系统&#xff0c;iOS由苹果公司开发&#xff0c;于2007年…
阅读更多...
conda配环境问题合集

conda配环境问题合集

&#xff08;CtrlF&#xff0c;请&#xff09; 问题&#xff1a; File "F:\Anaconda3\envs\YOLOv5\lib\ssl.py", line 773, in __init__ raise ValueError("check_hostname requires server_hostname") ValueError: check_hostname requires server_h…
阅读更多...
Vue2解决pinia刷新后数据丢失的问题

Vue2解决pinia刷新后数据丢失的问题

Pinia&#xff1a;官网 Pinia 是一个 Vue.js 状态管理库&#xff0c;如果你在组件中修改了 store 中的数据并刷新了界面&#xff0c;Pinia 会将 store 中的数据重置为初始值&#xff0c;从而导致数据丢失的问题。 这里给出vue2的解决方案&#xff1a; 可以使用 Pinia 的 Per…
阅读更多...
当接口要加入新方法时，我后悔没有早点学设计模式了

当接口要加入新方法时，我后悔没有早点学设计模式了

&#x1f4e2; 声明&#xff1a; &#x1f344; 大家好&#xff0c;我是风筝 &#x1f30d; 作者主页&#xff1a;【古时的风筝CSDN主页】。 ⚠️ 本文目的为个人学习记录及知识分享。如果有什么不正确、不严谨的地方请及时指正&#xff0c;不胜感激。 直达博主&#xff1a;「…
阅读更多...
PP材料粘接ABS材料使用UV胶的好处？

PP材料粘接ABS材料使用UV胶的好处？

跟随着现阶段材料的不断发展更迭&#xff0c;PP材料应用越来越广&#xff0c;生产效率要求越来越高&#xff0c;为了加快生产&#xff0c;提高效率&#xff0c;PP材料的粘接上使用UV胶粘接PP&#xff08;聚丙烯&#xff09;和ABS&#xff08;丙烯腈-丁二烯-苯乙烯共聚物&#x…
阅读更多...
python Open3D加载obj

python Open3D加载obj

pip安装Open3D python -m pip install open3d示例代码 import numpy as np import open3d as o3dpath_obj test/assimp-5.2.5/test/models/OBJ/box.objmesh o3d.io.read_triangle_mesh(path_obj, enable_post_processingTrue)print(np.asarray(mesh.vertices))mesh.compute…
阅读更多...
Jenkins：持续集成与持续交付的自动化利器

Jenkins：持续集成与持续交付的自动化利器

随着软件开发行业的快速发展&#xff0c;持续集成&#xff08;Continuous Integration&#xff0c;简称CI&#xff09;和持续交付&#xff08;Continuous Delivery&#xff0c;简称CD&#xff09;已经成为了现代软件开发的重要理念。Jenkins作为一款开源的持续集成和持续交付工…
阅读更多...
企业可以利用SD-WAN打破网络限制，实现高效稳定的应用访问

企业可以利用SD-WAN打破网络限制，实现高效稳定的应用访问

在当今数字化时代&#xff0c;我们面临着越来越多复杂应用和各种类型的数据传输。企业需要实时访问云应用、视频会议等关键应用&#xff0c;不断增长的访问流量&#xff0c;导致应用访问速度变得越来越慢&#xff0c;给工作效率和用户体验带来了很大困扰。 SD-WAN是否能够解决这…
阅读更多...
javaSwing酒店管理

javaSwing酒店管理

一、介绍 在这篇博客中&#xff0c;我们将介绍一个基于MySQL数据库、Java编程语言和Swing图形用户界面的简单酒店管理系统。该系统包括了查询房客信息、查询房客状态、修改房客信息、添加房间信息、添加住户、退房管理、预定管理、退订管理、入账管理、出账管理、修改资料等多…
阅读更多...
0009Java程序设计-ssm微信小程序在慢性疾病管理中的应用

0009Java程序设计-ssm微信小程序在慢性疾病管理中的应用

文章目录 **摘要**目录系统实现开发环境 编程技术交流、源码分享、模板分享、网课分享 企鹅&#x1f427;裙&#xff1a;776871563 摘要 首先,论文一开始便是清楚的论述了小程序的研究内容。其次,剖析系统需求分析,弄明白“做什么”,分析包括业务分析和业务流程的分析以及用例…
阅读更多...
极坐标曲线@典型的4种曲线

极坐标曲线@典型的4种曲线

文章目录 abstract典型曲线心形线玫瑰线阿基米德螺线伯努利双扭线 abstract 除了圆和圆锥曲线外,还有许多曲线用极坐标描述会简单得多 典型曲线 分析下列曲线时,线分析是否含有三角函数(周期性) 利用描点法做出单个周期内的图形 作图:可以打开geogebra https://www.geogebr…
阅读更多...
记：vite3+vue3+axios前端项目跨域问题解决【前端和服务器nginx配置】

记：vite3+vue3+axios前端项目跨域问题解决【前端和服务器nginx配置】

前言&#xff1a;什么是跨域&#xff0c;网上一搜一大把&#xff0c;所以这里直接跳过&#xff0c;直入主题。 处理方式&#xff1a;不通过后端处理跨域&#xff0c;通过前端服务器nginx处理。 1.前端涉及处理跨域的必要配置&#xff08;开发环境、生产环境&#xff09;&…
阅读更多...
银行插件导致的Outlook客户端无法连接服务器问题

银行插件导致的Outlook客户端无法连接服务器问题

问题现象 最近遇到好些同事出现outlook客户端无法连接服务器的情况&#xff0c;具体现象就是右下角一直显示【正在尝试连接…】或者【需要密码】&#xff0c;点击【需要密码】按钮&#xff0c;输密码的弹窗是一个完全空白的页面。 此时打开word&#xff0c;右上角那里去登录o…
阅读更多...
LeetCode19. Remove Nth Node From End of List

LeetCode19. Remove Nth Node From End of List

文章目录 一、题目二、题解 一、题目 Given the head of a linked list, remove the nth node from the end of the list and return its head. Example 1: Input: head [1,2,3,4,5], n 2 Output: [1,2,3,5] Example 2: Input: head [1], n 1 Output: [] Example 3: I…
阅读更多...
最新文章

Copyright @ 2022~2023