(文章本人原創，若轉載請注明出處)

下面看一下一些具體的實現，先看一下Sender接口的commitData方法的MySql實現，即SenderMySqlImp類：

    很簡單吧，其實就是用Stream來做，另外在網上可以找到有關Oracle上傳blob的實現，一般都是先insert一條記錄，blob字段用empty_blob()函數插入一個空數據，然后再取出這個blob字段，最后按字節寫入blob，具體參考SenderOracleImp類吧。個人感覺還是在mysql的這個效率高些并且看起來簡單了很多。

    然后來看看使用線程池的ProcessMulti類：

public class ProcessMulti implements Process{
    private String path;
    private Vector<String> files = new Vector<String>();
    private Properties prop;

    ProcessMulti() {
        prop = ConfigMgr.getProperties();  //取config.properties中配置信息
        this.path = prop.getProperty("path");
        this.files = Helper.getFiles(prop.getProperty("filetype"), this.path);
    }

    public void doProcess() {
//正如前面兩篇所說,這里是線程池構建器,傳入相關參數
        BlobSenderThreadPool tpe = new BlobSenderThreadPool(Integer
                .valueOf(prop.getProperty("corePoolSize")), Integer
                .valueOf(prop.getProperty("maxPoolSize")), Integer.valueOf(prop
                .getProperty("keepAliveTime")), TimeUnit.SECONDS,
                new ArrayBlockingQueue<Runnable>(Integer.valueOf(prop
                        .getProperty("maxPoolSize"))),
                new BlobSenderThreadPool.DiscardPolicy(), files.size());

        Logger.writeLogForce("開始處理." + new java.util.Date());
        for (int i = 0; i < this.files.size(); i++) {
            //向線程池提交要處理的任務,線程池根據其配置進行處理
            //Helper.getSender()會根據配置取得支持mysql或是oracel的寫入方法
            tpe.execute(new Runner(path, files.get(i), Helper.getSender()));
            Logger.writeLog("已提交第" + (int)(i+1)  + "個文件" + "，時間為："
                    + new java.util.Date());
        }
　　　　//可以在這里寫一個打印輸出,實際上程序很快就執行完上面的for,運行到這里,但是處理并沒有完成,
       //主程序好像職業經理人,他的工作就是分配任務給下屬,自已就完成工作了,但下屬們還要接著忙活呵呵...
       System.out.println("任務已分配...");
    }
    //線程池類
    class BlobSenderThreadPool extends ThreadPoolExecutor {
        volatile int planTask;//計劃任務,即計劃要寫的文件數

        public BlobSenderThreadPool(int corePoolSize, int maximumPoolSize,
                long keepAliveTime, TimeUnit unit,
                BlockingQueue<Runnable> workQueue,
                RejectedExecutionHandler handler, int planTask) {
            super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
            this.planTask = planTask;
        }

        @Override
        //當某個線程處理完時會調用此方法
        protected void afterExecute(Runnable r, Throwable t) {
            Logger.writeLog("當前已完成任務數：" + (int)(this.getCompletedTaskCount()+1)
                    + "計劃任務數：" + planTask);
           //若已處理完任務和計劃的任務數相同說明所有線程已完成處理,終止線程池處理
　　　　　　if ((this.getCompletedTaskCount()+1)== planTask)
                this.terminated();
            super.afterExecute(r, t);
        }

        @Override
        protected void terminated() {
            Logger.writeLogForce("所有任務已完成 ,處理結束時間===>>" + new java.util.Date());
            System.exit(0);
        }

    }

//要使用線程進行處理,類要實現Runable接口
    class Runner implements Runnable {
        String file;
        String path;
        Sender sender;

        Runner(String path, String file, Sender sender) {
            this.file = file;
            this.path = path;
            this.sender = sender;
        }
//Runer的實例會被傳入線程池,線程被運行時會調用run方法
        public void run() {
            sender.commitData(path, file);
        }

    }

(文章本人原創，若轉載請注明出處)

　　在實際當中的情況是系統數據庫中需要上傳大量照片到數據庫中，數據量比較大，且不能在界面中通過操作逐個上傳，要批量自動進行。其實起來也比較簡單直接利用線程池將照片數據讀取成流再存入BLOB字段即可。但是在實現后些功能后又進入了一些改造，實現了線程池、單線程、是否使用用連接池、不同數據庫等不同的配置，這樣在不同配置下可以觀察到程序性能的不同。并且經過設計切換這些配置不需要修改程序。

使用DbAccess接口的getConnect()取得數據庫連接，DbImp和DbPoolingImp實現了不使用連接池和使用連接池的兩個版本。Sender接口的commitData()用來把BLOB數據寫到數據庫中，因為不同數據庫可能寫法有點不同所以這里SenderMySqlImp和SenderOracleImp分別是Mysql和Oracle的實現。Process接口的doProcess()是開始進行處理的方法，無論是單線程還是多線程。因此ProcessMulti和ProcessSingle是分別使用線程池以及單線程處理的類。ConfigMgr用于取得config.properties文件內配置信息，Logger是日志類，Helper中匯集了一些共用的靜態方法。最后DataSender是主程序的類：）