Android教程網
  1. 首頁
  2. Android 技術
  3. Android 手機
  4. Android 系統教程
  5. Android 游戲
 Android教程網 >> Android技術 >> 關於Android編程 >> Android開發之使用HTTP訪問網絡資源

Android開發之使用HTTP訪問網絡資源

編輯:關於Android編程

使用HTTP訪問網絡資源

前面介紹了 URLConnection己經可以非常方便地與指定站點交換信息,URLConnection還有一個子類:HttpURLConnection,HttpURLConnection 在 LIRLConnection的基礎上做了進一步改進,增加了一些用於操作http資源的便捷方法。

1.使用HttpURLConnection

HttpURLConnection繼承了URLConnection,因此也可用於向指定網站發送GET請求 POST請求。它在URLConnection的基礎上提供了如下便捷的方法。

1) Int getResponseCode():獲取服務器的響應代碼。

2) String getResponseMessage():獲取服務器的響應消息。

3) String getRequestMethod():獲取發送請求的方法。

4) void setRequestMethod(String method):設置發送請求的方法。

下面通過個實用的示例來示范使用HttpURLConnection實現多線程下載。

1.1實例:多線程下載

使用多線程下載文件可以更快地完成文件的下載,因為客戶端啟動多個線程進行下寒意味著服務器也需要為該客戶端提供相應的服務。假設服務器同時最多服務100個用戶,服務器中一條線程對應一個用戶,100條線程在計算機內並發執行,也就是由CPU劃分史 片輪流執行,如果A應用使用了 99條線程下載文件,那麼相當於占用了 99個用戶的資源自然就擁有了較快的下載速度。

提示:實際上並不是客戶端並發的下載線程越多,程序的下載速度就越快,因為當客戶端開啟太多的並發線程之後,應用程序需要維護每條線程的開銷、線程同步的開銷,這些開銷反而會導致下載速度降低.

1.2為了實現多線程下載,程序可按如下步驟進行:

? 創建URL對象。

? 獲取指定URL對象所指向資源的大小(由getContentLength()方法實現),此處用了 HttpURLConnection 類。

? 在本地磁盤上創建一個與網絡資源相同大小的空文件。

? 計算每條線程應該下載網絡資源的哪個部分(從哪個字節開始,到哪個字節結束,依次創建、啟動多條線程來下載網絡資源的指定部分。

1.2該程序提供的下載工具類代碼如下。

package com.jph.net;

import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;

/**
 * Description:
 * 創建ServerSocket監聽的主類
 * @author  jph
 * Date:2014.08.27
 */
public class DownUtil
{
	/**下載資源的路徑**/ 
	private String path;
	/**下載的文件的保存位置**/ 
	private String targetFile;
	/**需要使用多少線程下載資源**/  
	private int threadNum;
	/**下載的線程對象**/  
	private DownThread[] threads;
	/**下載的文件的總大小**/ 
	private int fileSize;

	public DownUtil(String path, String targetFile, int threadNum)
	{
		this.path = path;
		this.threadNum = threadNum;
		// 初始化threads數組
		threads = new DownThread[threadNum];
		this.targetFile = targetFile;
	}

	public void download() throws Exception
	{
		URL url = new URL(path);
		HttpURLConnection conn = (HttpURLConnection) url.openConnection();
		conn.setConnectTimeout(5 * 1000);
		conn.setRequestMethod("GET");
		conn.setRequestProperty(
			"Accept",
			"image/gif, image/jpeg, image/pjpeg, image/pjpeg, "
			+ "application/x-shockwave-flash, application/xaml+xml, "
			+ "application/vnd.ms-xpsdocument, application/x-ms-xbap, "
			+ "application/x-ms-application, application/vnd.ms-excel, "
			+ "application/vnd.ms-powerpoint, application/msword, */*");
		conn.setRequestProperty("Accept-Language", "zh-CN");
		conn.setRequestProperty("Charset", "UTF-8");
		conn.setRequestProperty("Connection", "Keep-Alive");
		// 得到文件大小
		fileSize = conn.getContentLength();
		conn.disconnect();
		int currentPartSize = fileSize / threadNum + 1;
		RandomAccessFile file = new RandomAccessFile(targetFile, "rw");
		// 設置本地文件的大小
		file.setLength(fileSize);
		file.close();
		for (int i = 0; i < threadNum; i++)
		{
			// 計算每條線程的下載的開始位置
			int startPos = i * currentPartSize;
			// 每個線程使用一個RandomAccessFile進行下載
			RandomAccessFile currentPart = new RandomAccessFile(targetFile,
				"rw");
			// 定位該線程的下載位置
			currentPart.seek(startPos);
			// 創建下載線程
			threads[i] = new DownThread(startPos, currentPartSize,
				currentPart);
			// 啟動下載線程
			threads[i].start();
		}
	}

	// 獲取下載的完成百分比
	public double getCompleteRate()
	{
		// 統計多條線程已經下載的總大小
		int sumSize = 0;
		for (int i = 0; i < threadNum; i++)
		{
			sumSize += threads[i].length;
		}
		// 返回已經完成的百分比
		return sumSize * 1.0 / fileSize;
	}

	private class DownThread extends Thread
	{
		/**當前線程的下載位置**/ 
		private int startPos;
		/**定義當前線程負責下載的文件大小**/ 
		private int currentPartSize;
		/**當前線程需要下載的文件塊**/ 
		private RandomAccessFile currentPart;
		/**定義該線程已下載的字節數**/ 
		public int length;

		public DownThread(int startPos, int currentPartSize,
			RandomAccessFile currentPart)
		{
			this.startPos = startPos;
			this.currentPartSize = currentPartSize;
			this.currentPart = currentPart;
		}

		@Override
		public void run()
		{
			try
			{
				URL url = new URL(path);
				HttpURLConnection conn = (HttpURLConnection)url
					.openConnection();
				conn.setConnectTimeout(5 * 1000);
				conn.setRequestMethod("GET");
				conn.setRequestProperty(
					"Accept",
					"image/gif, image/jpeg, image/pjpeg, image/pjpeg, "
					+ "application/x-shockwave-flash, application/xaml+xml, "
					+ "application/vnd.ms-xpsdocument, application/x-ms-xbap, "
					+ "application/x-ms-application, application/vnd.ms-excel, "
					+ "application/vnd.ms-powerpoint, application/msword, */*");
				conn.setRequestProperty("Accept-Language", "zh-CN");
				conn.setRequestProperty("Charset", "UTF-8");
				InputStream inStream = conn.getInputStream();
				// 跳過startPos個字節,表明該線程只下載自己負責哪部分文件。
				inStream.skip(this.startPos);
				byte[] buffer = new byte[1024];
				int hasRead = 0;
				// 讀取網絡數據,並寫入本地文件
				while (length < currentPartSize
					&& (hasRead = inStream.read(buffer)) > 0)
				{
					currentPart.write(buffer, 0, hasRead);
					// 累計該線程下載的總大小
					length += hasRead;
				}
				currentPart.close();
				inStream.close();
			}
			catch (Exception e)
			{
				e.printStackTrace();
			}
		}
	}
}

上而的DownUtil工具類中包括一個DownloadThread內部類,該內部類的run()方法中負責打開遠程資源的輸入流,並調用inputStream的skip(int)方法跳過指定數量的字節,這樣就讓該線程讀取由它自己負責下載的部分。

提供了上面的DownUtil工具類之後,接下來就可以在Activity中調用該DownUtil類來執行下載任務,該程序界面中包含兩個文本框,一個用於輸入網絡文件的源路徑,另一個用於指定下載到本地的文件的文件名,該程序的界面比較簡單,故此處不再給出界面布局代碼。該程序的Activity代碼如下。

package com.jph.net;

import java.util.Timer;
import java.util.TimerTask;
import android.app.Activity;
import android.content.Context;
import android.os.Bundle;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ProgressBar;
import android.widget.Toast;

/**
 * Description:
 * 多線程下載
 * @author  jph
 * Date:2014.08.27
 */
public class MultiThreadDown extends Activity
{
	EditText url;
	EditText target;
	Button downBn;
	ProgressBar bar;
	DownUtil downUtil;
	private int mDownStatus;

	@Override
	public void onCreate(Bundle savedInstanceState)
	{
		super.onCreate(savedInstanceState);
		setContentView(R.layout.main);
		// 獲取程序界面中的三個界面控件
		url = (EditText) findViewById(R.id.url);
		target = (EditText) findViewById(R.id.target);
		downBn = (Button) findViewById(R.id.down);
		bar = (ProgressBar) findViewById(R.id.bar);
		// 創建一個Handler對象
		final Handler handler = new Handler()
		{
			@Override
			public void handleMessage(Message msg)
			{
				if (msg.what == 0x123)
				{
					bar.setProgress(mDownStatus);
				}
			}
		};
		downBn.setOnClickListener(new OnClickListener()
		{
			@Override
			public void onClick(View v)
			{
				// 初始化DownUtil對象(最後一個參數指定線程數)
				downUtil = new DownUtil(url.getText().toString(),
					target.getText().toString(), 6);
				new Thread()
				{
					@Override
					public void run()
					{
						try
						{
							// 開始下載
							downUtil.download();
						}
						catch (Exception e)
						{
							e.printStackTrace();
						}
						// 定義每秒調度獲取一次系統的完成進度
						final Timer timer = new Timer();
						timer.schedule(new TimerTask()
						{
							@Override
							public void run()
							{
								// 獲取下載任務的完成比率
								double completeRate = downUtil.getCompleteRate();
								mDownStatus = (int) (completeRate * 100);
								// 發送消息通知界面更新進度條
								handler.sendEmptyMessage(0x123);
								// 下載完全後取消任務調度
								if (mDownStatus >= 100)
								{
									showToastByRunnable(MultiThreadDown.this, "下載完成", 2000);
									timer.cancel();
								}
							}
						}, 0, 100);
					}
				}.start();
			}
		});
	}
	/**
	 * 在非UI線程中使用Toast
	 * @param context 上下文
	 * @param text 用以顯示的消息內容
	 * @param duration 消息顯示的時間
	 * */
	private void showToastByRunnable(final Context context, final CharSequence text, final int duration) {
	    Handler handler = new Handler(Looper.getMainLooper());
	    handler.post(new Runnable() {
	        @Override
	        public void run() {
	            Toast.makeText(context, text, duration).show();
	        }
	    });
	}
}

上面的Activity不僅使用了 DownUtil來控制程序下載,而且程序還啟動了一個定時器,該定時器控制每隔0.1秒査詢一次下載進度,並通過程序中的進度條來顯示任務的下載進度。

該程序不僅需要訪問網絡,還需要訪問系統SD卡,在SD卡中創建文件,因此必須授予該程序訪問網絡、訪問SD卡文件的權限:







程序運行效果圖:

Android多線程下載

下載到SD的資源

提示:上面的程序已經實現了多線程下載的核心代碼,如果要實現斷點下載,則還需要額外增加一個配置文件(大家可以發現所有斷點下載工具都會在下載開始生成兩個文件:一個是與網絡資源相同大小的空文件,一個是配置文件),該配置文件分別記錄每個線程已經下載到了哪個字節,當網絡斷開後再次開始下載時,每個線程根據配置文件裡記錄的位置向後下載即可。

2 使用ApacheHttpClient

在一般情況下,如果只是需要向Web站點的某個簡單頁面提交請求並獲取服務器響應, 完全可以使用前面所介紹的HttpURLConnection來完成。但在絕大部分情況下,Web站點的網頁可能沒這麼簡單,這些頁面並不是通過一個簡單的URL就可訪問的,可能需要用戶登錄而且具有相應的權限才可訪問該頁面。在這種情況下,就需要涉及Session、Cookie的處理了,如果打算使用HttpURLConnection來處理這些細節,當然也是可能實現的,只是處理起來難度就大了。

為了更好地處理向Web站點請求,包括處理Session、Cookie等細節問題,Apache開源組織提供了一個HttpClient項目,看它的名稱就知道,它是一個簡單的HTTP客戶端(並不是浏覽器),可以用於發送HTTP請求,接收HTTP響應。但不會緩存服務器的響應,不能執行HTML頁面中嵌入的JavaScript代碼;也不會對頁面內容進行任何解析、處理。

提示:簡單來說,HttpClient就是一個增強版的HttpURLConnection ,HttpURLConnection 可以做的事情 HttpClient 全部可以做;HttpURLConnection沒有提供的有些功能,HttpClient也提供了,但它只是關注於如何發送請求、接收響應,以及管理HTTP連接。|

Android集成了HttpClient,開發人員可以直接在Android應用中使用HttpCHent來訪問提交請求、接收響應。

2.1使用HttpClient發送清求、接收響應很簡單,只要如下幾步即可:

1) 創建HttpClient對象。

2) 如果需要發送GET請求,創建HttpGet對象;如果需要發送POST 求,創建HttpPost對象。

3) 如果需要發送請求參數,可調用HttpGet、HttpPost共同的setParams(HttpParams params)方法來添加請求參數;對於HttpPost對象而言,也可調用setEntity(HttpEntityentity)方法來設置請求參數。

4) 調用HttpClient對象的execute(HttpUriRequestrequest)發送請求,執行該方法返回一 個 HttpResponse。

5) 調用HttpResponse的getAllHeaders()、getHeaders(String name)等方法可獲取服務器的響應頭;調用HttpResponse的getEntity()方法可獲取HttpEntity對象,該對象包裝了服務器的響應內容。程序可通過該對象獲取服務器的響應內容。

2.2實例:訪問被保護資源

下面的Android應用需要向指定頁面發送請求,但該頁面並不是一個簡單的頁面,只有 當用戶已經登錄,而且登錄用戶的用戶名是jph時才可訪問該頁面。如果使用HttpUrlConnection來訪問該頁面,那麼需要處理的細節就太復雜了。下面將會借助於 HttpClient來訪問被保護的頁面。

訪問Web應用中被保護的頁面,如果使用浏覽器則十分簡單,用戶通過系統提供的登錄頁面登錄系統,浏覽器會負責維護與服務器之間的Session,如果用戶登錄的用戶名、密碼符合要求,就可以訪問被保護資源了。

為了通過HttpClient來訪問被保護頁面,程序同樣需要使用HttpClient來登錄系統,只要應用程序使用同一個HttpClient發送請求,HttpClient會自動維護與服務器之間的Session狀態,也就是說程序第一次使用HttpCHent登錄系統後,接下來使用HttpCHent即可訪問被保護頁面了。

提示:雖然此處給出的實例只是訪問被保護的頁面,但訪問其他被保護的資源也與此類似,程序只要第一次通過HttpClient登錄系統,接下來即可通過該HttpClient訪問被保護資源了。

2.3程序代碼:

package com.jph.net;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import android.app.Activity;
import android.app.AlertDialog;
import android.content.DialogInterface;
import android.os.Bundle;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.text.Html;
import android.view.View;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
/**
 * Description:
 * 使用HttpClient訪問受保護的網絡資源
 * @author  jph
 * Date:2014.08.28
 */
public class HttpClientDemo extends Activity
{
	TextView response;
	HttpClient httpClient;
	Handler handler = new Handler()
	{
		public void handleMessage(Message msg)
		{
			if(msg.what == 0x123)
			{
				// 使用response文本框顯示服務器響應
				response.append(Html.fromHtml(msg.obj.toString()) + "\n");
			}
		}
	};
	@Override
	public void onCreate(Bundle savedInstanceState)
	{
		super.onCreate(savedInstanceState);
		setContentView(R.layout.main);
		// 創建DefaultHttpClient對象
		httpClient = new DefaultHttpClient();
		response = (TextView) findViewById(R.id.response);
	}
	/**
	 * 此方法用於響應“訪問頁面”按鈕
	 * */
	public void accessSecret(View v)
	{
		response.setText("");
		new Thread()
		{
			@Override
			public void run()
			{
				// 創建一個HttpGet對象
				HttpGet get = new HttpGet(
					"http://10.201.1.32:8080/HttpClientTest_Web/secret.jsp");  //①
				try
				{
					// 發送GET請求
					HttpResponse httpResponse = httpClient.execute(get);//②
					HttpEntity entity = httpResponse.getEntity();
					if (entity != null)
					{
						// 讀取服務器響應
						BufferedReader br = new BufferedReader(
							new InputStreamReader(entity.getContent()));
						String line = null;
						
						while ((line = br.readLine()) != null)
						{
							Message msg = new Message();
							msg.what = 0x123;
							msg.obj = line;
							handler.sendMessage(msg);
						}
					}
				}
				catch (Exception e)
				{
					e.printStackTrace();
				}
			}
		}.start();
	}
	/**
	 * 此方法用於響應“登陸系統”按鈕
	 * */
	public void showLogin(View v)
	{
		// 加載登錄界面
		final View loginDialog = getLayoutInflater().inflate(
			R.layout.login, null);
		// 使用對話框供用戶登錄系統
		new AlertDialog.Builder(HttpClientDemo.this)
			.setTitle("登錄系統")
			.setView(loginDialog)
			.setPositiveButton("登錄",
			new DialogInterface.OnClickListener()
			{
				@Override
				public void onClick(DialogInterface dialog,
					int which)
				{
					// 獲取用戶輸入的用戶名、密碼
					final String name = ((EditText) loginDialog
						.findViewById(R.id.name)).getText()
						.toString();
					final String pass = ((EditText) loginDialog
						.findViewById(R.id.pass)).getText()
						.toString();
					new Thread()
					{
						@Override
						public void run()
						{
							try
							{
								HttpPost post = new HttpPost("http://10.201.1.32:8080/" +
										"HttpClientTest_Web/login.jsp");//③
								// 如果傳遞參數個數比較多的話可以對傳遞的參數進行封裝
								List params = new
									ArrayList();
								params.add(new BasicNameValuePair
									("name", name));
	
								
								
								params.add(new BasicNameValuePair
									("pass", pass));								
								// 設置請求參數
								post.setEntity(new UrlEncodedFormEntity(
									params, HTTP.UTF_8));
								// 發送POST請求
								HttpResponse response = httpClient
									.execute(post);  //④
								// 如果服務器成功地返回響應
								if (response.getStatusLine()
									.getStatusCode() == 200)
								{
									String msg = EntityUtils
										.toString(response.getEntity());
									Looper.prepare();
									// 提示登錄成功
									Toast.makeText(HttpClientDemo.this,
										msg, Toast.LENGTH_SHORT).show();
									Looper.loop();
								}
							}
							catch (Exception e)
							{
								e.printStackTrace();
							}
						}
					}.start();
				}
			}).setNegativeButton("取消", null).show();
	}
}

上面的程序中①、②號粗體字代碼先創建了一個HttpGet對象,接下來程序調用HttpClient的execute()方法發送GET請求;程序中③、④號粗體字代碼先創建了一個HttpPost對象,接下來程序調用了HttpClient的execute()方法發送POST請求。上面的GET請求用於獲取服務器上的被保護頁面,POST請求用於登錄系統。

運行該程序,單擊“訪問頁面”按鈕將可看到如下圖所示的頁面。

fail

從上圖可以看出,程序直接向指定Web應用的被保護頁面secret.jsp發送請求,程序將無法訪問被保護頁面,於是看到下圖所示的頁面。單擊下圖所示頁面中的“登錄”按鈕,系統將會顯示如下圖所示的登錄對話框。

在上圖所示對話框的兩個輸入框中分別輸入“jph”、“123”,然後單擊“登錄”按鈕,系統將會向Web站點的login.jsp頁面發送POST請求,並將用戶輸入的用戶名、密碼作為請求參數。如果用戶名、密碼正確,即可看到登錄成功的提示。

success

登錄成功後,HttpClient將會自動維護與服務器之間的連接,並維護與服務器之間的Session狀態,再次單擊程序中的“訪問頁面”按鈕,即可看到如下圖所示的輸出。

安全資源

從上圖可以看出,此時使用HttpClient發送GET請求即可正常訪問被保護資源,這就是因為前面使用了HttpClient登錄了系統,而且HttpClient可以維護與服務器之間的Session連接。

從上面的編程過程不難看出,使用Apache的HttpClient更加簡單,而且它比HttpURLConnection提供了更多的功能。

  1. 上一頁:
  2. 下一頁:
熱門文章
閱讀排行版
Copyright © Android教程網 All Rights Reserved