实例详解SpringBoot+nginx实现资源上传功能

  server {   listen  9090;   server_name localhost;     location ~ .(jpg|png|jpeg|gif|bmp)$ { #可识别的文件后缀   root /usr/nginx/image/; #图片的映射路径    autoindex on; #开启自动索引   expires 1h; #过期时间   }   location ~ .(css|js)$ {    root /usr/nginx/static/;    autoindex on;    expires 1h;   }    location ~ .(AVI|mov|rmvb|rm|FLV|mp4|3GP)$ {    root /usr/nginx/video/;    autoindex on;    expires 1h;   }    

  <parent>   <groupId>org.springframework.boot</groupId>   <artifactId>spring-boot-starter-parent</artifactId>   <version>2.1.7.RELEASE</version>  </parent>  <dependencies>   <dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-web</artifactId>    <version>2.1.7.RELEASE</version>   </dependency>   <dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-test</artifactId>    <version>2.1.7.RELEASE</version>    <scope>test</scope>   </dependency>   <!-- Apache工具组件 -->   <dependency>    <groupId>org.apache.commons</groupId>    <artifactId>commons-lang3</artifactId>    <version>3.8.1</version>   </dependency>   <dependency>    <groupId>org.apache.commons</groupId>    <artifactId>commons-io</artifactId>    <version>1.3.2</version>   </dependency>   <dependency>    <groupId>commons-net</groupId>    <artifactId>commons-net</artifactId>    <version>3.6</version>   </dependency>   <!-- 文件上传组件 -->   <dependency>    <groupId>commons-fileupload</groupId>    <artifactId>commons-fileupload</artifactId>    <version>1.3.3</version>   </dependency>   <dependency>    <groupId>org.projectlombok</groupId>    <artifactId>lombok</artifactId>    <version>1.16.22</version>   </dependency>   <dependency>    <groupId>com.jcraft</groupId>    <artifactId>jsch</artifactId>    <version>0.1.54</version>   </dependency>   <dependency>    <groupId>joda-time</groupId>    <artifactId>joda-time</artifactId>    <version>2.10.3</version>   </dependency>  </dependencies>

  ftp:   host: 自己服务器ip   userName: 服务器账号   password: 服务器密码   port: 22   rootPath: /usr/nginx/image   img:   url: http://ip:9090/  # ftp.img.url 可以不添加，这里只是为了上传文件成功后返回文件路径

  import com.jcraft.jsch.*;  import org.slf4j.Logger;  import org.slf4j.LoggerFactory;  import org.springframework.beans.factory.annotation.Value;  import org.springframework.stereotype.Component;  import java.io.InputStream;  import java.util.Properties;  @Component  public class FtpUtil {   private static Logger logger = LoggerFactory.getLogger(FtpUtil.class);   /**    * ftp服务器ip地址    */   private static String host;   @Value("${ftp.host}")   public void setHost(String val){    FtpUtil.host = val;   }   /**    * 端口    */   private static int port;   @Value("${ftp.port}")   public void setPort(int val){    FtpUtil.port = val;   }   /**    * 用户名    */   private static String userName;   @Value("${ftp.userName}")   public void setUserName(String val){    FtpUtil.userName = val;   }   /**    * 密码    */   private static String password;   @Value("${ftp.password}")   public void setPassword(String val){    FtpUtil.password = val;   }   /**    * 存放图片的根目录    */   private static String rootPath;   @Value("${ftp.rootPath}")   public void setRootPath(String val){    FtpUtil.rootPath = val;   }   /**    * 存放图片的路径    */   private static String imgUrl;   @Value("${ftp.img.url}")   public void setImgUrl(String val){    FtpUtil.imgUrl = val;   }   /**    * 获取连接    */   private static ChannelSftp getChannel() throws Exception{    JSch jsch = new JSch();    //->ssh root@host:port    Session sshSession = jsch.getSession(userName,host,port);    //密码    sshSession.setPassword(password);    Properties sshConfig = new Properties();    sshConfig.put("StrictHostKeyChecking", "no");    sshSession.setConfig(sshConfig);    sshSession.connect();    Channel channel = sshSession.openChannel("sftp");    channel.connect();    return (ChannelSftp) channel;   }   /**    * ftp上传图片    * @param inputStream 图片io流    * @param imagePath 路径，不存在就创建目录    * @param imagesName 图片名称    * @return urlStr 图片的存放路径    */   public static String putImages(InputStream inputStream, String imagePath, String imagesName){    try {     ChannelSftp sftp = getChannel();     String path = rootPath + imagePath + "/";     createDir(path,sftp);     //上传文件     sftp.put(inputStream, path + imagesName);     logger.info("上传成功！");     sftp.quit();     sftp.exit();     //处理返回的路径     String resultFile;     resultFile = imgUrl + imagePath + imagesName;     return resultFile;    } catch (Exception e) {     logger.error("上传失败：" + e.getMessage());    }    return "";   }   /**    * 创建目录    */   private static void createDir(String path,ChannelSftp sftp) throws SftpException {    String[] folders = path.split("/");    sftp.cd("/");    for ( String folder : folders ) {     if ( folder.length() > 0 ) {      try {       sftp.cd( folder );      }catch ( SftpException e ) {       sftp.mkdir( folder );       sftp.cd( folder );      }     }    }   }   /**    * 删除图片    */   public static void delImages(String imagesName){    try {     ChannelSftp sftp = getChannel();     String path = rootPath + imagesName;     sftp.rm(path);     sftp.quit();     sftp.exit();    } catch (Exception e) {     e.printStackTrace();    }   }  }

  import java.util.Random;  public class IDUtils {   /**    * 生成随机图片名    */   public static String genImageName() {    //取当前时间的长整形值包含毫秒    long millis = System.currentTimeMillis();    //加上三位随机数    Random random = new Random();    int end3 = random.nextInt(999);    //如果不足三位前面补0    String str = millis + String.format("%03d", end3);    return str;   }  }    

  import com.wzy.util.FtpUtil;  import com.wzy.util.IDUtils;  import lombok.extern.slf4j.Slf4j;  import org.joda.time.DateTime;  import org.springframework.stereotype.Service;  import org.springframework.web.multipart.MultipartFile;  import java.io.IOException;  import java.io.InputStream;  /**   * @Package: com.wzy.service   * @Author: Clarence1   * @Date: 2019/10/4 21:34   */  @Service  @Slf4j  public class NginxService {   public Object uploadPicture(MultipartFile uploadFile) {    //1、给上传的图片生成新的文件名    //1.1获取原始文件名    String oldName = uploadFile.getOriginalFilename();    //1.2使用IDUtils工具类生成新的文件名，新文件名 = newName + 文件后缀    String newName = IDUtils.genImageName();    assert oldName != null;    newName = newName + oldName.substring(oldName.lastIndexOf("."));    //1.3生成文件在服务器端存储的子目录    String filePath = new DateTime().toString("/yyyyMMdd/");    //2、把图片上传到图片服务器    //2.1获取上传的io流    InputStream input = null;    try {     input = uploadFile.getInputStream();    } catch (IOException e) {     e.printStackTrace();    }    //2.2调用FtpUtil工具类进行上传    return FtpUtil.putImages(input, filePath, newName);   }  }    

  import com.fasterxml.jackson.core.JsonProcessingException;  import com.fasterxml.jackson.databind.ObjectMapper;  import com.wzy.service.NginxService;  import lombok.extern.slf4j.Slf4j;  import org.springframework.beans.factory.annotation.Autowired;  import org.springframework.web.bind.annotation.PostMapping;  import org.springframework.web.bind.annotation.RequestParam;  import org.springframework.web.bind.annotation.RestController;  import org.springframework.web.multipart.MultipartFile;  import java.util.HashMap;  import java.util.Map;  @RestController  @Slf4j  public class NginxController {   @Autowired   private NginxService nginxService;   /**    * 可上传图片、视频，只需在nginx配置中配置可识别的后缀    */   @PostMapping("/upload")   public String pictureUpload(@RequestParam(value = "file") MultipartFile uploadFile) {    long begin = System.currentTimeMillis();    String json = "";    try {     Object result = nginxService.uploadPicture(uploadFile);     json = new ObjectMapper().writeValueAsString(result);    } catch (JsonProcessingException e) {     e.printStackTrace();    }    long end = System.currentTimeMillis();    log.info("任务结束，共耗时：[" + (end-begin) + "]毫秒");    return json;   }   @PostMapping("/uploads")   public Object picturesUpload(@RequestParam(value = "file") MultipartFile[] uploadFile) {    long begin = System.currentTimeMillis();    Map<Object, Object> map = new HashMap<>(10);    int count = 0;    for (MultipartFile file : uploadFile) {     Object result = nginxService.uploadPicture(file);     map.put(count, result);     count++;    }    long end = System.currentTimeMillis();    log.info("任务结束，共耗时：[" + (end-begin) + "]毫秒");    return map;   }  }