java实现文件上传下载至ftp服务器

以前做的一个项目，用到了文件上传下载至ftp服务器，现在对其进行一下复习，比较简单，一下就能看明白。
环境：首先，先安装ftp服务器，我是在win8本地用IIS配置的， 百度一下就可以找到安装文档。
1.在你的项目目录下建立ftp配置文件，目录如下图

01 ftpconfig.properties:

ftpIp=10.73.222.29
ftpPort=21
ftpUser=WP
ftpPwd=04143114wp
ftpRemotePath=d://share  

02 读取ftpconfig.properties中的具体内容的类：

 package com.java.core.util;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

/**
 * @author wangpei
 * @version 创建时间：2017年5月6日 下午9:42:40 读取ftp文件的配置文件
 */
public class ReadFtpProperties {
    private InputStream is;
    private Properties properties;

    public ReadFtpProperties() {
        is = this.getClass().getResourceAsStream("/ftpconfig.properties");// 将配置文件读入输入流中
        properties = new Properties();
        try {
            properties.load(is);
        } catch (IOException e) {
            System.out.println("配置文件不存在..");
            e.printStackTrace();
        } finally {

            if (null != is) {

                try {
                    is.close();
                } catch (IOException e) {
                    System.out.println("关闭流失败..");
                    e.printStackTrace();
                }
            }

        }

    }

    public String getIp() {// 获取ftp服务器的ip地址
        return properties.getProperty("ftpIp");

    }

    public String getPort() {// 获取ftp服务器的端口
        return properties.getProperty("ftpPort");

    }

    public String getUser() {// 获取ftp登录用户名
        return properties.getProperty("ftpUser");

    }

    public String getPwd() {// 获取ftp服务器的登录密码
        return properties.getProperty("ftpPwd");

    }

    public String getRemotePath() {// 获取ftp服务器的存放文件的目录
        return properties.getProperty("ftpRemotePath");

    }

}

03 文件上传下载的接口类

package com.java.web.service;

import java.io.InputStream;
import org.apache.commons.net.ftp.FTPClient;
import com.java.core.util.ReadFtpProperties;


/**
 * @author wangpei
 * @version 创建时间：2017年5月6日 下午6:39:03 
 * 文件上传下载业务逻辑接口层
 */
public interface FtpService {
    /*
     * 登录至FTP
     */
    public boolean loginFTP(FTPClient client, ReadFtpProperties rfp);

    /*
     * 退出ftp
     */
    public boolean logout(FTPClient  client);//

    /*
     * 上传文件到remotePath，其在ftp上的名字为inputStream
     */
    public boolean uploadFile(FTPClient client, String remotePath,
            String fileNewName, InputStream inputStream, ReadFtpProperties rfp);

    /*
     * 从目录remotePath，下载文件fileName
     */
    public InputStream downFileByFtp(FTPClient client, String remotePath,
            String fileName);

    /*
     * 删除ftp上的目录为pathName的文件
     */
    public boolean delFile(FTPClient client, String pathName);

}

04 文件上传下载的接口实现类

package com.java.web.service.serviceImpl;

import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.net.SocketException;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import com.java.core.util.ReadFtpProperties;
import com.java.web.service.FtpService;

/**
 * @author wangpei
 * @version 创建时间：2017年5月6日 下午10:02:28 类说明
 */
public class FtpServiceImpl implements FtpService {

    public boolean loginFTP(FTPClient client, ReadFtpProperties rfp) {
        String ftpIp = rfp.getIp();
        String ftpPort = rfp.getPort();
        String ftpUser = rfp.getUser();
        String ftpPwd = rfp.getPwd();
        // String fgtpRemotePath = rfp.getRemotePath();
        boolean b = false;

        try {
            client.connect(ftpIp, Integer.parseInt(ftpPort));
        } catch (NumberFormatException e) {
            System.out.println("无法连接到ftp");
            return false;
        } catch (SocketException e) {
            System.out.println("无法连接到ftp");
            return false;
        } catch (IOException e) {
            System.out.println("无法连接到ftp");
            return false;
        }
        client.setControlEncoding("uft-8");
        try {
            b = client.login(ftpUser, ftpPwd);
        } catch (IOException e) {
            System.out.println("登录ftp出错");
            logout(client);// 退出/断开FTP服务器链接
            return false;
        }
        return b;

    }

    public boolean logout(FTPClient client) {
        boolean b = false;

        try {
            b = client.logout();// 退出登录
            client.disconnect();// 断开连接
        } catch (IOException e) {
            return false;
        }
        return b;

    }

    public boolean uploadFile(FTPClient client, String remotePath,
            String fileNewName, InputStream inputStream, ReadFtpProperties rfp) {
        boolean b = false;
        try {
            client.setFileType(FTPClient.BINARY_FILE_TYPE);
            client.enterLocalPassiveMode();
            if (remotePath != null && !"".equals(remotePath.trim())) {
                String[] pathes = remotePath.split("/");
                for (String onepath : pathes) {
                    if (onepath == null || "".equals(onepath.trim())) {
                        continue;
                    }

                    onepath = new String(onepath.getBytes("utf-8"),
                            "iso-8859-1");
                    System.out.println("onepath=" + onepath);
                    if (!client.changeWorkingDirectory(onepath)) {
                        client.makeDirectory(onepath);// 创建FTP服务器目录
                        client.changeWorkingDirectory(onepath);// 改变FTP服务器目录
                    } else {
                        System.out.println("文件单路径");
                    }
                }
            }
            b = client.storeFile(new String(fileNewName.getBytes("utf-8"),
                    "iso-8859-1"), inputStream);
        } catch (UnsupportedEncodingException e) {
            return false;
        } catch (IOException e) {
            return false;
        }
        return b;
    }

    public InputStream downFileByFtp(FTPClient ftpClient, String remotePath,
            String fileName) {

        FTPFile[] fs;
        InputStream is = null;
        try {
            // 设置被动模式
            ftpClient.enterLocalPassiveMode();
            // 设置以二进制流的方式传输
            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
            // 设置编辑格式
            ftpClient.setControlEncoding("utf-8");

            remotePath = remotePath.substring(0,
                    remotePath.lastIndexOf(fileName));
            fs = ftpClient.listFiles(remotePath);// 递归目标目录
            for (FTPFile ff : fs) {
                if (ff.getName().equals(fileName)) {// 查找目标文件
                    is = ftpClient.retrieveFileStream(new String(
                            (remotePath + fileName).getBytes("utf-8"),
                            "iso-8859-1"));
                    break;
                }
            }

        } catch (IOException e) {

            e.printStackTrace();
        }
        return is;

    }

    public boolean delFile(FTPClient ftpClient, String pathName) {
        boolean b = false;

        try {
            b = ftpClient.deleteFile(pathName);

            return b;
        } catch (Exception e) {
            return false;
        } finally {
            logout(ftpClient);// 退出/断开FTP服务器链接
        }

    }

}

代码很好理解，看一遍应该就可以理解，在这儿就不具体分析了，主要看代码中的注释。