主要是一些流操作吧，之前用得少，這次寫了就先儲存起來，程式碼如下：

import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.util.Queue;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.LinkedBlockingQueue;

import org.apache.http.HttpEntity;
import org.apache.http.TruncatedChunkException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.apache.poi.xssf.usermodel.XSSFCell;
import org.apache.poi.xssf.usermodel.XSSFRow;
import org.apache.poi.xssf.usermodel.XSSFSheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;

import com.alibaba.fastjson.JSONObject;

/**
 * 圖片下載
 * @author xiaowei 2018年3月5日 下午1:42:36
 */
public class DownloadPicH5 {

    private static final String CERT_URL         = "http://***/cifCert/queryCifCert";
    private static final String PIC_URL          = "http://***/show?uniqueKey=";
    private static final String RESOURCE_PATH    = "/home/dev/***.xlsx";
    private static final String ERROR_PATH       = "/home/dev/error.txt";
    private static final String EXAMPLE_PIC_PATH = "/home/dev/example.jpg";
    private static final String PIC_POSTFIX      = ".jpg";
    private static final String PIC_FACE         = "正面" + PIC_POSTFIX;
    private static final String PIC_BACK         = "反面" + PIC_POSTFIX;
    private static final String PIC_HAND         = "手持照" + PIC_POSTFIX;
    private static List<Cust>   errorList        = new ArrayList<>();
    static byte[]               bytes            = new byte[1024];

    // 預載入樣例圖片
    static {
        try {
            InputStream in = new FileInputStream(new File(EXAMPLE_PIC_PATH));
            in.read(bytes);
            in.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) throws Exception {

        LinkedBlockingQueue<Cust> queue = new LinkedBlockingQueue<>(230000);
        // ArrayBlockingQueue 為有界佇列
        //        ArrayBlockingQueue<Cust> queue = new ArrayBlockingQueue<>(230000);
        //        List<Cust> list = new ArrayList<>(5000);
        FileInputStream excelFileInputStream = new FileInputStream(RESOURCE_PATH);
        // XSSFWorkbook 就代表一個 Excel 檔案
        // 建立其物件，就開啟這個 Excel 檔案
        XSSFWorkbook workbook = new XSSFWorkbook(excelFileInputStream);
        // 輸入流使用後，及時關閉！這是檔案流操作中極好的一個習慣！
        excelFileInputStream.close();
        // XSSFSheet 代表 Excel 檔案中的一張表格
        // 我們通過 getSheetAt(0) 指定表格索引來獲取對應表格
        // 注意表格索引從 0 開始！
        XSSFSheet sheet = workbook.getSheetAt(0);
        // 開始迴圈表格資料,表格的行索引從 0 開始
        // employees.xlsx 第一行是標題行，我們從第二行開始, 對應的行索引是 1
        // sheet.getLastRowNum() : 獲取當前表格中最後一行資料對應的行索引
        String str;
        for (int rowIndex = 0; rowIndex <= sheet.getLastRowNum(); rowIndex++) {

            // XSSFRow 代表一行資料
            XSSFRow row = sheet.getRow(rowIndex);
            if (row == null) {
                continue;
            }
            XSSFCell nameCell = row.getCell(0);
            str = nameCell.getStringCellValue();
            //            queue.add(new Cust(str, str.substring(str.length() - 19, str.length())));
            queue.put(new Cust(str, str.substring(str.length() - 19, str.length())));

        }
        // 操作完畢後，記得要將開啟的 XSSFWorkbook 關閉
        workbook.close();

        final CountDownLatch latch = new CountDownLatch(128);
        for (int i = 0; i < 128; i++) {
            new Thread(new Runnable() {
                public void run() {
                    while (!queue.isEmpty()) {
                        // 儲存圖片
                        getPicInfo(queue);
                    }
                    latch.countDown();
                }
            }).start();
        }
        latch.await();
        System.out.println("SUCCESS");
        // 儲存失敗記錄
        if (!errorList.isEmpty()) {
            String error = JSONObject.toJSONString(errorList);
            File tempFile = new File(ERROR_PATH);
            FileOutputStream outStream = new FileOutputStream(tempFile);
            outStream.write(error.getBytes());
            outStream.close();
        }
    }

    public static byte[] readInputStream(InputStream inStream) throws Exception {
        ByteArrayOutputStream outStream = new ByteArrayOutputStream();
        //建立一個Buffer字串 
        byte[] buffer = new byte[1024];
        //每次讀取的字串長度，如果為-1，代表全部讀取完畢 
        int len = 0;
        //使用一個輸入流從buffer裡把資料讀取出來 
        while ((len = inStream.read(buffer)) != -1) {
            //用輸出流往buffer裡寫入資料，中間引數代表從哪個位置開始讀，len代表讀取的長度 
            outStream.write(buffer, 0, len);
        }
        //關閉輸入流 
        inStream.close();
        //把outStream裡的資料寫入記憶體 
        return outStream.toByteArray();
    }

    /**
     * 獲取圖片相關資訊
     */
    public static void getPicInfo(Queue<Cust> queue) {

        Cust cust = queue.poll();
        String path = "/home/dev/h5/" + cust.resNo + "/";
        // 建立資料夾
        File file = new File(path);
        if (!file.exists()) {
            file.mkdirs();
        }

        //        // 由於前期除錯程式，所以存在重新下載檔案的情況
        //        // 當三個檔案均存在時，跳過該客戶
        //        String pathIgnore = path + PIC_FACE;
        //        File imageFile = new File(pathIgnore);
        //        boolean fileExist = imageFile.exists();
        //        if (fileExist) {
        //            pathIgnore = path + PIC_BACK;
        //            imageFile = new File(pathIgnore);
        //            fileExist = imageFile.exists();
        //            if (fileExist) {
        //                pathIgnore = path + PIC_HAND;
        //                imageFile = new File(pathIgnore);
        //                fileExist = imageFile.exists();
        //                if (fileExist)
        //                    return;
        //            }
        //
        //        }
        try {

            // 1、get cert fileNo
            String response = null;
            CloseableHttpClient httpClient = HttpClients.createDefault();
            HttpPost post = new HttpPost(CERT_URL);
            StringEntity entity = new StringEntity(new Req(cust.custNo).toString(), "UTF-8");
            entity.setContentType("application/json");
            post.setEntity(entity);
            CloseableHttpResponse httpResponse = httpClient.execute(post);
            HttpEntity httpEntity = httpResponse.getEntity();
            response = EntityUtils.toString(httpEntity, "UTF-8");
            List<Cert> certList = JSONObject.parseObject(response).getJSONArray("respData")
                .toJavaList(Cert.class);

            // 2、 download file
            boolean type1Exist = false;
            boolean type2Exist = false;
            boolean type5Exist = false;
            for (Cert cert : certList) {
                HttpGet get = new HttpGet(PIC_URL + cert.fileNo);
                CloseableHttpResponse respose = null;
                switch (cert.certType) {
                    case "1":
                        download(httpClient, get, respose, path, PIC_FACE, cust);
                        type1Exist = true;
                        break;
                    case "2":
                        download(httpClient, get, respose, path, PIC_BACK, cust);
                        type2Exist = true;
                        break;
                    case "5":
                        download(httpClient, get, respose, path, PIC_HAND, cust);
                        type5Exist = true;
                        break;
                    default:
                        break;
                }
            }

            if (!type1Exist) {
                File tempFile = new File(path + PIC_FACE);
                FileOutputStream outStream = new FileOutputStream(tempFile);
                outStream.write(bytes);
                outStream.close();
            }
            if (!type2Exist) {
                File tempFile = new File(path + PIC_BACK);
                FileOutputStream outStream = new FileOutputStream(tempFile);
                outStream.write(bytes);
                outStream.close();
            }
            if (!type5Exist) {
                File tempFile = new File(path + PIC_HAND);
                FileOutputStream outStream = new FileOutputStream(tempFile);
                outStream.write(bytes);
                outStream.close();
            }
        } catch (Exception e) {
            errorDo(cust);
        }
    }

    /**
     * 真正下載並儲存圖片的地方
     */
    public static void download(CloseableHttpClient httpClient, HttpGet get,
                                CloseableHttpResponse response, String path, String name, Cust cust) {

        // 檔案已存在，跳過下載
        File imageFile = new File(path + name);
        if (imageFile.exists()) {
            return;
        }

        try {
            response = httpClient.execute(get);
        } catch (Exception e) {
            e.printStackTrace();
        }
        HttpEntity entity = response.getEntity();
        try {
            InputStream instream = entity.getContent();
            byte[] data = readInputStream(instream);

            //建立輸出流 
            FileOutputStream outStream = new FileOutputStream(imageFile);
            //寫入資料 
            outStream.write(data);
            //關閉輸出流 
            outStream.close();
        } catch (TruncatedChunkException te) {
            errorDo(cust);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 網路錯誤等下載異常時，呼叫該方法重試下載數次
     * @description 此處程式碼是複製getPicInfo方法，可以提取並優化，暫不做處理了。
     */
    public static void errorDo(Cust cust) {

        // 建立資料夾
        String path = "/home/dev/h5/" + cust.resNo + "/";
        File file = new File(path);
        if (!file.exists()) {
            file.mkdirs();
        }
        for (int i = 0; i < 3; i++) {
            try {
                // 1、get cert fileNo
                String response = null;
                CloseableHttpClient httpClient = HttpClients.createDefault();
                HttpPost post = new HttpPost(CERT_URL);
                StringEntity entity = new StringEntity(new Req(cust.custNo).toString(), "UTF-8");
                entity.setContentType("application/json");
                post.setEntity(entity);
                CloseableHttpResponse httpResponse = httpClient.execute(post);
                HttpEntity httpEntity = httpResponse.getEntity();
                response = EntityUtils.toString(httpEntity, "UTF-8");
                List<Cert> certList = JSONObject.parseObject(response).getJSONArray("respData")
                    .toJavaList(Cert.class);

                // 2、 download file
                boolean type1Exist = false;
                boolean type2Exist = false;
                boolean type5Exist = false;
                for (Cert cert : certList) {
                    HttpGet get = new HttpGet(PIC_URL + cert.fileNo);
                    CloseableHttpResponse respose = null;
                    switch (cert.certType) {
                        case "1":
                            download(httpClient, get, respose, path, PIC_FACE, cust);
                            type1Exist = true;
                            break;
                        case "2":
                            download(httpClient, get, respose, path, PIC_BACK, cust);
                            type2Exist = true;
                            break;
                        case "5":
                            download(httpClient, get, respose, path, PIC_HAND, cust);
                            type5Exist = true;
                            break;
                        default:
                            break;
                    }
                }

                if (!type1Exist) {
                    File tempFile = new File(path + PIC_FACE);
                    FileOutputStream outStream = new FileOutputStream(tempFile);
                    outStream.write(bytes);
                    outStream.close();
                }
                if (!type2Exist) {
                    File tempFile = new File(path + PIC_BACK);
                    FileOutputStream outStream = new FileOutputStream(tempFile);
                    outStream.write(bytes);
                    outStream.close();
                }
                if (!type5Exist) {
                    File tempFile = new File(path + PIC_HAND);
                    FileOutputStream outStream = new FileOutputStream(tempFile);
                    outStream.write(bytes);
                    outStream.close();
                }
                return;
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        errorList.add(cust);
    }
}

/**
 * 客戶類，儲存客戶的resNo、custNo
 * @author xiaowei 2018年3月5日 上午11:38:10
 */
class Cust {
    String resNo;
    String custNo;

    public Cust(String resNo, String custNo) {
        this.resNo = resNo;
        this.custNo = custNo;
    }

    @Override
    public String toString() {
        return "Cust [resNo=" + resNo + ", custNo=" + custNo + "]";
    }

}

/**
 * 用來包裝作為http請求物件，主要功能是toString方法。
 * @description 可用其他方法實現
 * @author xiaowei 2018年3月5日 上午11:40:02
 */
class Req implements Serializable {

    private static final long serialVersionUID = 1L;
    String                    customerNo;

    public Req(String customerNo) {
        this.customerNo = customerNo;
    }

    public String getCustomerNo() {
        return customerNo;
    }

    public void setCustomerNo(String customerNo) {
        this.customerNo = customerNo;
    }

    @Override
    public String toString() {
        return JSONObject.toJSONString(this);
    }
}

/**
 * 身份資訊類，用來接收客戶的檔案資訊
 * @author xiaowei 2018年3月5日 上午11:41:29
 */
class Cert {
    String id;
    String customerNo;
    String customerName;
    String certType;
    String fileNo;
    String fileDesc;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getCustomerNo() {
        return customerNo;
    }

    public void setCustomerNo(String customerNo) {
        this.customerNo = customerNo;
    }

    public String getCustomerName() {
        return customerName;
    }

    public void setCustomerName(String customerName) {
        this.customerName = customerName;
    }

    public String getCertType() {
        return certType;
    }

    public void setCertType(String certType) {
        this.certType = certType;
    }

    public String getFileNo() {
        return fileNo;
    }

    public void setFileNo(String fileNo) {
        this.fileNo = fileNo;
    }

    public String getFileDesc() {
        return fileDesc;
    }

    public void setFileDesc(String fileDesc) {
        this.fileDesc = fileDesc;
    }

    @Override
    public String toString() {
        return "Cert [id=" + id + ", customerNo=" + customerNo + ", customerName=" + customerName
               + ", certType=" + certType + ", fileNo=" + fileNo + ", fileDesc=" + fileDesc + "]";
    }

}