SSM框架前后端分离,FTP上传文件

maven依赖

这里我是用的maven项目,还有就是我的文件是通过ftp上传到我的另一个服务器上的,除去最基本的依赖后,还需要三个依赖

<dependency>  
    <groupId>commons-net</groupId>  
    <artifactId>commons-net</artifactId>  
    <version>3.1</version>  
</dependency>  
<dependency>  
    <groupId>commons-fileupload</groupId>  
    <artifactId>commons-fileupload</artifactId>  
    <version>1.3.1</version>  
</dependency>  
<!-- commons-io -->  
<dependency>  
    <groupId>commons-io</groupId>  
    <artifactId>commons-io</artifactId>  
    <version>2.4</version>  
</dependency> 

spring配置

<bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
        <!-- 限制上传文件大小上限5M -->
        <property name="maxUploadSize" value="5242880" />
    </bean>

FtpUtil

import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import java.io.*;

/**
 * @Author:Gaara
 * @Description:ftp上传工具
 * @Date:Created in 2018/1/3 9:55
 * @Modified By:
 */
public class FtpUtil {
    /**
     * @param host      ftp服务器host
     * @param port      ftp服务器端口
     * @param username  ftp登录账号
     * @param password  ftp登录密码
     * @param basePath  ftp服务器基础目录
     * @param filePath  ftp服务器文件存放路径。例如分日期存放:/2015/01/01。文件的路径为basePath+filePath
     * @param filename  上传到FTP服务器上的文件名
     * @param input     输入流
     * @return
     */
    public static boolean uploadFile(String host, int port, String username, String password, String basePath,
                                     String filePath, String filename, InputStream input) {
        boolean result = false;
        FTPClient ftp = new FTPClient();
        try {
            int reply;
            ftp.connect(host, port);// 连接FTP服务器
            // 如果采用默认端口,可以使用ftp.connect(host)的方式直接连接FTP服务器
            ftp.login(username, password);// 登录
            reply = ftp.getReplyCode();
            if (!FTPReply.isPositiveCompletion(reply)) {
                ftp.disconnect();
                return result;
            }
            //切换到上传目录
            if (!ftp.changeWorkingDirectory(basePath+filePath)) {
                //如果目录不存在创建目录
                String[] dirs = filePath.split("/");
                String tempPath = basePath;
                for (String dir : dirs) {
                    if (null == dir || "".equals(dir)) continue;
                    tempPath += "/" + dir;
                    if (!ftp.changeWorkingDirectory(tempPath)) {
                        if (!ftp.makeDirectory(tempPath)) {
                            return result;
                        } else {
                            ftp.changeWorkingDirectory(tempPath);
                        }
                    }
                }
            }
            //设置上传文件的类型为二进制类型
            ftp.setFileType(FTP.BINARY_FILE_TYPE);
            //上传文件
            if (!ftp.storeFile(filename, input)) {
                return result;
            }
            input.close();
            ftp.logout();
            result = true;
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (ftp.isConnected()) {
                try {
                    ftp.disconnect();
                } catch (IOException ioe) {
                }
            }
        }
        return result;
    }
}

controller

package com.xxxx.controller;

import com.xxxx.entity.ResultEntity;
import com.xxxx.util.FtpUtil;
import com.xxxx.util.IDUtil;
import com.xxxx.util.PropertyPlaceholder;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.io.InputStream;

/**
 * @Author:Gaara
 * @Description:
 * @Date:Created in 2018/1/2 16:59
 * @Modified By:
 */
@Controller
@RequestMapping("/upload")
public class UploadController {
    @value("${ftpHost}")
    private String host; 
    @value("${ftpUser}")
    private String userName;
    @value("${ftpPwd}")
    private String userPwd;
    @value("${ftpBasePath}")
    private String basePath; 

    @ResponseBody
    @RequestMapping(value = "/uploadImg")
    public ResultEntity uploadImg(HttpServletRequest req) throws IOException {
        MultipartHttpServletRequest request = (MultipartHttpServletRequest) req;
        MultipartFile file = request.getFile("file");

        if (file != null){
            // 获取文件的后缀
            String originalName = file.getOriginalFilename();
            String suffix = originalName.substring(originalName.lastIndexOf("."));
            // 时间戳+随机数生成文件名
            String fileName = String.valueOf(System.currentTimeMillis())+(int)((Math.random()*9+1)*100000)+suffix;

            // 将文件转化为字节流
            InputStream is = file.getInputStream();
            boolean uploadRes = FtpUtil.uploadFile(host, 21, userName, userPwd, basePath, "/", fileName, is);
            if (uploadRes){
                return ResultEntity.ok(fileName);
            }
        }

        return ResultEntity.build("1000","图片上传失败");
    }
}

Html页面

<!DOCTYPE html>  
<html>  
    <head>  
        <meta charset="utf-8" />  
        <title>测试</title>  
        <script src="http://apps.bdimg.com/libs/jquery/2.1.4/jquery.min.js" type="text/javascript" charset="utf-8"></script>  
    </head>  
    <body>  
        <input type="file" id="file" onchange="ajaxFileUpload();" />  
    </body>  
    <script>  
        function ajaxFileUpload() {  
            var form = new FormData;          //创建一个FormData对象  
            form.append('file',$("#file").get(0).files[0]);
            //将文件放到FormData对象中  
            console.log(form);  
            $.ajax({  
                url : "http://127.0.0.1:8080/upload/uploadImg",//访问路径  
                contentType: false,  
                processData: false,   
                type:"post",  
                data :form,  
                dataType : "json"  
                  
            }).success(function(data,status){  
                if(status=="success"){  
                    if(data.code==200){  
                        alert("文件上传成功");  
                    }  
                    if(data.code==400){  
                        alert("文件上传失败");  
                    }  
                }                    
            }).error(function(){  
                alert("服务器未响应");  
            });  
        }            
    </script>  
</html>  

到这里前,测试上传文件已经可以实现,但是还有两个问题:

  • 文件大小超出限制时不能返回友好的json进行提示
  • 不能限制上传文件的后缀(比如只想上传图片)

文件大小超出限制时返回友好的json进行提示

  • 自定义异常处理器类
package com.xxxx.aspect;

import com.xxxx.entity.ResultEntity;
import org.springframework.web.multipart.MaxUploadSizeExceededException;
import org.springframework.web.servlet.HandlerExceptionResolver;
import org.springframework.web.servlet.ModelAndView;
import org.springframework.web.servlet.view.json.MappingJackson2JsonView;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**
 * @Author:Gaara
 * @Description: 自定义异常处理器类
 * @Date:Created in 2018/1/4 16:44
 * @Modified By:
 */
public class MaxUploadSizeExceptionHandler implements HandlerExceptionResolver{

    @Override
    public ModelAndView resolveException(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, Exception e) {
        ModelAndView mv = new ModelAndView(new MappingJackson2JsonView());
        if (e instanceof MaxUploadSizeExceededException){
            mv.addObject(ResultEntity.build("1111","图片大小不能超过5M"));
            return mv;
        }
        return null;
    }
}
  • spring配置
<bean class="com.xxxx.aspect.MaxUploadSizeExceptionHandler" />

限制上传文件的后缀

  • 自定义一个文件上传类型限制的拦截器
package com.xxxx.aspect;

import com.alibaba.fastjson.JSON;
import com.xxxx.entity.ResultEntity;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.Iterator;
import java.util.Map;

/**
 * @Author:Gaara
 * @Description:全局文件类型拦截器
 * @Date:Created in 2018/1/4 18:36
 * @Modified By:
 */
public class FileTypeInterceptor extends HandlerInterceptorAdapter{
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        Boolean flag = true;
        if (request instanceof MultipartHttpServletRequest){
            MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
            Map<String,MultipartFile> files = multipartRequest.getFileMap();
            Iterator<String> iterator = files.keySet().iterator();

            // 对多部件请求资源进行遍历
            while (iterator.hasNext()){
                String formKey = iterator.next();
                MultipartFile multipartFile = multipartRequest.getFile(formKey);
                String fileName = multipartFile.getOriginalFilename();
                // 判断是否为限制文件类型
                if (!checkFile(fileName)){
                    ServletOutputStream out = null;
                    response.setCharacterEncoding("UTF-8");
                    response.setContentType("text/json;charset=UTF-8");

                    String json = JSON.toJSONString(ResultEntity.build("1000","不支持的类型",""));
                    out = response.getOutputStream();
                    out.write(json.getBytes("UTF-8"));
                    flag = false;
                }
            }
        }
        return flag;
    }

    /**
     * 判断是否为允许的上传文件类型,true表示允许
     * @param fileName
     * @return
     */
    private Boolean checkFile(String fileName){
        String suffixList = "jpg,gif,png,ico,bmp,jpeg";
        String suffix = fileName.substring(fileName.lastIndexOf(".")+1,fileName.length());
        if (suffixList.contains(suffix.trim().toLowerCase())){
            return true;
        }
        return false;
    }
}
  • spring配置
<mvc:interceptors>
    <mvc:interceptor>
        <!--/**表示所有URL和子URL路径-->
        <mvc:mapping path="/**"/>
        <!--配置定义的文件上传类型限制拦截器-->
        <bean class="com.xyzq.aspect.FileTypeInterceptor" />
    </mvc:interceptor>
</mvc:interceptors>

最后感谢下,下面各位博主的文章还有传智的入云龙老师(看了不少老师的视频)

最最后,有个疑问filter、interceptor和aspect到底有啥区别啊?

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,802评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,109评论 2 379
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,683评论 0 335
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,458评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,452评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,505评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,901评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,550评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,763评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,556评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,629评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,330评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,898评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,897评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,140评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,807评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,339评论 2 342

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,579评论 18 139
  • Spring Boot 参考指南 介绍 转载自:https://www.gitbook.com/book/qbgb...
    毛宇鹏阅读 46,717评论 6 342
  • 要加“m”说明是MB,否则就是KB了. -Xms:初始值 -Xmx:最大值 -Xmn:最小值 java -Xms8...
    dadong0505阅读 4,802评论 0 53
  • spring官方文档:http://docs.spring.io/spring/docs/current/spri...
    牛马风情阅读 1,646评论 0 3
  • 单翅的鸟开始飞翔 它折断的翅膀 是它眼里的泪 泪是一场告别 告别是一场凌乱的雨 从九月开始 从十月结束
    薛子沐阅读 303评论 0 0