可以这样来实现上传:
activity中执行:
private class UploadPhotoTask extends AsyncTask<String, Void, Boolean>{ @Override protected void onPreExecute() { super.onPreExecute(); } protected Boolean doInBackground(String... params) { return HttpUploadedFile.getInstance().doUploadPhoto(getApplicationContext(), mUploadFilePathName, mHandler); } protected void onPostExecute(Boolean result){ mIsUploading = false; showProgressBar(false); if(result){ Toast.makeText(UploadPhotoActivity.this, R.string.upload_photo_fail, Toast.LENGTH_SHORT).show(); }else{ Toast.makeText(UploadPhotoActivity.this, R.string.upload_photo_fail, Toast.LENGTH_SHORT).show(); } } }
/** Handler to get notify from upload photo engine*/ private Handler mHandler = new Handler() { @Override public void handleMessage(Message msg) { switch (msg.what) { case HttpUploadedFile.POST_PROGRESS_NOTIFY: int completePercent = msg.arg1; HandleUploadProgress(completePercent); break; default: break; } } }; /** * handle the uploading progress notification */ private void HandleUploadProgress(int completePercent){ View containerView = findViewById(R.id.photo_upload_progress_bar_container); int maxLen = containerView.getWidth(); <strong>//这个是进度条所在的parent layout的宽度</strong> int barLen = (completePercent * maxLen) / 100; View barView = findViewById(R.id.photo_upload_progress_bar); LayoutParams params = new LayoutParams(); params.height = LayoutParams.FILL_PARENT; params.width = barLen; barView.setLayoutParams(params); //更新进度条的宽度 } /** * show or hide progress bar */ private void showProgressBar(boolean show){ View view = findViewById(R.id.photo_upload_progress_layout); if(show){ view.setVisibility(View.VISIBLE); View bar = view.findViewById(R.id.photo_upload_progress_bar); LayoutParams params = new LayoutParams(); params.height = LayoutParams.FILL_PARENT; params.width = 3; bar.setLayoutParams(params); }else{ view.setVisibility(View.GONE); } }
public class HttpUploadedFile { /** single instance of this class */ private static HttpUploadedFile instance = null; /** * Constructor */ private HttpUploadedFile(){ } /** * Factory method */ public static synchronized HttpUploadedFile getInstance(){ if(instance == null){ instance = new HttpUploadedFile(); } return instance; } String url = "http://2.novelread.sinaapp.com/framework-sae/index.php?c=main&a=getPostBody"; private int lastErrCode = 0;// 最近一次出错的错误代码 byte[] tmpBuf = new byte[BUF_LEN]; byte[] tmpBuf2 = new byte[BUF_LEN * 2]; public static final int POST_PROGRESS_NOTIFY = 101; HttpURLConnection connection = null; public static final int HTTP_ARGUMENT_ERR = -1001;// HTTP 参数错误 public static final int HTTP_RESPONSE_EMPTY = -1002;// Http Response is // Empty public static final int HTTP_URL_ERR = -1003;// Url格式错误 public static final int HTTP_GZIP_ERR = -1004;// 响应数据解压缩失败 public static final int HTTP_CANCELED = -1005;// 当前下载已取消 public static final int HTTP_EXCEPTION = -1006;// 发生异常 private boolean bIsStop = false; protected Object objAbort = new Object(); private Handler mHandler = null; public static final int TIMEOUT = 30000;// 超时时间30秒 private static final int BUF_LEN = 512;// 数据缓冲长度 public boolean doUploadPhoto(Context context, String filePathName, Handler handler) { boolean ret = false; File file = new File(filePathName); if (!file.exists()) { return false; } FileInputStream fs = null; if (file != null) { try { fs = new FileInputStream(file); } catch (FileNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (file == null || fs == null) { return false; } mHandler = handler; ret = postWithoutResponse(context, url, fs, (int) file.length()); if (fs != null) { try { fs.close(); fs = null; } catch (Exception e) { } } return ret; } public Boolean postWithoutResponse(Context context, final String strUrl, InputStream dataStream, int iStreamLen) { <strong> //<span style="font-family: Arial, Helvetica, sans-serif;">iStreamLen是FIle的大写,以字节作为单位</span></strong> if (TextUtils.isEmpty(strUrl) || dataStream == null || iStreamLen <= 0) { lastErrCode = HTTP_ARGUMENT_ERR; return false; } URL postUrl = null; try { postUrl = new URL(strUrl); } catch (MalformedURLException ex) { Log.e("HttpUtil", "get MalformedURL", ex); lastErrCode = HTTP_URL_ERR; return false; } bIsStop = false; InputStream input = null; DataOutputStream ds = null; ByteArrayOutputStream byteOutStream = null; HttpURLConnection conn = null; byte[] outData = null; try { if (bIsStop) { lastErrCode = HTTP_CANCELED; return false; } conn = getConnection(context, postUrl); connection = conn; conn.setRequestMethod("POST"); conn.setDoInput(true); conn.setDoOutput(true); conn.setConnectTimeout(TIMEOUT * 3); conn.setReadTimeout(TIMEOUT * 3); conn.setRequestProperty("Connection", "Keep-Alive"); conn.setRequestProperty("Content-Type", "application/octet-stream"); conn.setRequestProperty("Content-Length", String.valueOf(iStreamLen)); if (bIsStop) { lastErrCode = HTTP_CANCELED; return false; } // get the wifi status WifiManager wifiManager = (WifiManager) context .getSystemService(Context.WIFI_SERVICE); boolean bWifiEnable = (wifiManager.getWifiState() == WifiManager.WIFI_STATE_ENABLED); // byte[] data = new byte[BUF_LEN]; ds = new DataOutputStream(conn.getOutputStream()); int len = 0; int postLen = 0; int nMaxProgress = bWifiEnable ? 80 : 40; while (!bIsStop && ((len = dataStream.read(tmpBuf2)) != -1)) {<strong>//如果bIsStop为true,则下面写文件到服务器的过程会终止</strong> ds.write(tmpBuf2, 0, len); ds.flush(); // waiting for uploading the image file to optimize the progress // bar when using GPRS if (!bWifiEnable) { Thread.sleep(30); } // notify post progress postLen += len; if (mHandler != null) { Message msg = new Message(); msg.what = POST_PROGRESS_NOTIFY; <strong>msg.arg1 = (postLen * nMaxProgress) / iStreamLen;//postLen是已经上传的文件大小,</strong><pre name="code" class="java">nMaxProgress 的作用上增快进度条mHandler.sendMessage(msg);}}if (bIsStop) {lastErrCode = HTTP_CANCELED;return false;}ds.flush();// waiting for uploading the image file to optimize the progress bar// when using GPRSif (!bWifiEnable) {postLen = 0;while (postLen < iStreamLen) {Thread.sleep(30);// notify post progresspostLen += tmpBuf2.length;if (mHandler != null) {Message msg = new Message();msg.what = POST_PROGRESS_NOTIFY;msg.arg1 = (postLen * 35) / iStreamLen + 50;mHandler.sendMessage(msg);}}}// waiting for the server‘s responseInputStream is = conn.getInputStream();int ch;StringBuffer res = new StringBuffer();while ((ch = is.read()) != -1) {res.append((char) ch);}if (mHandler != null) {Message msg = new Message();msg.what = POST_PROGRESS_NOTIFY;msg.arg1 = 90;mHandler.sendMessage(msg);}return true;} catch (Exception ex) {Log.e("HttpUtil", "post", ex);if (bIsStop) {lastErrCode = HTTP_CANCELED;} else {lastErrCode = HTTP_EXCEPTION;}return false;} finally {try {outData = null;if (input != null) {input.close();input = null;}// if (ds != null){// ds.close();// ds = null;// }try {ds.close();ds = null;} catch (Exception e) {// TODO: handle exception}if (conn != null) {conn.disconnect();conn = null;}if (byteOutStream != null) {byteOutStream.close();byteOutStream = null;}if (bIsStop) { //如果终止完成后会通知cancel那个方法synchronized (objAbort) {objAbort.notify();}}if (mHandler != null) {Message msg = new Message();msg.what = POST_PROGRESS_NOTIFY;msg.arg1 = 100;mHandler.sendMessage(msg);}} catch (Exception ex) {Log.e("HttpUtil", "post finally", ex);}}}public synchronized void cancel() {try {bIsStop = true;//用户点击了cancel button,这个设置bIsStop为trueif (connection != null) {connection.disconnect();connection = null;}synchronized (objAbort) { //只有
postWithoutResponse执行到finally才通知可以执行完这个函数objAbort.wait(50);}} catch (Exception ex) {Log.v("HttpUtil", "canel", ex);}}private HttpURLConnection getConnection(Context context, URL url)throws Exception {String[] apnInfo = null;WifiManager wifiManager = (WifiManager) context.getSystemService(Context.WIFI_SERVICE);int wifiState = wifiManager.getWifiState();HttpURLConnection conn = null;conn = (HttpURLConnection) url.openConnection();//获取http的连接return conn;}}
android一个上传图片的例子,包括如何终止上传过程,如果在上传的时候更新进度条(二),布布扣,bubuko.com
android一个上传图片的例子,包括如何终止上传过程,如果在上传的时候更新进度条(二)
原文地址:http://blog.csdn.net/baidu_nod/article/details/38467025