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

最近小编在学习使用nginx放置静态资源，例如图片、视频、css/js等，下面就来记录一下一波学习干货。

1.nginx安装及配置

小编使用的服务器是阿里云的轻量应用服务器，系统使用的是Ubuntu。注意记得开放 9090TCP端口，如果不使用 9090端口作为服务器端口也可不用。

安装

首先，获取安装包是必要的吧

小编是将安装包放在/usr/nginx 中，进入目录下然后执行tar -zxvf nginx-1.11.3.tar.gz进行解压

配置

修改 /usr/nginx/conf/nginx.conf ：

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;
 }

该修改的修改，该增加的增加，切记勿乱删

最后一步，启动nginx，执行 ./usr/nginx/sbin/nginx

到这里服务器nginx就准备可以了

你可以试下在 /usr/nginx/image 下放图片01.jpg，然后在本地 http://ip:9090/01.jpg 看看图片能否访问到

2. SpringBoot 实现资源的上传

pom.xml：

org.springframework.boot
spring-boot-starter-parent
2.1.7.RELEASE
org.springframework.boot
spring-boot-starter-web
2.1.7.RELEASE
org.springframework.boot
spring-boot-starter-test
2.1.7.RELEASE
test
org.apache.commons
commons-lang3
3.8.1
org.apache.commons
commons-io
1.3.2
commons-net
commons-net
3.6
commons-fileupload
commons-fileupload
1.3.3
org.projectlombok
lombok
1.16.22
com.jcraft
jsch
0.1.54
joda-time
joda-time
2.10.3

appilcation.yml：

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

工具类 FtpUtil.class：

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();
  }
 }
}

工具类IDUtils.class（修改上传图片名）：

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;
 }
}

NginxService.class：

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);
 }
}

NginxController.class：

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
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;
 }
}