java实现图片直接上传到ftp服务器

工作半年了，之前总是喜欢把总结和学习到的新东西放到自己OneNote上保存，方便自己回顾。但最近翻翻boss直聘上的要求，貌似写技术博客是个加分项哎，思来想去，决定以后但文档都在简上写好了，因为平时查问题的时候发现还是简书的排版最好，废话不说了开始吧！

• pom.xml依赖引入

  <!-- ftp客户端 -->
    <dependency>
      <groupId>commons-net</groupId>
      <artifactId>commons-net</artifactId>
      <version>3.1</version>
    </dependency>

• FtpUtil工具类,主要是封装了利用commons.net包下的FTPClient连接、登陆ftp服务器，并切换到ftp服务器下指定文件夹，设置上传到一些属性最后完成上传。其中的ftpIP，ftpUser, ftpPass, ftpPort都是从配置文件properties中读取的。

public class FtpUtil {

    private static Logger logger = LoggerFactory.getLogger(FtpUtil.class);
    //从properties文件读取相应的配置
    private static String ftpIP = PropertiesUtil.getProperty("ftp.server.ip");
    private static String ftpUser = PropertiesUtil.getProperty("ftp.user");
    private static String ftpPass = PropertiesUtil.getProperty("ftp.pass");
    private static String ftpPort = PropertiesUtil.getProperty("ftp.port");

/**
     * 将文件直接上传到ftp服务器到方法，不会经过tomcat本地缓冲
     *
     * @param remotePath  ftp服务器中的文件夹
     * @param fileName    文件的新名称
     * @param inputStream
     * @return
     */
    public static boolean uploadFile(String remotePath, String fileName, InputStream inputStream) {
        boolean isSeccess = false;
        boolean result = false;
        FTPClient ftpClient = new FTPClient();
        try {
            //连接登陆
            ftpClient.connect(ftpIP);
            isSeccess = ftpClient.login(ftpUser, ftpPass);
            logger.info("ftp服务器:{},登陆--{}", ftpIP, isSeccess);
            //如果登陆成功...
            if (isSeccess) {
                //切换到指定的ftp服务器文件夹目录
                boolean isChangeSuccess = ftpClient.changeWorkingDirectory(remotePath);
                //如果切换失败则创建改目录再切换
                if (!isChangeSuccess) {
                    ftpClient.makeDirectory(PropertiesUtil.getProperty("ftp.dir"));
                    ftpClient.changeWorkingDirectory(remotePath);
                }
                //设置缓冲大小，编码格式，文件类型
                ftpClient.setBufferSize(1024);
                ftpClient.setControlEncoding("UTF-8");
                ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
                //开始上传
                logger.info("开始上传文件：{}", fileName);
                result = ftpClient.storeFile(fileName, inputStream);
                logger.info("文件：{},上传:{}", fileName, result);
                return result;
            }
        } catch (IOException e) {
            logger.error("文件上传失败", e);
        } finally {
            try {
                //关闭流
                inputStream.close();
                ftpClient.logout();
            } catch (IOException e) {
                logger.error("输入流关闭失败", e);
            }
        }
        return result;
    }
}

• Service层主要是对上传对文件进行重命名，并封装好返回给前端的结果样式,其中ServerResponse对象是前端要求的高可用响应对象，附在最后

@Service("iFileService")
public class FileServiceImpl implements IFileService {

    //让控制台输出此文件记录内容
    private Logger logger = LoggerFactory.getLogger(FileServiceImpl.class);

    /**
     * 将文件直接上传至ftp服务器
     *
     * @param file
     * @return
     */
    @Override
    public ServerResponse upload(MultipartFile file) {
        Map<String, String> resultMap = new HashMap();
        String oldName = file.getOriginalFilename();
        String newName = UUID.randomUUID().toString();
        //给文件重命名
        newName = newName + oldName.substring(oldName.lastIndexOf("."));
        try {
            //利用FtpUtil中到方法进行上传文件
            boolean result = FtpUtil.uploadFile(PropertiesUtil.getProperty("ftp.dir"), newName, file.getInputStream());
            if (result) {
                //如果上传成功，则返回前端新的文件名和路径
                resultMap.put("uri", newName);
                //根据nginx配置的ftp文件夹和域名的对应关系组装文件在ftp服务器中的位置
                resultMap.put("url", PropertiesUtil.getProperty("ftp.server.http.prefix") + PropertiesUtil.getProperty("ftp.dir") + newName);
                return ServerResponse.createBySucess(resultMap);
            } else {
                return ServerResponse.createByErrorMessage("上传失败");
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return ServerResponse.createByErrorMessage("上传失败");
    }
}

• Controller层逻辑,主要是对用户权限对校验以及文件上传

@RequestMapping(value = "upload", method = {RequestMethod.POST})
    @ResponseBody
    public ServerResponse upload(@RequestParam(value = "file", required = true) MultipartFile file, HttpSession session) {
        User user = (User) session.getAttribute(Const.CURRENT_USER);
        if (user == null) {
            return ServerResponse.createByErrorCodeMessage(ResponseCode.NEED_LOGIN.getCode(), "用户未登陆");
        }
        if (user.getRole() != Const.ADMIN) {
            return ServerResponse.createByErrorMessage("用户无此权限");
        }
        //业务逻辑
        return iFileService.upload(file);
    }

---

• 附：高可用响应类

public class ServerResponse<T> implements Serializable {
    private int status;
    private String msg;
    private T data;

    private ServerResponse(int status) {
        this.status = status;
    }

    private ServerResponse(int status, T data) {
        this(status, data, null);
    }

    private ServerResponse(int status, T data, String msg) {
        this.status = status;
        this.data = data;
        this.msg = msg;
    }

    private ServerResponse(int status, String msg) {
        this(status);
        this.msg = msg;
    }
    @JsonIgnore     //json序列化到时候就不会显示这个public方法在json里面
    public boolean isSuccess() {
        return this.status == ResponseCode.SUCCESS.getCode();
    }

    public int getStatus() {
        return status;
    }

    public T getData() {
        return data;
    }

    public String getMsg() {
        return msg;
    }

    //成功时返回到数据封装ServerResponse对象
    public static <T> ServerResponse<T> createBySucess(){
        return new ServerResponse<T>(ResponseCode.SUCCESS.getCode());
    }
    public static <T> ServerResponse<T> createBySucessMsg(String msg){
        return new ServerResponse<T>(ResponseCode.SUCCESS.getCode(),msg);
    }
    public static <T> ServerResponse<T> createBySucess(T data){
        return new ServerResponse<T>(ResponseCode.SUCCESS.getCode(),data);
    }
    public static <T> ServerResponse<T> createBySucess(String msg,T data){
        return new ServerResponse<T>(ResponseCode.SUCCESS.getCode(),data,msg);
    }

    public static <T> ServerResponse<T> createByError(){
        return new ServerResponse<T>(ResponseCode.ERROR.getCode(),ResponseCode.ERROR.getDesc());
    }
    public static <T> ServerResponse<T> createByErrorMessage(String msg){
        return new ServerResponse<T>(ResponseCode.ERROR.getCode(),msg);
    }
    public static <T> ServerResponse<T> createByErrorCodeMessage(Integer code,String msg){
        return new ServerResponse<T>(code,msg);
    }
}

• 附：properties配置文件，其中ftp.server.http.prefix是nginx配置文件中对应ftp文件夹的那个servername

ftp.server.ip=192.168.1.1
ftp.user=ftpuser
ftp.pass=123456
ftp.server.http.prefix=http://image.test.com/
ftp.port=21

#ftp.dir=img/
ftp.dir=video/

• 这个是conf.d文件夹下自己添加的conf文件，其中的image.test.com对应的是服务器根目录下的ftpfile文件，如果只是测试，在本机hosts文件中也要配置域名和ip的对应关系。否则从返回的结果中也是无法访问的

当在浏览器中输入image.test.com域名时，首先会从本机hosts文件查看是否有对应的ip，如果有则去访问对应的ip资源，然后会被nginx截获，并与nginx配置的域名ip对应关系对比，如果一致则可以访问资源。

server {
    listen 80;
    autoindex on;
    server_name image.test.com;
    access_log /etc/nginx/logs/access.log combined;
    index index.html index.htm index.jsp index.php;
    #error_page 404 /404.html;
    if ( $query_string ~* ".*[\;'\<\>].*" ){
        return 404;
    }

    location ~ /(mmall_fe|mmall_admin_fe)/dist/view/* {
        deny all;
    }

    location / {
        root /ftpfile;
        add_header Access-Control-Allow-Origin *;
    }
}

• 最后的返回结果样式, 直接访问url后的结果

{
    "status": 0,
    "data": {
        "uri": "05c0a49a-a461-4ab2-b277-58a1051f828c.jpeg",
        "url": "http://image.test.com/video/05c0a49a-a461-4ab2-b277-58a1051f828c.jpeg"
    }
}

//Linux服务器中ftpfile文件夹中的video文件下的上传文件
[slf@www ftpfile]$ cd video
[slf@www video]$ ls
05c0a49a-a461-4ab2-b277-58a1051f828c.jpeg
[slf@www video]$ 

image.png