-Android -線程池 批量上傳圖片 -附php接收代碼

（出處：http://www.cnblogs.com/linguanh/）

目錄：

　　1，前序

　　2，類特點

　　3，用法

　　4，java代碼

　　5，php代碼

 

 

1，前序

　　還是源於重構，看着之前為趕時間寫着的碎片化的代碼，甚是悲劇，臃腫且長，其實重構也是一個提高的過程，重構過程中會接觸到更多的知識點。至少，我現在意識到，那怕是聽過、有這樣的意識而沒真正動過手都是不行的，多線程並發最好使用線程池而不要一味地 new Thread(...).start()。下面我分享個自己剛寫好的圖片批量上傳類，順帶server端接口代碼，已經過測試，一套直接可用。

 

2，本類特點

　　1、耦合度低，操作簡單、使用時僅 6 行代碼即可直接 批量上傳完圖片；

　　2、使用的是軟化線程池對象，內存消耗這方面可以放心地交給系統處理；

　　3、采用鏈式操作，配置方便；

　　4、自帶上傳函數，光學習這個都夠了；

　　5、懶人必備...

 

3，使用例子

new PicUpLoadExecutor(3)// 並發數       
　　　　  .withUpLoadUrl(url)   // 服務端接口文件的url
        .withHandler(handler) // 發完后發消息的handler
        .exec(picBitmaps);    // 要上傳的圖片bitmaps

4，client端java類

注釋已經很豐富，不懂請留言

package cn.share.bananacloud.post.send;

import android.graphics.Bitmap;
import android.os.Handler;
import android.util.Log;

import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.lang.ref.SoftReference;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

/**
 *  Created by 林冠宏 on 2016/4/30.
 *
 *  1,線程池批量上傳圖片類，選用 newFixedThreadPool
 *  2,以 Bitmap 數組為例子
 *  3,自定義一個 圖片上傳 函數
 *
 */

public class PicUpLoadExecutor {

    private static final String TAG = "PicUpLoadHelper";
    public static final int UpLoadFinish = 0x321;

    /** 如果你不想內存不足是它們被gc掉，請換為強引用 */
    private SoftReference<ExecutorService> fixedThreadPool = null;

    /** 並發數>0 --1 ~ 128,用 short 足以 */
    private short poolSize = 1;
    private Handler handler = null;
    private ExecListenter ExecListenter;
    private String url = null;

    public PicUpLoadExecutor(short poolSize){
        fixedThreadPool = new SoftReference<ExecutorService>(Executors.newFixedThreadPool(poolSize));
    }

    public PicUpLoadExecutor(short poolSize,ThreadFactory threadFactory){
        fixedThreadPool = new SoftReference<ExecutorService>(Executors.newFixedThreadPool(poolSize,threadFactory));
    }

    /** 設置並發數 */
    /*public PicUpLoadExecutor withPoolSize(short poolSize){
        this.poolSize = poolSize;
        return this;
    }*/

    /** 設置圖片總數，已直接換為圖片數目 */
    /*public PicUpLoadHelper withPicSize(short poolSize){
        this.picSize = picSize;
        return this;
    }*/

    /** 設置圖片上傳路徑 */
    public PicUpLoadExecutor withUpLoadUrl(String url){
        this.url = url;
        return this;
    }

    /** 設置handler */
    public PicUpLoadExecutor withHandler(Handler handler){
        this.handler = handler;
        return this;
    }

    /** 設置自定義 run 函數接口 */
    /*public PicUpLoadHelper withExecRunnableListenter(ExecRunnableListenter ExecRunnableListenter){
        this.ExecRunnableListenter = ExecRunnableListenter;
        return this;
    }*/

    /** 設置開始前接口 */
    public PicUpLoadExecutor withBeforeExecListenter(ExecListenter ExecListenter){
        this.ExecListenter = ExecListenter;
        return this;
    }


    public ExecutorService getFixedThreadPool(){
        return fixedThreadPool.get();
    }

    /** 開發原則--接口分離 */

    /** 自定義run接口 */
    public interface ExecRunnableListenter{
        void onRun(int i);
    }

    /** 開始任務前接口，沒用到，可自行設置 */
    public interface ExecListenter{
        void onBeforeExec();
    }

    /** 為減少 程序計數器 每次在循環時花費在 if else 的時間，這里還是 重載一次 好 */

    public void exec(final Bitmap[] bitmaps,final ExecRunnableListenter ExecRunnableListenter){
        if(bitmaps==null){
            return;
        }
        if(ExecRunnableListenter!=null){
            int picNums = bitmaps.length;
            for(int i=0;i<picNums;i++){
                /** 自定義執行上傳任務 */
                final int picIndex = i;
                fixedThreadPool.get().execute(new Runnable() {
                    @Override
                    public void run() {
                        ExecRunnableListenter.onRun(picIndex);
                    }
                });
            }
        }
    }

    public void exec(final Bitmap[] bitmaps){
        if(bitmaps==null){
            return;
        }
        int picNums = bitmaps.length;
        for(int i=0;i<picNums;i++){
            /** 默認執行上傳任務 */
            final int picIndex = i;
            fixedThreadPool.get().execute(new Runnable() {
                @Override
                public void run() {
                    /** 批量 上傳 圖片，此靜態函數若有使用全局變量，必須要 加 synchronized */
                    String json = uploadPic
                            (
                                    url,
                                    "" + picIndex + ".jpg", /** 我自己情況的上傳 */
                                    bitmaps[picIndex]       /** 對應的圖片流 */
                            );
                    if(json!=null){
                        /** 服務器上傳成功返回的標示, 自己修改吧，我這里是我的情況 */
                        if(json.trim().equals("yes")){
                            /** UpLoadFinish 是每次傳完一張發信息的信息標示 */
                            handler.sendEmptyMessage(UpLoadFinish);
                        }
                    }
                    Log.d(TAG,"pic "+picIndex+" upLoad json ---> "+json);
                }
            });
        }
    }

    /** 若有依賴全局變量必須加 synchronized */
    /** 此函數采用 tcp 數據包傳輸 */
    public static String uploadPic(String uploadUrl,String filename,Bitmap bit){
        String end = "\r\n"; /** 結束符 */
        String twoHyphens = "--";
        String boundary = "******"; /** 數據包頭，設置格式沒強性要求 */
        int compress=100; /** 壓縮初始值 */
        try{
            HttpURLConnection httpURLConnection
                    = (HttpURLConnection) new URL(uploadUrl).openConnection();
            /** 設置每次傳輸的流大小，可以有效防止手機因為內存不足崩潰 */
            /** 此方法用於在預先不知道內容長度時啟用沒有進行內部緩沖的 HTTP 請求正文的流。*/
            httpURLConnection.setChunkedStreamingMode(256 * 1024);// 256K

            httpURLConnection.setConnectTimeout(10*1000);
            httpURLConnection.setDoInput(true);
            httpURLConnection.setDoOutput(true);
            httpURLConnection.setUseCaches(false);

            httpURLConnection.setRequestMethod("POST");
            /** tcp鏈接，防止丟包，需要進行長鏈接設置 */
            httpURLConnection.setRequestProperty("Connection", "Keep-Alive");
            httpURLConnection.setRequestProperty("Charset", "UTF-8");
            httpURLConnection.setRequestProperty("Content-Type","multipart/form-data;boundary=" + boundary);

            /** 發送報頭操作，dos 也是流發送體 */
            DataOutputStream dos = new DataOutputStream(httpURLConnection.getOutputStream());
            dos.writeBytes(twoHyphens + boundary + end);
            /** uploadedfile 是接口文件的接受流的鍵，client 和 server 要同步 */
            dos.writeBytes("Content-Disposition: form-data; name=\"uploadedfile\"; filename=\""
                    + filename.substring(filename.lastIndexOf("/") + 1)
                    + "\""
                    + end);
            dos.writeBytes(end);

            /** 下面是壓縮操作 */
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            bit.compress(Bitmap.CompressFormat.JPEG, compress, baos);
            while (baos.toByteArray().length / 1024 > 500) {
                Log.d(TAG,"compress time ");
                baos.reset();
                compress -= 10;
                if(compress==0){
                    bit.compress(Bitmap.CompressFormat.JPEG, compress, baos);
                    break;
                }
                bit.compress(Bitmap.CompressFormat.JPEG, compress, baos);
            }

            /** 發送比特流 */
            InputStream fis = new ByteArrayInputStream(baos.toByteArray());
            byte[] buffer = new byte[10*1024]; // 8k+2k
            int count = 0;
            while ((count = fis.read(buffer)) != -1) {
                dos.write(buffer, 0, count);
            }
            fis.close();
            dos.writeBytes(end);
            dos.writeBytes(twoHyphens + boundary + twoHyphens + end);
            dos.flush();

            /** 獲取返回值 */
            InputStream is = httpURLConnection.getInputStream();
            InputStreamReader isr = new InputStreamReader(is, "utf-8");
            BufferedReader br = new BufferedReader(isr);
            String result = br.readLine();

            Log.d(TAG, "send pic result "+result);
            dos.close();
            is.close();
            return result;
        } catch (Exception e){
            e.printStackTrace();
            Log.d(TAG, e.toString());
            return null;
        }
    }
}

5，server端接受代碼 php

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2016/4/30
 * Time: 15:37
 */

// $_FILES['uploadedfile']['name'] 是傳過來的圖片名稱

$target_path = "要保存到的路徑";

if(move_uploaded_file($_FILES['uploadedfile']['tmp_name'], $target_path)) {
    echo "yes";
}  else{
    echo "no";
}


?>