ftp上传下载实例(部分)

package com.suning.schedule.util;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;

/**
* ftp上传、下载
*
* @author xxx
*/
public class FtpUtil
{
    /**
     * 上传文件
     *
     * @param ip ftp服务器IP
     * @param port ftp服务端口
     * @param username 用户名
     * @param password 密码
     * @param workDirectory 工作目录
     * @param filename 文件名称
     * @param inputStream 文件流
     * @return 存储结果
     */
    public static boolean uploadFile(String ip, int port, String username, String password, String workDirectory,
        String filename, FileInputStream inputStream)
    {
        boolean success = false;
        FTPClient ftp = new FTPClient();
        try
        {
            // 连接FTP服务器,如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
            ftp.connect(ip, port);
            // 登录，用户名和密码
              ftp.login(username, password);// 登录
              // ftp拒绝服务请求
            if (!FTPReply.isPositiveCompletion(ftp.getReplyCode()))
            {
                ftp.disconnect();
                return success;
            }
           // 设置文件的传出方式
             client.setFileType(FTPClient.BINARY_FILE_TYPE);
           // 设置文件的编码
             client.setControlEncoding("UTF-8");
            // 设置ftp的初始化目录
            ftp.changeWorkingDirectory(workDirectory);
            ftp.storeFile(filename, inputStream);
            ftp.logout();
            success = true;
        }
        catch (IOException e)
        {
        }
        finally
        {
            if (ftp.isConnected())
            {
                try
                {
                    ftp.disconnect();
                }
                catch (IOException ioe)
                {
                }
            }
        }
        return success;
    }

    /**
     * 下载文件
     *
     * @param ip ftp服务器IP
     * @param port ftp服务端口
     * @param username 用户名
     * @param password 密码
     * @param workDirectory 工作目录
     * @param localPath 本地路径
     * @return 下载结果
     */
    public static boolean downFile(String ip, int port, String username, String password, String workingDirectory,
        String localPath)
    {
        boolean success = false;
        FTPClient ftp = new FTPClient();
        try
        {
           // 连接FTP服务器,如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
            ftp.connect(ip, port);
           // 登录，用户名和密码
            ftp.login(username, password);// 登录
            // ftp拒绝服务请求
            if (!FTPReply.isPositiveCompletion(ftp.getReplyCode()))
            {
                ftp.disconnect();
                return success;
            }
           // 设置文件的传出方式
            client.setFileType(FTPClient.BINARY_FILE_TYPE);
          // 设置文件的编码
            client.setControlEncoding("UTF-8");
          // 设置ftp的初始化目录
          ftp.changeWorkingDirectory(workingDirectory);
            FTPFile[] fs = ftp.listFiles();
            for (FTPFile ff : fs)
            {
                if (ff.getType() == FTPFile.FILE_TYPE)
                {
                    File localFile = new File(localPath + "/" + ff.getName());
                    OutputStream is = new FileOutputStream(localFile);
                    ftp.retrieveFile(ff.getName(), is);
                    is.close();
                    // 如果下载成功了,就把下载的文件从ftp服务器中删除.
                    ftp.dele(ff.getName());
                }
            }
            ftp.logout();
            success = true;
        }
        catch (IOException e)
        {
        }
        finally
        {
            if (ftp.isConnected())
            {
                try
                {
                    ftp.disconnect();
                }
                catch (IOException ioe)
                {
                }
            }
        }
        return success;
    }

}