一个java FTP的客户端

使用的了apache的commons-net实现批量下载,上传,删除等功能:

java 代码

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.SocketException;
import java.util.List;
import java.util.Properties;

import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPListParseEngine;

public class FtpClientHandler {

    private FTPClient f              = new FTPClient();

    private String    host           = "10.168.211.37";

    private String    username       = "test";

    private String    password       = "test";

    private String    r_workDirector = "./";

    private String    l_workDirector = "../";

    private String    config_file    = "../config/boss-config.properties";

    private String    remote_files   = "*";

    private String    local_files    = "*";

    public FtpClientHandler() throws IOException {
        super();
        init();
    }

    public void init() throws IOException {
        FileInputStream fis = new FileInputStream(config_file);
        Properties config = new Properties();
        config.load(fis);
        host = config.getProperty("Boss_FTP_Url");
        username = config.getProperty("Username");
        password = config.getProperty("Password");
        r_workDirector = config.getProperty("Remote_workdirector");
        l_workDirector = config.getProperty("Local_workdirector");

        remote_files = config.getProperty("Remote_download_files");
        local_files = config.getProperty("Local_upload_files");

    }

    private void connection() throws SocketException, IOException {
        f.connect(host);
        f.login(username,
                password);
        f.changeWorkingDirectory(r_workDirector);
    }

    private void close() throws IOException {
        if (f != null)
            f.disconnect();
    }

    public void DeleteFiles() throws IOException {
        connection();
        FTPListParseEngine engine = f.initiateListParsing(remote_files);
        FTPFile[] files = engine.getFiles();
        for (int i = 0; i < files.length; i++) {
            System.out.print(i + ">>");
            System.out.println(files[i].getRawListing());
            f.dele(files[i].getName());
        }
        close();
    }

    public void DownloadFiles() throws FileNotFoundException, IOException {
        connection();
        FTPListParseEngine engine = f.initiateListParsing(remote_files);
        FTPFile[] files = engine.getFiles();
        for (int i = 0; i < files.length; i++) {
            System.out.print(i + ">>");
            System.out.println(files[i].getRawListing());
            f.retrieveFile(files[i].getName(),
                           new FileOutputStream(new File(l_workDirector
                                   + files[i].getName())));
        }
        close();
    }

    public void StorFiles() throws FileNotFoundException, IOException {
        connection();
        File file = new File(l_workDirector);// 在此目录中找文件

        BFSFileSearch search = new BFSFileSearch();
        List fileList = search.scanFiles(file,
                                         local_files);
        for (int i = 0; i < fileList.size(); i++) {
            String fileName = (String) fileList.get(i);
            f.storeFile(fileName,
                        new FileInputStream(new File(l_workDirector + fileName)));
        }
        close();
    }
}

其中利用深度搜索机制来对*,?等通配符的支持:

java 代码

import java.io.File;
import java.util.ArrayList;
import java.util.List;
import java.util.Vector;

public class BFSFileSearch {
    /**
     * @param fileName
     *            String 需要查找的文件，可含通配符如*.java
     * @param base
     *            File String 欲查找的文件夹
     * @param ArrayList
     *            fileList 结果集
     * @param count
     *            int 控制结果数量，为0，表示返回所有的匹配的文件
     */
    public void scanFiles(File base, String fileName, List fileList, int count) {
        Queue queue = new Queue();// 实例化队列
        queue.put(base);// 入队
        while (!queue.isEmpty()) {
            File f = (File) queue.get();// 出队列
            if (f.exists() && f.isDirectory()) {
                String[] files = f.list();
                for (int i = 0; i < files.length; i++) {
                    File f2 = new File(f,
                                       files[i]);
                    if (f2.isDirectory()) {// 文件夹则进队列
                        queue.put(f2);
                    } else {// 文件则进行匹配
                        String filePath = f2.getAbsolutePath();
                        filePath = filePath.substring(filePath.lastIndexOf("/") + 1);// 提取文件名
                        if (wildcardMatch(fileName,
                                          filePath)) {// 匹配成功
                            if (count != 0 && fileList.size() >= count) {
                                return;
                            }
                            fileList.add(filePath);// 添加到结果集
                        }
                    }
                }
            }
        }
    }

    /**
     * overwrite method scanFiles
     * @param base
     * @param fileName
     * @return
     */
    public List scanFiles(File base, String fileName) {
        Queue queue = new Queue();// 实例化队列
        queue.put(base);// 入队
        List fileList = new ArrayList();
        while (!queue.isEmpty()) {
            File f = (File) queue.get();// 出队列
            if (f.exists() && f.isDirectory()) {
                String[] files = f.list();
                for (int i = 0; i < files.length; i++) {
                    File f2 = new File(f,
                                       files[i]);
                    if (f2.isDirectory()) {// 文件夹则进队列
                        queue.put(f2);
                    } else {// 文件则进行匹配
                        String filePath = f2.getAbsolutePath();
                        filePath = filePath.substring(filePath.lastIndexOf("/") + 1);// 提取文件名
                        if (wildcardMatch(fileName,
                                          filePath)) {// 匹配成功
                            fileList.add(filePath);// 添加到结果集
                        }
                    }
                }
            }
        }
        return fileList;
    }

    public boolean wildcardMatch(String pattern, String string) {
        int stringLength = string.length();
        int stringIndex = 0;
        for (int patternIndex = 0; patternIndex < pattern.length(); ++patternIndex) {
            char c = pattern.charAt(patternIndex);

            if (c == '*') {
                while (stringIndex < stringLength) {
                    if (wildcardMatch(pattern.substring(patternIndex + 1),
                                      string.substring(stringIndex))) {
                        return true;
                    }
                    ++stringIndex;
                }// end of while

            } else if (c == '?') {
                ++stringIndex;
                if (stringIndex > stringLength) {
                    return false;
                }

            } else {
                if (stringIndex >= stringLength
                        || c != string.charAt(stringIndex)) {
                    return false;
                }
                ++stringIndex;
            }
        }
        return stringIndex == stringLength;
    }

    class Queue {// 先进先出的队列
        private Vector vector = new Vector();

        public void put(Object object) {// 入队
            vector.addElement(object);
        }

        public Object get() {// 出队
            Object object = peek();
            if (object != null) {
                vector.removeElementAt(0);
            }
            return object;
        }

        public Object peek() {// 取队列首元素
            if (isEmpty()) {
                return null;
            }
            return vector.elementAt(0);
        }

        public boolean isEmpty() {// 队列是否为空
            return vector.isEmpty();
        }

        public int size() {// 队列的大小
            return vector.size();
        }

    }
}