SpringBoot：上传单个图片，上传图片压缩包，读取本地磁盘图片

一时失言乱红尘 2022-11-27 10:11 191阅读 0赞

**目录**

1. 上传单个图片

业务方法

工具类

返回结果

2. 上传图片压缩包并解压到指定目录，和用户信息匹配

业务方法

工具类

常量

3. 读取本地磁盘图片

方式1：配置文件

方式2：修改yaml文件

方式3：使用三方工具，如：minio

--------------------

# 1. 上传单个图片 #

## 业务方法 ##

### Controller层 ###

@PostMapping("/upload")
        public AjaxResult uploadImg(@RequestParam("file") MultipartFile multipartFile) {
            AjaxResult result = certifInfoService.uploadImg(multipartFile);
            return result;
    }

### Service层 ###

//    /**
    //     * 服务端口
    //     */
    //    @Value("${server.port}")
    //    private String serverPort;
    //
    //    /**
    //     * 在配置文件中配置的文件保存路径
    //     */
    //    @Value("${certif.img.storePath}")
    //    private String imgStorePath;
    
        public AjaxResult uploadImg(MultipartFile multipartFile) {
    
            // 1. 校验
            if (multipartFile.isEmpty() || StringUtils.isBlank(multipartFile.getOriginalFilename())) {
                return AjaxResult.error("图片或图片名缺失");
            }
            String contentType = multipartFile.getContentType();
            if (!contentType.contains("")) {
                return AjaxResult.error("图片类型缺失");
            }
    
            // 2. 保存
            String originalFilename = multipartFile.getOriginalFilename();
            log.info("【上传图片】:name:{},type:{}", originalFilename, contentType);
            //处理图片
            //获取路径
            String filePath = imgStorePath;
            log.info("【上传图片】,图片保存路径:{}", filePath);
            try {
                ImageUtil.saveImg(multipartFile, filePath, originalFilename);
            } catch (IOException e) {
                log.info("【上传图片】失败,图片保存路径={}", filePath);
                return AjaxResult.error("【上传图片】失败");
            }
    
            // 3.更新数据库（上传图片名称和证书编号一致）
            String certifNum = originalFilename.substring(0, originalFilename.lastIndexOf("."));
            CertifInfoDO certifInfoDO = new CertifInfoDO();
            certifInfoDO.setCertifNum(certifNum);
            String imageUrlPath = readUserImageUrl(originalFilename);
            certifInfoDO.setUserImageUrl(imageUrlPath);
            List<CertifInfoDO> certifInfoDOList = Arrays.asList(certifInfoDO);
            certifInfoMapper.batchInsertOrUpdateCertif(certifInfoDOList);
            return AjaxResult.success("【上传图片】成功");
        }

## 工具类 ##

import org.springframework.web.multipart.MultipartFile;
    
    import java.io.*;
    
    public class ImageUtil {
    
        /**
         * 保存文件，直接以multipartFile形式
         * @param multipartFile
         * @param path 文件保存绝对路径
         * @param fileName 文件名
         * @return 返回路径+文件名
         * @throws IOException
         */
        public static String saveImg(MultipartFile multipartFile, String path, String fileName) throws IOException {
            File file = new File(path);
            if (!file.exists()) {
                file.mkdirs();
            }
            FileInputStream fileInputStream = (FileInputStream) multipartFile.getInputStream();
            String fileFullPath = path + File.separator + fileName;
            BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(fileFullPath));
            byte[] bs = new byte[1024];
            int len;
            while ((len = fileInputStream.read(bs)) != -1) {
                bos.write(bs, 0, len);
            }
            bos.flush();
            bos.close();
            return fileFullPath;
        }
    }

## 返回结果 ##

import java.util.HashMap;
    import com.ruoyi.common.core.constant.HttpStatus;
    import com.ruoyi.common.core.utils.StringUtils;
    
    /**
     * 操作消息提醒
     * 
     * @author ruoyi
     */
    public class AjaxResult extends HashMap<String, Object>
    {
        private static final long serialVersionUID = 1L;
    
        /** 状态码 */
        public static final String CODE_TAG = "code";
    
        /** 返回内容 */
        public static final String MSG_TAG = "msg";
    
        /** 数据对象 */
        public static final String DATA_TAG = "data";
    
        /**
         * 初始化一个新创建的 AjaxResult 对象，使其表示一个空消息。
         */
        public AjaxResult()
        {
        }
    
        /**
         * 初始化一个新创建的 AjaxResult 对象
         * 
         * @param code 状态码
         * @param msg 返回内容
         */
        public AjaxResult(int code, String msg)
        {
            super.put(CODE_TAG, code);
            super.put(MSG_TAG, msg);
        }
    
        /**
         * 初始化一个新创建的 AjaxResult 对象
         * 
         * @param code 状态码
         * @param msg 返回内容
         * @param data 数据对象
         */
        public AjaxResult(int code, String msg, Object data)
        {
            super.put(CODE_TAG, code);
            super.put(MSG_TAG, msg);
            if (StringUtils.isNotNull(data))
            {
                super.put(DATA_TAG, data);
            }
        }
    
        /**
         * 返回成功消息
         * 
         * @return 成功消息
         */
        public static AjaxResult success()
        {
            return AjaxResult.success("操作成功");
        }
    
        /**
         * 返回成功数据
         * 
         * @return 成功消息
         */
        public static AjaxResult success(Object data)
        {
            return AjaxResult.success("操作成功", data);
        }
    
        /**
         * 返回成功消息
         * 
         * @param msg 返回内容
         * @return 成功消息
         */
        public static AjaxResult success(String msg)
        {
            return AjaxResult.success(msg, null);
        }
    
        /**
         * 返回成功消息
         * 
         * @param msg 返回内容
         * @param data 数据对象
         * @return 成功消息
         */
        public static AjaxResult success(String msg, Object data)
        {
            return new AjaxResult(HttpStatus.SUCCESS, msg, data);
        }
    
        /**
         * 返回错误消息
         * 
         * @return
         */
        public static AjaxResult error()
        {
            return AjaxResult.error("操作失败");
        }
    
        /**
         * 返回错误消息
         * 
         * @param msg 返回内容
         * @return 警告消息
         */
        public static AjaxResult error(String msg)
        {
            return AjaxResult.error(msg, null);
        }
    
        /**
         * 返回错误消息
         * 
         * @param msg 返回内容
         * @param data 数据对象
         * @return 警告消息
         */
        public static AjaxResult error(String msg, Object data)
        {
            return new AjaxResult(HttpStatus.ERROR, msg, data);
        }
    
        /**
         * 返回错误消息
         * 
         * @param code 状态码
         * @param msg 返回内容
         * @return 警告消息
         */
        public static AjaxResult error(int code, String msg)
        {
            return new AjaxResult(code, msg, null);
        }
    }

# 2. 上传图片压缩包并解压到指定目录，和用户信息匹配 #

## 依赖包 ##

<dependency>
    	<groupId>net.lingala.zip4j</groupId>
    	<artifactId>zip4j</artifactId>
    	<version>1.3.2</version>
    </dependency>

## 业务方法 ##

### Controller层 ###

@PostMapping("/zip")
        public AjaxResult uploadImgZip(@RequestParam("file") MultipartFile zipFile) throws IOException {
            AjaxResult result = certifInfoService.uploadImgZip(zipFile);
            return result;
            
        }

### Service层 ###

//    /**
    //     * 服务端口
    //     */
    //    @Value("${server.port}")
    //    private String serverPort;
    //
    //    /**
    //     * 在配置文件中配置的文件保存路径
    //     */
    //    @Value("${certif.img.storePath}")
    //    private String imgStorePath;
     /**
         * @Title: 批量证书图片上传
         * @MethodName: uploadImgZip
         * @param zipFile
         * @Exception
         * @Description:
         *
         * @author: 王延飞
         */
        @Override
        public AjaxResult uploadImgZip(MultipartFile zipFile) throws IOException {
    
            // 1. 参数校验
            if (Objects.isNull(zipFile)) {
                return AjaxResult.error("【批量证书图片上传】缺少zip包");
            }
            String fileContentType = zipFile.getContentType();
    
            if (!Constants.CONTENT_TYPE_ZIP.equals(fileContentType)
                    && !Constants.CONTENT_TYPE_ZIP_COMPRESSED.equals(fileContentType)
            ) {
                return AjaxResult.error("【批量证书图片上传】类型不是zip");
            }
    
            // 2. 保存
            //将压缩包保存在指定路径
            String filePath = imgStorePath + File.separator + zipFile.getName();
            //保存到服务器
            boolean saveFile = FileUtils.saveFile(zipFile, filePath);
            if (!saveFile) {
                return AjaxResult.error("【批量证书图片上传】失败");
            }
    
            // 3. 更新数据库
            InputStream in = new BufferedInputStream(new FileInputStream(filePath));
            ZipInputStream zin = new ZipInputStream(in);
            ZipEntry ze;
            ArrayList<CertifInfoDO> certifInfoDOS = new ArrayList<>();
            while ((ze = zin.getNextEntry()) != null) {
                if (ze.isDirectory()) {
                } else {
                    String originalFilename = ze.getName();
                    if (StringUtils.isBlank(originalFilename)) {
                        return AjaxResult.error("【批量证书图片上传】存在文件名缺失");
                    }
                    String certifNum = originalFilename.substring(0, originalFilename.lastIndexOf("."));
                    CertifInfoDO certifInfoDO = new CertifInfoDO();
                    certifInfoDO.setCertifNum(certifNum);
                    String imageUrlPath = readUserImageUrl(originalFilename);
                    certifInfoDO.setUserImageUrl(imageUrlPath);
                    certifInfoDOS.add(certifInfoDO);
    
                }
            }
            zin.closeEntry();
            certifInfoMapper.batchInsertOrUpdateCertif(certifInfoDOS);
    
            String destPath = imgStorePath + File.separator;
            // 4. 解压,并删除zip包
            boolean unPackZip = FileUtils.unPackZip(new File(filePath), "", destPath, true);
            if (unPackZip) {
                return AjaxResult.success("【批量证书图片上传解压】成功");
            } else {
                return AjaxResult.error("【批量证书图片上传解压】失败");
            }
    
    
        }
    
        /**
         * @Title: 图片路径
         * @MethodName: getUserImageUrl
         * @param originalFilename
         * @Return java.lang.String
         * @Exception
         * @Description:
         *
         * @author: 王延飞
         */
        private String readUserImageUrl(String originalFilename) {
            // http://localhost:8989/image/11
            StringBuilder imageUrl = new StringBuilder("http://");
            String hostAddress = null;
            try {
                hostAddress = Inet4Address.getLocalHost().getHostAddress();
            } catch (UnknownHostException e) {
                log.info("【图片路径】获取失败:{}", e);
                return null;
            }
            String imageUrlPath = imageUrl.append(hostAddress)
                    .append(":").append(serverPort)
                    .append("/image/").append(originalFilename)
                    .toString().trim();
            return imageUrlPath;
        }

## 工具类 ##

import com.ruoyi.common.core.constant.Constants;
    import net.lingala.zip4j.core.ZipFile;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.boot.system.ApplicationHome;
    import org.springframework.web.multipart.MultipartFile;
    
    import java.io.*;
    import java.util.zip.ZipEntry;
    import java.util.zip.ZipInputStream;
    
    /**
     * @Title: zip文件解压
     * @Description:
     *
     * @author: 王延飞
     * @date: 2020/8/14 0014 10:25
     * @version V1.0
     */
    public class FileUtils {
    
        protected static Logger log = LoggerFactory.getLogger(FileUtils.class);
    
        /**
         * @Title: 文件保存
         * @MethodName: saveFile
         * @param file
         * @param path
         * @Return boolean
         * @Exception
         * @Description:
         *
         * @author: 王延飞
         * @date: 2020/8/14 0014 11:04
         */
        public static boolean saveFile(MultipartFile file, String path) {
    
            File desFile = new File(path);
            if (!desFile.getParentFile().exists()) {
                desFile.mkdirs();
            }
            try {
                file.transferTo(desFile);
            } catch (IOException e) {
                log.error("【文件保存】异常，路径：{} ，异常信息：{} ", path, e);
                return false;
            }
            return true;
        }
    
        /**
         * @Title: 获取项目classpath路径
         * @MethodName: getApplicationPath
         * @param
         * @Return java.lang.String
         * @Exception
         * @Description:
         *
         * @author: 王延飞
         */
        public static String getApplicationPath() {
    
            //获取classpath
            ApplicationHome h = new ApplicationHome(CertifApplication.class);
            File jarF = h.getSource();
            return jarF.getParentFile() + File.separator;
        }
    
        /**
         * zip文件解压
         *
         * @param destPath 解压文件路径
         * @param zipFile  压缩文件
         * @param password 解压密码(如果有)
         * @param isDel 解压后删除
         */
        public static boolean unPackZip(File zipFile, String password, String destPath, boolean isDel) {
            try {
                ZipFile zip = new ZipFile(zipFile);
                /*zip4j默认用GBK编码去解压*/
                zip.setFileNameCharset(Constants.UTF8);
                log.info("【文件解压】begin unpack zip file....");
                zip.extractAll(destPath);
                // 如果解压需要密码
                if (zip.isEncrypted()) {
                    zip.setPassword(password);
                }
            } catch (Exception e) {
                log.error("【文件解压】异常，路径：{} ，异常信息：{} ", destPath, e);
                return false;
            }
    
            if (isDel) {
                zipFile.deleteOnExit();
            }
            return true;
        }
    
    
        /**
         * @Title: 读取文件内容
         * @MethodName:  readZipFile
         * @param file
         * @Return void
         * @Exception
         * @Description:
         *
         * @author: 王延飞
         * @date:  2020/8/14 0014 20:26
         */
        public static void readZipFile(String file) throws Exception {
            
            java.util.zip.ZipFile zf = new java.util.zip.ZipFile(file);
            InputStream in = new BufferedInputStream(new FileInputStream(file));
            ZipInputStream zin = new ZipInputStream(in);
            ZipEntry ze;
            while ((ze = zin.getNextEntry()) != null) {
                if (ze.isDirectory()) {
                } else {
                    System.err.println("file - " + ze.getName());
    
                }
            }
            zin.closeEntry();
        }
    }

## 常量 ##

/**
     * 通用常量信息
     * 
     */
    public class Constants
    {
        /**
         * UTF-8 字符集
         */
        public static final String UTF8 = "UTF-8";
    
        /**
         * GBK 字符集
         */
        public static final String GBK = "GBK";
    
        /**
         * http请求
         */
        public static final String HTTP = "http://";
    
        /**
         * https请求
         */
        public static final String HTTPS = "https://";
    
        /**
         * 文件类型 <application/zip>
         */
        public static final String CONTENT_TYPE_ZIP = "application/zip";
    
        /**
         * 文件类型 <application/x-zip-compressed>
         */
        public static final String CONTENT_TYPE_ZIP_COMPRESSED = "application/x-zip-compressed";
    }

# 3. 读取本地磁盘图片 #

> 按照如下方式修改后，就可以通过以下路径访问
> 
> [http://localhost:8989/image/11.png][http_localhost_8989_image_11.png]

## 方式1：配置文件 ##

package com.ruoyi.certif.config;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
    import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
    /**
     * @Title:  访问本地(磁盘)图片
     * @ClassName: com.ruoyi.certif.config.SourceConfiguration.java
     * @Description:
     *
     * @author: 王延飞
     * @date:  2020/8/14 0014 15:26
     * @version V1.0
     */
    @Configuration
    public class SourceConfiguration extends WebMvcConfigurerAdapter {
    
        /**
         * 在配置文件中配置的文件保存路径
         */
        @Value("${certif.img.storePath}")
        private String imgStorePath;
    
        @Override
        public void addResourceHandlers(ResourceHandlerRegistry registry) {
    
            //其中/cetif/photo表示访问的前缀。"file:imgStorePath"是文件真实的存储路径(如：)
            // 访问路径如下:http://localhost:8088/cetif/photo/XXX.png
            registry.addResourceHandler("/cetif/photos/**").addResourceLocations("file:"+imgStorePath);
            super.addResourceHandlers(registry);
        }
    
    }

## 方式2：修改yaml文件 ##

# Tomcat
    server:
      port: 8989
    
    # 图片存放路径
    certif:
      img:
        storePath: D:\home\fly
    
    # Spring
    spring:
      # 访问图片路径为/image/**
      mvc:
        static-path-pattern: /image/**
      # 图片本地存放路径
      resources:
        static-locations: file:${certif.img.storePath}
      application:
        # 应用名称
        name: ruoyi-certif
      profiles:
        # 环境配置
        active: dev

## 方式3：使用三方工具，如：minio ##

参考连接：[https://segmentfault.com/a/1190000012844836][https_segmentfault.com_a_1190000012844836]

[http_localhost_8989_image_11.png]: http://localhost:8989/image/11.png
[https_segmentfault.com_a_1190000012844836]: https://segmentfault.com/a/1190000012844836