摘要：封裝一個(gè)操作工具類概述前人的代碼中把操作和業(yè)務(wù)邏輯實(shí)現(xiàn)耦合在一起，據(jù)說(shuō)經(jīng)過(guò)多次的修改，在性能表現(xiàn)方面已經(jīng)非?？孔V。連接對(duì)象池使用對(duì)象池管理方式需要提供一個(gè)工廠類，管理對(duì)象的生成銷毀等。

前人的代碼中把FTP操作和業(yè)務(wù)邏輯實(shí)現(xiàn)耦合在一起，據(jù)說(shuō)經(jīng)過(guò)多次的修改，在性能表現(xiàn)方面已經(jīng)非常靠譜。
在原來(lái)的代碼中可以看到使用了commons-net進(jìn)行FTP操作，使用commons-pool對(duì)象池方式管理FTP連接，
完成了多線程下載和上傳的功能，本次的修改只是把耦合的地方剝離開(kāi)來(lái)。

使用apache commons pool對(duì)象池管理方式需要提供一個(gè)工廠類，管理對(duì)象的生成銷毀等。
需要實(shí)現(xiàn)如下方法，

PooledObject makeObject(K key) throws Exception;
void destroyObject(K key, PooledObject p) throws Exception;
boolean validateObject(K key, PooledObject p);

apache commons pool提供了一個(gè)帶泛型的接口KeyedPooledObjectFactory，
需要繼承實(shí)現(xiàn)類提供對(duì)象工廠的key類型，及要生產(chǎn)的對(duì)象類型，key可以是一個(gè)類，包含F(xiàn)TP的IP
，端口，用戶名密碼等屬性組成，目的是區(qū)分不同的FTP連接，

public class FtpClientConfig {
    
    private String host;
    private int port;
    private String username;
    private String password;
...
}

這里要生產(chǎn)的對(duì)象類型當(dāng)然是FTPClient了，所以我們的工廠類是這樣的，

public class FtpClientFactory implements KeyedPooledObjectFactory{
...
}

相應(yīng)的，我們提供一個(gè)對(duì)象池的實(shí)現(xiàn)，其實(shí)很簡(jiǎn)單

public class FtpClientPool extends GenericKeyedObjectPool  {

    public FtpClientPool(FtpClientFactory factory, FtpPoolConfig config) {
        super(factory, config);
    }

}

構(gòu)造方法的參數(shù)就是我們提供的對(duì)象工廠FtpClientFactory和FtpPoolConfig，FtpPoolConfig是

public class FtpPoolConfig extends GenericKeyedObjectPoolConfig{
    public FtpPoolConfig() {
        setTestWhileIdle(true);
        setTimeBetweenEvictionRunsMillis(60000);
        setMinEvictableIdleTimeMillis(1800000L);
        setTestOnBorrow(true);
    }
}

針對(duì)FTP連接設(shè)置了一些參數(shù)。

外部只要拿到FtpClientPool對(duì)象就可以獲取FTPClient對(duì)象、返回FTPClien對(duì)象了，
FTPClient的生成銷毀就交給了FtpClientFactory管理。

FTP連接池比方數(shù)據(jù)庫(kù)連接池來(lái)看，使用連接池似乎可以模仿Spring的JdbcTemplate，這個(gè)模板封裝了
獲取連接，執(zhí)行數(shù)據(jù)庫(kù)操作，返還連接給連接池的過(guò)程，在這里同樣也適合。這里引入一個(gè)自己實(shí)現(xiàn)的"模板類"，

public class FtpTemplate implements FtpOperations {
    @Autowired
    private FtpClientPool ftpClientPool;    
}

繼承自己定義的FTP操作接口，并且注入上一步封裝好的對(duì)象池，當(dāng)然在實(shí)踐過(guò)程中可能做不到像JdbcTemplate
那樣完全的泛型化。
比如為了泛型實(shí)例化，引入InterfaceConfig類我們才能真正實(shí)現(xiàn)FtpTemplate類。

public class FtpTemplate implements FtpOperations {
    ...
    @Override
    public String getFile(InterfaceConfig k, String fileName) throws Exception {
        if (logger.isDebugEnabled()) {
            logger.debug("正在下載" + toFtpInfo(k) + "/" + fileName + "文件");
        }
        final FTPClient client = getFtpClient(getFtpClientPool(), k);
        boolean ret = changeDirectory(client,k);
        
        try {
            if(ret) {
                return performPerFile(client, fileName);
            }
            return null;
        } catch(Exception e) {
            logger.error("下載" + toFtpInfo(k) + "/" + fileName + "文件異常",e);
            throw e;
        } finally {
            //return to object pool
            if(client != null) {
                returnFtpClient(getFtpClientPool(), k, client);
            }
        }
    }
...
}

通過(guò)InterfaceConfig提供對(duì)象池識(shí)別的key獲得我們需要的對(duì)象池里的對(duì)象FTPClient。

    private FTPClient getFtpClient(FtpClientPool ftpClientPool, InterfaceConfig k) throws Exception {
        FtpClientConfig config = buildFtpClientConfig(k);
        FTPClient client = null;
        try {
            client = ftpClientPool.borrowObject(config);
        } catch (Exception e) {
            logger.error("獲取FTPClient對(duì)象異常 " + toFtpInfo(k),e);
            throw e;
        }
        return client;
    }
    private FtpClientConfig buildFtpClientConfig(InterfaceConfig k) {
        FtpClientConfig config = new FtpClientConfig();
        config.setHost(k.getFtpUrl());
        config.setPort(Integer.valueOf(k.getFtpPort()));
        config.setUsername(k.getUserName());
        config.setPassword(k.getPwd());
        return config;
    }    

這個(gè)InterfaceConfig是業(yè)務(wù)代碼中的對(duì)象類型，可能是Model類。目前為止我引入了一點(diǎn)點(diǎn)關(guān)于
業(yè)務(wù)的代碼，但還沒(méi)有耦合進(jìn)來(lái)業(yè)務(wù)實(shí)現(xiàn)邏輯。

其實(shí)FtpTemplate已經(jīng)是一個(gè)適合業(yè)務(wù)邏輯實(shí)現(xiàn)的工具類的，但是它的功能單純一些，為了完成特殊的業(yè)務(wù)功能，
如多線程下載，下載文件業(yè)務(wù)處理成功后才刪除遠(yuǎn)端服務(wù)的文件等，這里再對(duì)FtpTemplate做一次封裝。

public class FtpUtils {
    @Autowired
    private FtpTemplate ftpTemplate;
    private ConcurrentHashMap poolMap = new ConcurrentHashMap<>(); //存儲(chǔ)線程池
    
    public void downloadDirectory(InterfaceConfig config,
             final FtpCallback callback) {
        logger.info("正在下載FTP目錄" + toFtpInfo(config));
        ThreadPoolExecutor workPool = poolMap.get(config.getInterfaceCode());
        if(workPool == null) {
            BlockingQueue workQueue = new LinkedBlockingQueue(100);
            workPool = new ThreadPoolExecutor(MAX_CORE_NUM, MAX_THREAD_NUM, 1, TimeUnit.MINUTES, workQueue);
            poolMap.put(config.getInterfaceCode(), workPool);
        }
        try {
            List fileNames = ftpTemplate.listFiles(config,config.getOrdersCount());
            BlockingQueue fileQueue = new LinkedBlockingQueue(fileNames); //生產(chǎn)者資料
            for(int i = 0; i < config.getThreadNum(); i++) {
                try {
                    workPool.execute(new GetFileConsumer(config, fileQueue, callback));
                } catch (Exception e) {
                    logger.error("提交線程出現(xiàn)異常",e);
                }
            }
        } catch (Exception e) {
            logger.error("FTP操作出現(xiàn)異常"+toFtpInfo(config),e);
        }
        logger.info("下載FTP目錄完成" + toFtpInfo(config));
    }        
}

注入了FtpTemplate，加入了多線程線程池管理，下載方法也需要外部傳入回調(diào)方法。
回調(diào)方法中就可以完成保存下載的FTP文件，刪除遠(yuǎn)端對(duì)應(yīng)的文件等邏輯。即使了多了一層多線程
下載功能的封裝，我們也沒(méi)有把業(yè)務(wù)處理邏輯耦合進(jìn)來(lái)。當(dāng)然，不滿意的地方還是引入了業(yè)務(wù)的Model類。

略

從上往下可以看出來(lái)三處封裝，分別是FtpUtils、FtpTemplate和FtpClientPool，我們可以分別
對(duì)他們進(jìn)行單元測(cè)試，

注入FtpClientPool，測(cè)試FTP連接問(wèn)題等

注入FtpTemplate，測(cè)試FTP操作問(wèn)題等

注入FtpUtils,傳入回調(diào)函數(shù)，測(cè)試業(yè)務(wù)問(wèn)題

由于JUnit對(duì)多線程單元測(cè)試并沒(méi)有提供支持，所以第3點(diǎn)實(shí)現(xiàn)起來(lái)有困難。

https://github.com/Honwhy/com... 見(jiàn)master分支