java上传图片功能实现

1 MinIO核心概念

下面介绍MinIO中的几个核心概念，这些概念在所有的对象存储服务中也都是通用的。

  • 对象（Object）

    对象是实际的数据单元，例如我们上传的一个图片。

  • 存储桶（Bucket）

    存储桶是用于组织对象的命名空间，类似于文件夹。每个存储桶可以包含多个对象。

  • 端点（Endpoint）

    端点是MinIO服务器的网络地址，用于访问存储桶和对象，例如http://192.168.10.101:9000

    注意：

    9000为MinIO的API的默认端口，前边配置的9001以为管理页面端口。

  • Access Key 和 Secret Key

    Access Key是用于标识和验证访问者身份的唯一标识符，相当于用户名。

    Secret Key是与Access Key关联的密码，用于验证访问者的身份。

2.上传图片到minio当中去

  1. 创建一个Maven项目

  2. 引入如下依赖

    <dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.5.3</version>
</dependency>

  3. 编写如下内容

    
public class App {public static void main(String[] args) throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {//1.创建 MinioClient对象MinioClient minioClient = MinioClient.builder().credentials("minioadmin", "minioadmin").endpoint("http://192.168.153.128:9000").build();//2.判断指定名称的桶是否存在boolean flag = minioClient.bucketExists(BucketExistsArgs.builder().bucket("b002").build());//3.如果不存在，则先创建桶并设置策略if (!flag) {//创建桶minioClient.makeBucket(MakeBucketArgs.builder().bucket("b002").build());//指定策略String policy = """{"Version": "2012-10-17","Statement": [{"Effect": "Allow","Principal": {"AWS": ["*"]},"Action": ["s3:GetObject"],"Resource": ["arn:aws:s3:::b002/*"]}]}""";minioClient.setBucketPolicy(SetBucketPolicyArgs.builder().bucket("b002").config(policy).build());}// 4.上传图片minioClient.uploadObject(UploadObjectArgs.builder().bucket("b002").object("公寓-健身房.jpg").filename("C:\\Users\\codercui\\Pictures\\7.images\\房间-厨房-2.jpg").build());}
}

  4. 运行测试

    运行上述代码，然后查看MinIO管理页面，观察是否上传成功。

项目当中实现真正的图片上传

1. 图片上传流程

可以看出图片上传接口接收的是图片文件，返回的Minio对象的URL。

2. 图片上传接口开发

        配置Minio Client

1.引入Minio Maven依赖

  • 在common模块的pom.xml文件增加如下内容：

    <dependency><groupId>io.minio</groupId><artifactId>minio</artifactId>
</dependency>

2.配置Minio相关参数

在application.yml中配置Minio的endpoint、accessKey、secretKey、bucketName等参数

minio:endpoint: http://<hostname>:<port>access-key: <access-key>secret-key: <secret-key>bucket-name: <bucket-name>

注意：上述<hostname>、<port>等信息需根据实际情况进行修改。

3.创建一个minio的配置类

在common模块中创建com.atguigu.lease.common.minio.MinioProperties，内容如下

package com.cuihub.lease.common.minio;import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;@ConfigurationProperties(prefix = "minio")
@Data
public class MinioProperties {private String endpoint;private String accessKey;private String secretKey;private String bucketName;
}

 @ConfigurationProperties 需要的依赖添加到pom.xml当中去

    <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-configuration-processor</artifactId><optional>true</optional></dependency>

4.创建MinioConfiguration

在common模块中创建com.atguigu.lease.common.minio.MinioConfiguration，内容如下

package com.cuihub.lease.common.minio;import io.minio.BucketExistsArgs;
import io.minio.MakeBucketArgs;
import io.minio.MinioClient;
import io.minio.SetBucketPolicyArgs;
import io.minio.errors.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.io.IOException;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;@Configuration
@EnableConfigurationProperties(MinioProperties.class)
public class MinioConfiguration {@Autowiredprivate MinioProperties minioProperties;@Beanpublic MinioClient minioClient() throws ServerException, InsufficientDataException,ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException,InvalidResponseException, XmlParserException, InternalException {MinioClient minioClient = MinioClient.builder().endpoint(minioProperties.getEndpoint()).credentials(minioProperties.getAccessKey(), minioProperties.getAccessKey()).build();boolean bucketExistsFlag = minioClient.bucketExists(BucketExistsArgs.builder().bucket(minioProperties.getBucketName()).build());if (!bucketExistsFlag){minioClient.makeBucket(MakeBucketArgs.builder().bucket(minioProperties.getBucketName()).build());String policy = """{"Statement" : [ {"Action" : "s3:GetObject","Effect" : "Allow","Principal" : "*","Resource" : "arn:aws:s3:::%s/*"} ],"Version" : "2012-10-17"}""".formatted(minioProperties.getBucketName());minioClient.setBucketPolicy(SetBucketPolicyArgs.builder().config(policy).bucket(minioProperties.getBucketName()).build());}return minioClient;}
}

5. 创建一个控制类

package com.cuihub.lease.web.admin.controller.apartment;import com.cuihub.lease.common.result.Result;
import com.cuihub.lease.web.admin.service.FileService;
import io.minio.MinioClient;
import io.minio.PutObjectArgs;
import io.minio.errors.*;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;
import java.io.StringReader;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;@Tag(name = "文件管理")
@RequestMapping("/admin/file")
@RestController
public class FileUploadController {@Autowiredprivate FileService fileService;@Operation(summary = "上传文件")@CrossOrigin@PostMapping("upload")public Result<String> upload(@RequestParam MultipartFile file) throws Exception {String url = fileService.upload(file);
//        System.out.println("url = " + url);return Result.ok(url);}}

6.创建FileService业务逻辑层

package com.cuihub.lease.web.admin.service;import org.springframework.web.multipart.MultipartFile;import java.io.IOException;public interface FileService {
String upload(MultipartFile multipartFile) throws Exception;
}

7.创建一个j接口实现类imp

package com.cuihub.lease.web.admin.service.impl;import com.cuihub.lease.common.minio.MinioProperties;
import com.cuihub.lease.web.admin.service.FileService;
import io.minio.MinioClient;
import io.minio.PutObjectArgs;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.UUID;@Service
public class FileServiceImpl implements FileService {@Autowiredprivate MinioProperties minioProperties;@Autowiredprivate MinioClient minioClient;@Overridepublic String upload(MultipartFile file) throws Exception {//获取原始文件名String originalFilename = file.getOriginalFilename();//创建新的文件名SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");originalFilename= sdf.format(new Date())+ "/" +( UUID.randomUUID().toString().replaceAll("-", ""))+"_"+originalFilename;minioClient.putObject(PutObjectArgs.builder().stream(file.getInputStream(), file.getSize(), -1).contentType(file.getContentType()).bucket(minioProperties.getBucketName()).object(originalFilename).build());System.out.println(minioProperties.getEndpoint()+minioProperties.getBucketName()+"fashedkjhgft");String url = String.format("%s/%s",minioProperties.getEndpoint(),minioProperties.getBucketName())+"/"+originalFilename;return url;}
}

 这时候你就可以给前端返回一个图片的url地址啦

注意：

        1.添加配置文件指定桶名

        2.String.format 当中的占位符是%s，这里的s是小写，如果是大写%S那么返回的地址里面的字母全是大写的了

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

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

    相关文章

    深入MapReduce——引入

    深入MapReduce——引入

    引入 前面我们已经深入了HDFS的设计与实现&#xff0c;对于分布式系统也有了不错的理解。 但HDFS仅仅解决了海量数据存储和读写的问题。要想让数据产生价值&#xff0c;一定是需要从数据中挖掘出价值才行&#xff0c;这就需要我们拥有海量数据的计算处理能力。 下面我们还是…
    阅读更多...
    Typescript泛型详解解读

    Typescript泛型详解解读

    泛型 : 在定义函数、接口、类的时候不能预先确定要使用的数据的类型,而是在使用函数、接口、类的时候才能确定数据的类型 普通方法示例&#xff1a; 需求:定义一个函数,传入两个参数,第一参数是数据,第二个参数是数量,函数的作用:根据数量产生对应个数的数据,存放在一个数组中…
    阅读更多...
    [AI翻译] 语言指南（proto 3）

    [AI翻译] 语言指南（proto 3）

    语言指南&#xff08;proto 3&#xff09; 语言指南&#xff08;proto 3&#xff09;| 协议缓冲区文档 --- Language Guide (proto 3) | Protocol Buffers Documentation 介绍如何在项目中使用 Protocol Buffers 语言的 proto3 修订版。 本指南描述了如何使用协议缓冲区语言来…
    阅读更多...
    工作流引擎camunda7和liteflow的功能异同对比，性能对比，使用场景对比

    工作流引擎camunda7和liteflow的功能异同对比，性能对比，使用场景对比

    Camunda 7 和 LiteFlow 是两个不同的工作流引擎&#xff0c;虽然它们都可以用来实现流程编排和管理&#xff0c;但它们的设计理念、功能特点和适用场景存在较大的差异。以下是对它们的功能和性能的详细对比&#xff1a; 1. 基本介绍 Camunda 7 定位&#xff1a;一款重量级的企…
    阅读更多...
    解决npm install安装出现packages are looking for funding run `npm fund` for details问题

    解决npm install安装出现packages are looking for funding run `npm fund` for details问题

    当我们运行npm install时&#xff0c;可能会收到类似以下的提示信息&#xff1a;“x packages are looking for funding.” 这并不是错误提示&#xff0c;也不会影响项目的正常运行。其实实在提醒有一些软件包正在寻求资金支持。 根据提示输入npm fund可以查看详细的信息&#…
    阅读更多...
    小米Vela操作系统开源：AIoT时代的全新引擎

    小米Vela操作系统开源：AIoT时代的全新引擎

    小米近日正式开源了其物联网嵌入式软件平台——Vela操作系统&#xff0c;并将其命名为OpenVela。这一举动在AIoT&#xff08;人工智能物联网&#xff09;领域掀起了不小的波澜&#xff0c;也为开发者们提供了一个强大的AI代码生成器和开发平台。OpenVela项目源代码已托管至GitH…
    阅读更多...
    python定时监控端口脚本

    python定时监控端口脚本

    python写了一个监控端口服务&#xff0c;自动重启的脚本 为了防止以后找不到代码&#xff0c;特别记录一下 import os import sys import threading import timeimport socket import subprocessdef check_port_and_run_script(port, script_path):# 创建一个socket对象sock …
    阅读更多...
    2025_1_22打卡

    2025_1_22打卡

    402. 移掉 K 位数字 - 力扣&#xff08;LeetCode&#xff09; 279. 完全平方数 - 力扣&#xff08;LeetCode&#xff09;
    阅读更多...
    【搞机】GMK-G3因特尔n100处理器核显直通win10虚拟机

    【搞机】GMK-G3因特尔n100处理器核显直通win10虚拟机

    环境 系统&#xff1a;Proxmox Virtual Environment 8.1.3 Linux内核&#xff1a;Linux version 6.5.13-6-pve (buildproxmox) (gcc (Debian 12.2.0-14) 12.2.0, GNU ld (GNU Binutils for Debian) 2.40) #1 SMP PREEMPT_DYNAMIC PMX 6.5.13-6 (2024-07-26T12:34Z) CPU&#x…
    阅读更多...
    MECD+: 视频推理中事件级因果图推理--VLM长视频因果推理

    MECD+: 视频推理中事件级因果图推理--VLM长视频因果推理

    论文链接&#xff1a;https://arxiv.org/pdf/2501.07227v1 1. 摘要及主要贡献点 摘要&#xff1a; 视频因果推理旨在从因果角度对视频内容进行高层次的理解。然而&#xff0c;目前的研究存在局限性&#xff0c;主要表现为以问答范式执行&#xff0c;关注包含孤立事件和基本因…
    阅读更多...
    HTML5 History API

    HTML5 History API

    在 HTML5 的 History API 中&#xff0c;pushState 和 replaceState 方法也可以接受一个 state 对象作为参数。这些方法允许你在改变浏览器路由时不重新加载页面&#xff0c;并且可以附加一些自定义数据。 state 返回在 history 栈顶的 任意 值的拷贝。 let currentState h…
    阅读更多...
    2024“博客之星”——我的博客成长与技术洞察

    2024“博客之星”——我的博客成长与技术洞察

    &#x1f31f;欢迎来到 我的博客 —— 探索技术的无限可能&#xff01; &#x1f31f;博客的简介&#xff08;文章目录&#xff09; 目录 一、引言二、个人成长与突破盘点&#xff08;一&#xff09;技能提升与知识拓展&#xff08;二&#xff09;创作风格与影响力提升&#xf…
    阅读更多...
    学生管理系统C++版（简单版）详解

    学生管理系统C++版（简单版）详解

    有错请指出 啊~&#xff0c;答应大家的来了 头文件&#xff1a; #include<iostream> #include<stdlib.h> #include<windows.h> iostream是标准头文件&#xff0c;stdlib.h也可以写成cstdlib&#xff0c;windows.h&#xff0c;用Sleep 数据定义&#xff…
    阅读更多...
    Apache Hive 聚合函数与 OVER 窗口函数：从基础到高级应用

    Apache Hive 聚合函数与 OVER 窗口函数：从基础到高级应用

    在大数据时代&#xff0c;Apache Hive 是处理和分析海量数据的强大工具。Hive 提供了丰富的聚合函数和强大的 OVER 窗口函数&#xff0c;能够帮助我们高效地进行数据分析。本文将综合介绍 Hive 的聚合函数和 OVER 窗口函数&#xff0c;结合实际使用场景和代码示例&#xff0c;帮…
    阅读更多...
    KOC营销2.0：出海品牌在2025年春节的创新故事讲述

    KOC营销2.0：出海品牌在2025年春节的创新故事讲述

    在全球化日益加深的今天&#xff0c;春节已不再是中国独有的节日符号&#xff0c;它逐渐成为了世界各地文化交融的一部分。对于出海品牌而言&#xff0c;春节不仅是连接中国消费者与海外市场的桥梁&#xff0c;更是展示品牌文化深度与创意的重要契机。KOC营销作为新时代的传播策…
    阅读更多...
    最新-CentOS 7安装1 Panel Linux 服务器运维管理面板

    最新-CentOS 7安装1 Panel Linux 服务器运维管理面板

    CentOS 7安装1 Panel Linux 服务器运维管理面板 一、前言二、环境要求三、在线安装四、离线安装1.点击下面1 Panel官网链接访问下载&#xff0c;如未登录或注册&#xff0c;请登录/注册后下载2.使用将离线安装包上传至目标终端/tem目录下3.进入到/tem目录下解压离线安装包4.执行…
    阅读更多...
    C++|开源日志库log4cpp和glog

    C++|开源日志库log4cpp和glog

    文章目录 log4cpp 和 glog对比1. **功能对比**2. **易用性和配置**3. **性能**4. **线程安全**5. **日志输出**6. **功能扩展**7. **适用场景**8. **总结** 其它开源C日志库1. **spdlog**2. **easylogging**3. **Boost.Log**4. **loguru**5. **Poco Logging**6. **Qt Logging (…
    阅读更多...
    高频次UDP 小包丢包分析

    高频次UDP 小包丢包分析

    目录 背景测试方法测试结果case1: （经过多级交换机）case2： 长时测试（经过多级交换机）case3: 长时测试（设备直联）可能原因分析解决方法背景 UDP作为面向非连接的传输协议，并不能保证可靠交付。本文编写代码测试设备之间UDP小包传输的可靠性。 测试方法 发送侧基于豆包…
    阅读更多...
    基于springboot+vue的高校社团管理系统的设计与实现

    基于springboot+vue的高校社团管理系统的设计与实现

    开发语言&#xff1a;Java框架&#xff1a;springbootJDK版本&#xff1a;JDK1.8服务器&#xff1a;tomcat7数据库&#xff1a;mysql 5.7&#xff08;一定要5.7版本&#xff09;数据库工具&#xff1a;Navicat11开发软件&#xff1a;eclipse/myeclipse/ideaMaven包&#xff1a;…
    阅读更多...
    vim在末行模式下的删除功能

    vim在末行模式下的删除功能

    删除:d :1d #删除第1行 :1,5d #删除第一行至第五行 :g/^\s*$/d #删除文件中的空白行 ——g所有 ——^表示行首 ——$表示行尾 ——\s 空白符 ——* 0至多个 示例&#xff1a;
    阅读更多...
    最新文章

    Copyright @ 2022~2023