文件上传demo

拼搏现实的明天。 2022-11-15 15:45 166阅读 0赞

## service层 ##

package com.tx.menu.service;
    
    import org.springframework.web.multipart.MultipartFile;
    
    
    public interface TestService { 
    
        public String  uploadFileTest(MultipartFile zipFile);
    }

## 实现类TestServiceImp ##

package com.tx.menu.service.impl;
    
    import com.tx.menu.service.TestService;
    import org.apache.commons.io.IOUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.stereotype.Service;
    import org.springframework.web.multipart.MultipartFile;
    
    import java.io.File;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.util.UUID;
    
    /** * @author * Description: */
    @Service
    public class TestServiceImp implements TestService { 
    
        private static final Logger logger = LoggerFactory.getLogger(TestServiceImp.class);
    
        @Override
        public String uploadFileTest(MultipartFile zipFile) { 
            //文件保存路径
            String targetFilePath = "E:\\uploadFile";
            //生成随机名
            String fileName = UUID.randomUUID().toString().replace("-", "");
            //加上名字后缀
            String filrsuffix=getFileSuffix(zipFile);
            if (filrsuffix!=null){ 
                fileName+=filrsuffix;
            }
            File targetFile = new File(targetFilePath + File.separator + fileName);
    
            FileOutputStream fileOutputStream = null;
            try { 
                fileOutputStream = new FileOutputStream(targetFile);
                IOUtils.copy(zipFile.getInputStream(), fileOutputStream);
                logger.info("------>>>>>>uploaded a file successfully!<<<<<<------");
    
            } catch (IOException e) { 
                return e.getMessage();
            } finally { 
                try { 
                    fileOutputStream.close();
                } catch (IOException e) { 
                    logger.error("", e);
                }
            }
            return "/Upload/"+fileName;
        }
        //添加上名字后缀
        private String getFileSuffix(MultipartFile file) { 
            if (file == null) { 
                return null;
            }
            String fileName = file.getOriginalFilename();
            int suffixIndex = fileName.lastIndexOf(".");
            if (suffixIndex == -1) {     // 无后缀
                return null;
            } else {                     // 存在后缀
                return fileName.substring(suffixIndex, fileName.length());
            }
        }
    }

## controller，返回的是文件上传的地址 ##

package com.tx.menu.controller;
    
    import com.sun.org.slf4j.internal.Logger;
    import com.sun.org.slf4j.internal.LoggerFactory;
    import com.tx.common.utils.CodeMsg;
    import com.tx.common.utils.Result;
    import com.tx.menu.service.TestService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.multipart.MultipartFile;
    
    
    
    /** * 文件上传 */
    @RestController
    @RequestMapping(value = "/aop")
    public class FileController { 
    
        private static final Logger logger = LoggerFactory.getLogger(FileController.class);
    
        @Autowired
        private TestService testService;
    
        /** * 文件上传测试接口 * @return */
    
        @RequestMapping("/upload")
        public Result uploadFileTest(@RequestParam("uploadFile") MultipartFile zipFile) { 
    
            if (zipFile==null){ 
                return  Result.error(CodeMsg.EMPTY_PARAM_ERROR,"上传的文件不能为空");
            }
            String s = testService.uploadFileTest(zipFile);
            return  Result.success(s);
        }
    }

## 返回结果集：Result ##

package com.tx.common.utils;
    
    
    
    public class Result<T> { 
        private String message;
        private int retCode;
        private T data;
    
        private Result(T data) { 
            this.retCode = 200;
            this.message = "成功";
            this.data = data;
        }
    
        private Result(CodeMsg cm) { 
            if (cm == null) { 
                return;
            }
            this.retCode = cm.getRetCode();
            this.message = cm.getMessage();
        }
    
        /** * 成功时候的调用 * * @return */
        public static <T> Result<T> success(T data) { 
            return new Result<T>(data);
        }
    
        /** * 成功，不需要传入参数 * * @return */
        @SuppressWarnings("unchecked")
        public static <T> Result<T> success() { 
            return (Result<T>) success("");
        }
    
        /** * 失败时候的调用 * * @return */
        public static <T> Result<T> error(CodeMsg cm) { 
            return new Result<T>(cm);
        }
    
        /** * 失败时候的调用,扩展消息参数 * * @param cm * @param msg * @return */
        public static <T> Result<T> error(CodeMsg cm, String msg) { 
            CodeMsg newCodeMsg = null;
            try { 
                newCodeMsg = (CodeMsg) cm.clone();
            } catch (Exception e) { 
                e.printStackTrace();
            }
            newCodeMsg.setMessage(cm.getMessage() + "--" + msg);
            return new Result<T>(newCodeMsg);
        }
    
        public T getData() { 
            return data;
        }
    
        public String getMessage() { 
            return message;
        }
    
        public int getRetCode() { 
            return retCode;
        }
    
    
    }

## CodeMsg ##

package com.tx.common.utils;
    
    public class CodeMsg implements Cloneable { 
        private int retCode;
        private String message;
    
        // 通用异常
        public static CodeMsg SUCCESS = new CodeMsg(0, "success");
        public static CodeMsg EMPTY_PARAM_ERROR = new CodeMsg(400, "参数异常");
        public static CodeMsg INTER_ERROR = new CodeMsg(505, "服务端异常");
    
        private CodeMsg(int retCode, String message) { 
            this.retCode = retCode;
            this.message = message;
        }
    
        public int getRetCode() { 
            return retCode;
        }
    
        public String getMessage() { 
            return message;
        }
    
        public void setMessage(String message) { 
            this.message = message;
        }
    
        @Override
        protected Object clone() throws CloneNotSupportedException { 
            return (CodeMsg) super.clone();
        }
    }

## Postman测试： ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ2NTQ5MDg1_size_16_color_FFFFFF_t_70]

## 结果： ##

![在这里插入图片描述][20210402111336837.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzQ2NTQ5MDg1_size_16_color_FFFFFF_t_70]: /images/20221022/89bd5e80ff844e94a935e420524ef960.png
[20210402111336837.png]: /images/20221022/a2c1f899d65242f09702ecadc577ca36.png