实例详解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.bootspring-boot-starter-parent2.1.7.RELEASEorg.springframework.bootspring-boot-starter-web2.1.7.RELEASEorg.springframework.bootspring-boot-starter-test2.1.7.RELEASEtestorg.apache.commonscommons-lang33.8.1org.apache.commonscommons-io1.3.2commons-netcommons-net3.6commons-fileuploadcommons-fileupload1.3.3org.projectlomboklombok1.16.22com.jcraftjsch0.1.54joda-timejoda-time2.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;@Componentpublic 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@Slf4jpublic 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@Slf4jpublic 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();  Mapmap = 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; }}