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

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

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

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服务器链接    }  }}