安卓基础干货(五)：安卓线程与数据上传下载的学习

使用POST方式提交数据时的中文乱码解决方法（重点）

解决办法：使用客户端和服务器两边的字符集编码保持一致。
UTF-8，

使用GET方式提交数据的中文乱码的解决方法

使用URLEncoder.encode(name,"UTF-8")进行url编码：
String path = "http://192.168.22.136:8080/web/servlet/LoginServlet?username="+URLEncoder.encode(name,"UTF-8")+"&password="+URLEncoder.encode(pwd,"UTF-8");

使用httpclient提交数据（重点）

apache httpClient 轻量级的浏览器：

• 使用GET方式数据步骤：

   1、创建一个浏览器：
  
   2、输入一个网址：
  
   3、敲回车
  

模块代码：

	package com.itheima.qqlogin;

	import java.io.InputStream;
	import java.net.HttpURLConnection;
	import java.net.URL;
	import java.net.URLEncoder;
	
	import org.apache.http.HttpResponse;
	import org.apache.http.client.HttpClient;
	import org.apache.http.client.methods.HttpGet;
	import org.apache.http.impl.client.DefaultHttpClient;
	
	import com.itheima.htmlview.utils.StreamTools;
	
	import android.app.Activity;
	import android.os.Bundle;
	import android.text.TextUtils;
	import android.view.View;
	import android.widget.EditText;
	import android.widget.Toast;
	
	public class MainActivity extends Activity {

	private EditText et_name;

	private EditText et_pwd;
	@Override
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(R.layout.activity_main);
		
		et_name = (EditText) findViewById(R.id.et_name);

		et_pwd = (EditText) findViewById(R.id.et_pwd);
	
	}

	public void login(View view){
		final String name = et_qq.getText().toString().trim();
		
		final String pwd = et_pwd.getText().toString().trim();
		
		if(TextUtils.isEmpty(name) || TextUtils.isEmpty(pwd)){
			Toast.makeText(this, "qq和密码不能空", 0).show();
			return;
		}else{
			new Thread(){
				
				public void run() {
					
					try {
						String path = "http://192.168.22.136:8080/web/servlet/LoginServlet?username="+URLEncoder.encode(name,"UTF-8")+"&password="+URLEncoder.encode(pwd,"UTF-8");
						
	//					
	//					1、创建一个浏览器：
						HttpClient client = new DefaultHttpClient();
	//				    2、输入一个网址：
						HttpGet httpGet = new HttpGet(path);
	//
	//					3、敲回车
						HttpResponse response = client.execute(httpGet);
						//获取服务器端返回的响应码（状态码）
						int code = 	response.getStatusLine().getStatusCode();
	//					int code = conn.getResponseCode();
						if(code == 200){
	//					4、解析服务器返回的二进制数据，解析成一个字符串
	//						 InputStream is = conn.getInputStream();
							 //获取服务器返回的二进制数据流
							 InputStream is = response.getEntity().getContent();
							 
							 String result = StreamTools.readStream(is);
							 System.out.println("---------"+ result);
						 }

					} catch (Exception e) {
						e.printStackTrace();
					}
				};
			}.start();
		}
	}
     
}

• 使用post方式向服务器端提交数据

   1、创建一个浏览器：
  
   2、输入一个网址：
  
   3、敲回车
  

模版代码：

	package com.itheima.qqlogin;

	import java.io.InputStream;
	import java.net.HttpURLConnection;
	import java.net.URL;
	import java.net.URLEncoder;
	import java.util.ArrayList;
	import java.util.List;

	import org.apache.http.HttpResponse;
	import org.apache.http.client.HttpClient;
	import org.apache.http.client.entity.UrlEncodedFormEntity;
	import org.apache.http.client.methods.HttpPost;
	import org.apache.http.impl.client.DefaultHttpClient;
	import org.apache.http.message.BasicNameValuePair;
	
	import android.app.Activity;
	import android.os.Bundle;
	import android.os.Handler;
	import android.os.Message;
	import android.text.TextUtils;
	import android.view.View;
	import android.widget.EditText;
	import android.widget.Toast;
	
	import com.itheima.htmlview.utils.StreamTools;
	
	public class MainActivity extends Activity {

	private EditText et_qq;

	private EditText et_pwd;
	
	private Handler handler = new Handler(){
		public void handleMessage(android.os.Message msg) {
			
			String result = (String) msg.obj;
			
			Toast.makeText(MainActivity.this, result, 0).show();
		};
	};
	@Override
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(R.layout.activity_main);
		
		et_qq = (EditText) findViewById(R.id.et_qq);

		et_pwd = (EditText) findViewById(R.id.et_pwd);
	
	}

	public void login(View view){
		final String name = et_qq.getText().toString().trim();
		
		final String pwd = et_pwd.getText().toString().trim();
		
		if(TextUtils.isEmpty(name) || TextUtils.isEmpty(pwd)){
			Toast.makeText(this, "qq和密码不能空", 0).show();
			return;
		}else{
			new Thread(){
				
				public void run() {
					
					try {
						String path = "http://192.168.1.196:8080/web/servlet/LoginServlet";
	//					String data = "username="+name+"&password="+pwd;
						
						String data = "username="+URLEncoder.encode(name,"UTF-8")+"&password="+URLEncoder.encode(pwd,"UTF-8");
						
	//					1、创建一个浏览器：

						HttpClient client = new DefaultHttpClient();
	//					2、输入一个网址：
						HttpPost httpPost = new HttpPost(path);	
						List<BasicNameValuePair> parameters = new ArrayList<BasicNameValuePair>();
						
						BasicNameValuePair p1 = new BasicNameValuePair("username", name);
						
						BasicNameValuePair p2 = new BasicNameValuePair("password", pwd);
						parameters.add(p1);
						parameters.add(p2);
						//默认使用iso-8859-1编码，需要指定UTF-8
						UrlEncodedFormEntity entity = new UrlEncodedFormEntity(parameters,"UTF-8");
						
	//					3、敲回车
						//设置提交的数据
						httpPost.setEntity(entity);
						HttpResponse  response = client.execute(httpPost);
						 
	//				    4、服务器返回数据
	//				    （1）判断状态码：200 ok，404 没有找到资源、503、509 服务器端错误
						 int code =  response.getStatusLine().getStatusCode();
	//						 int code = conn.getResponseCode();
						 if(code == 200){
	//					 (2）解析服务器返回的二进制数据，解析成一个字符串
							 InputStream is = response.getEntity().getContent();	  
							 String result = StreamTools.readStream(is);
							 System.out.println("---------"+ result);
							 
							 Message msg = Message.obtain();
							 msg.obj = result;
							 handler.sendMessage(msg);
						 }

						
					} catch (Exception e) {
						e.printStackTrace();
					}
				};
			}.start();
		}
	}
     
	}

使用Aynchttpclient向服务器端提交数据（重点）

1、创建一个浏览器：

2、输入一个网址：

3、敲回车

• 使用GET方式向服务器端提交数据

   package com.itheima.qqlogin;
   
   import java.io.InputStream;
   import java.net.HttpURLConnection;
   import java.net.URL;
   import java.net.URLEncoder;
   
   import org.apache.http.Header;
   
   import com.itheima.htmlview.utils.StreamTools;
   import com.loopj.android.http.AsyncHttpClient;
   import com.loopj.android.http.AsyncHttpResponseHandler;
   
   import android.app.Activity;
   import android.os.Bundle;
   import android.text.TextUtils;
   import android.view.View;
   import android.widget.EditText;
   import android.widget.Toast;
   
   public class MainActivity extends Activity {
   
   	private EditText et_name;
   
   	private EditText et_name;
   	@Override
   	protected void onCreate(Bundle savedInstanceState) {
   		super.onCreate(savedInstanceState);
   		setContentView(R.layout.activity_main);
   		
   		et_qq = (EditText) findViewById(R.id.et_qq);
   
   		et_pwd = (EditText) findViewById(R.id.et_pwd);
   	
   	}
   
   	public void login(View view){
   		final String name = et_qq.getText().toString().trim();
   		
   		final String pwd = et_pwd.getText().toString().trim();
   		
   		if(TextUtils.isEmpty(name) || TextUtils.isEmpty(pwd)){
   			Toast.makeText(this, "qq和密码不能空", 0).show();
   			return;
   		}else{	
   				try {
   					String path = "http://192.168.1.103:8080/web/servlet/LoginServlet?username="+URLEncoder.encode(name,"UTF-8")+"&password="+URLEncoder.encode(pwd,"UTF-8");
                    //1、创建一个浏览器： 
   					AsyncHttpClient client = new AsyncHttpClient();
   					//2、输入网址，调用get方式向服务器发送请求：
   					client.get(path, new AsyncHttpResponseHandler() {
   								
                        /*
                         * 请求成功，服务器端正常响应 响应码200
                     	  * statusCode 响应码200ok，404没有找到资源，503服务器内部错误, Header[] headers 响应头信息, byte[] responseBody 服务器返回的数据
                     	  */
   				     @Override
   					  public void onSuccess(int statusCode, Header[] headers, byte[] responseBody) {
   								Toast.makeText(MainActivity.this, new String(responseBody), 0).show();
   							}
   							
   					  		/*
                     	   * 请求成功，服务器端正常响应 响应码200
                     	   * int statusCode, Header[] headers, byte[] responseBody, Throwable error
                     	   * statusCode 响应码200ok，404没有找到资源，503服务器内部错误, Header[] headers 响应头信息, byte[] responseBody 服务器返回的数据
                     	   * Throwable error 服务器端返回的异常
                     	   */
   						@Override
   						public void onFailure(int statusCode, Header[] headers, byte[] responseBody, Throwable arg3) {
   							Toast.makeText(MainActivity.this, new String(responseBody), 0).show();
   						}
   					});
   				} catch (Exception e) {
   					e.printStackTrace();
   				}
   			};
   		
   	}
   }
  

• 使用POST方式向服务器端提交数据

   package com.itheima.qqlogin;
   import java.io.InputStream;
   import java.io.UnsupportedEncodingException;
   import java.net.HttpURLConnection;
   import java.net.URL;
   import java.net.URLEncoder;
   
   import org.apache.http.Header;
   
   import android.app.Activity;
   import android.os.Bundle;
   import android.os.Handler;
   import android.os.Message;
   import android.text.TextUtils;
   import android.view.View;
   import android.widget.EditText;
   import android.widget.Toast;
   
   import com.itheima.htmlview.utils.StreamTools;
   import com.loopj.android.http.AsyncHttpClient;
   import com.loopj.android.http.AsyncHttpResponseHandler;
   import com.loopj.android.http.RequestParams;
   
   public class MainActivity extends Activity {
   
   	private EditText et_qq;
   
   	private EditText et_pwd;
   	
   	private Handler handler = new Handler(){
   		public void handleMessage(android.os.Message msg) {
   			
   			String result = (String) msg.obj;
   			
   			Toast.makeText(MainActivity.this, result, 0).show();
   		};
   	};
   	@Override
   	protected void onCreate(Bundle savedInstanceState) {
   		super.onCreate(savedInstanceState);
   		setContentView(R.layout.activity_main);
   		
   		et_qq = (EditText) findViewById(R.id.et_qq);
   
   		et_pwd = (EditText) findViewById(R.id.et_pwd);
   	
   	}
   
   	public void login(View view){
   		final String name = et_qq.getText().toString().trim();
   		
   		final String pwd = et_pwd.getText().toString().trim();
   		
   		if(TextUtils.isEmpty(name) || TextUtils.isEmpty(pwd)){
   			Toast.makeText(this, "qq和密码不能空", 0).show();
   			return;
   		}else{
   			try {
   				String path = "http://192.168.22.136:8080/web/servlet/LoginServlet";
   	//			String data = "username="+name+"&password="+pwd;
   				
   	//				String data = "username="+URLEncoder.encode(name,"UTF-8")+"&password="+URLEncoder.encode(pwd,"UTF-8");
   	//				1、创建一个浏览器：
   				AsyncHttpClient client = new AsyncHttpClient();	
   	//				2、输入一个网址,敲回车：
   				RequestParams params = new RequestParams();
   				params.put("username", name);
   				params.put("password", pwd);
   				
   				client.post(path, params, new AsyncHttpResponseHandler() {
   					
   					@Override
   					public void onSuccess(int statusCode, Header[] headers, byte[] responseBody) {
   						Toast.makeText(MainActivity.this, new String(responseBody), 0).show();
   						
   					}
   					
   					@Override
   					public void onFailure(int statusCode, Header[] headers, byte[] responseBody, Throwable e) {
   						Toast.makeText(MainActivity.this, new String("服务器端返回数据失败"), 0).show();
   					}
   				});
   			} catch (Exception e) {
   				e.printStackTrace();
   			}
   		}
   	}     
   	}
  

多线程下载的原理

javase实现多线程

步骤：

1、在客户端创建一个与服务器端大小一样的空白文件
2、设置子线程的个数
3、计算每个子线程下载的数据块大小和下载起始位置、结束位置
4、创建子线程开始下载数据
5、得到每个子线程都下载完成的标记

代码：
MultiThreadDownLoader.java:

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

public class MultiThreadDownLoader {

//2、使用的子线程的个数
private static int threadCount =3;

/**
 * @param args
 */
public static void main(String[] args) {
	try {
		String path = "http://192.168.22.136:8080/sogou.exe";
		URL url = new URL(path);
		HttpURLConnection conn = (HttpURLConnection) url.openConnection();
		conn.setRequestMethod("GET");
		conn.setConnectTimeout(3000);
		
		int code = conn.getResponseCode();
		if(code == 200){
		int length =	conn.getContentLength();
		//1、在客户端创建一个与服务端文件一样大小的文件
		RandomAccessFile file = new RandomAccessFile("temp.exe", "rw");
		file.setLength(length);
		//3、每个子线程下载数据块 ,下载的起始位置和结束位置
		int blockSize = length/threadCount;
		
		// threadId * blockSize  ---- （threadId+1）* blockSize -1
		for(int threadId =0; threadId < threadCount; threadId++){
			//下载的起始位置和结束位置
			int startIndex = threadId * blockSize;
			int endIndex = 0;
			
			if(threadId != (threadCount -1)){
				 endIndex = (threadId + 1) * blockSize - 1;
			}else{
				endIndex = length-1;
			}
			
			//开启子线程下载数据
			new ThreadDownLoader(path, startIndex, endIndex, threadId, threadCount).start();
			
		}
			
		}else{
			//抛出异常
		}
	} catch (Exception e) {
		e.printStackTrace();
	}
}
}

ThreadDownLoader.java:

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


public class ThreadDownLoader extends Thread {

private String path;
private int startIndex;
private int endIndex;
private int threadId;
private int threadCount;
//正在运行的线程个数
private static  int runningThreadCount = 3; 
ThreadDownLoader(String path,int startIndex,int endIndex,int threadId,int threadCount){
	this.path = path;
	this.startIndex = startIndex;
	this.endIndex = endIndex;
	this.threadId = threadId;
	this.threadCount = threadCount;
	
}

@Override
	public void run() {
	  downLoad(path,startIndex,endIndex,threadId,threadCount);
	}


public void downLoad(String path,int startIndex,int endIndex,int threadId,int threadCount)
 {
  try {
	    URL url = new URL(path);
		HttpURLConnection conn = (HttpURLConnection) url.openConnection();
		
		conn.setRequestMethod("GET");
		conn.setConnectTimeout(3000);
		//设置子线程请求数据的范围
		conn.setRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);
		int code = conn.getResponseCode();
		if(code == 206){//请求部分数据
			
		 InputStream is = conn.getInputStream();
		  RandomAccessFile file = new RandomAccessFile("temp.exe","rw");
		  //指定从哪个位置开始写数据
		  file.seek(startIndex);
		  
		   byte[] buffer = new byte[1024];
		  int len = -1;
		  while((len = is.read(buffer)) != -1){
			  file.write(buffer, 0, len);
		  }
		  
		  file.close();
		  System.out.println("线程"+threadId+"下载完成...............");
		  synchronized (ThreadDownLoader.this) {
			  runningThreadCount--;
			  if(runningThreadCount == 0){
				  System.out.println("文件下载完成...............");
			  }
		}
		}
} catch (Exception e) {
	 System.out.println("线程"+threadId+"下载失败...............");
	e.printStackTrace();
}
  
}

}

断点续传下载

1、实时记录线程下载的位置；

2、接上一次下载的位置继续下载；

代码：

import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.channels.ReadableByteChannel;

public class ThreadDownLoader extends Thread {

private String path;
private int startIndex;
private int endIndex;
private int threadId;
private int threadCount;
//正在运行的线程个数
private static  int runningThreadCount = 3; 
ThreadDownLoader(String path,int startIndex,int endIndex,int threadId,int threadCount){
	this.path = path;
	this.startIndex = startIndex;
	this.endIndex = endIndex;
	this.threadId = threadId;
	this.threadCount = threadCount;
	
}

	@Override
	public void run() {
	  downLoad(path,startIndex,endIndex,threadId,threadCount);
	}
	public void downLoad(String path,int startIndex,int endIndex,int threadId,int threadCount){
	  try {
		    URL url = new URL(path);
			HttpURLConnection conn = (HttpURLConnection) url.openConnection();
			
			conn.setRequestMethod("GET");
			conn.setConnectTimeout(3000);
			
			//获取上一次下载的位置，接着下载
			File threadFile = new File(threadId+".txt");
			if(threadFile.exists() && threadFile.length() > 0){
				FileReader fr = new FileReader(threadFile);
				BufferedReader br = new BufferedReader(fr);
				String position = br.readLine();
				//设置子线程请求数据的范围
				conn.setRequestProperty("Range", "bytes="+position+"-"+endIndex);
				startIndex = Integer.valueOf(position);
			}else{
				//设置子线程请求数据的范围
				conn.setRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);
			}
			
			
			int code = conn.getResponseCode();
			if(code == 206){//请求部分数据
				
			 InputStream is = conn.getInputStream();
			  RandomAccessFile file = new RandomAccessFile("temp.exe","rw");
			  //指定从哪个位置开始写数据
			  file.seek(startIndex);
			  
			  byte[] buffer = new byte[1024*1024];
			  int len = -1;
			  int total = 0;
			  while((len = is.read(buffer)) != -1){
				  file.write(buffer, 0, len);
				  total = total + len;
				  int currentPosition = startIndex + total;
				  //能够即时的把数据写到数据
				  RandomAccessFile f = new RandomAccessFile(threadId+".txt", "rwd");
				  f.write((currentPosition+"").getBytes());
				  f.close();
				  
			  }
			  
			  file.close();
			  System.out.println("线程"+threadId+"下载完成...............");
			  synchronized (ThreadDownLoader.this) {
				  runningThreadCount--;
				  if(runningThreadCount == 0){
					  System.out.println("文件下载完成...............");
				  }
			}
			}
	} catch (Exception e) {
		 System.out.println("线程"+threadId+"下载失败...............");
		e.printStackTrace();
	}
  }
}

多线程下载移植到Android项目上（重点）

1、设置布局文件：

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical"
tools:context=".MainActivity" >

<EditText
    android:layout_width="match_parent"
    android:layout_height="wrap_content"
    android:hint="请输入下载的文件网络地址"
    android:id="@+id/et_path" />

<EditText
    android:layout_width="match_parent"
    android:layout_height="wrap_content"
    android:hint="开启几个子线程加速下载"
    android:text="3"
    android:id="@+id/et_threadCount" />

<Button 
    android:layout_width="match_parent"
    android:layout_height="wrap_content"
    android:text="下载"
    android:onClick="downLoad"
    />

</LinearLayout>

2、修改代码：

MainActivity.java:

package com.itheima.multithreaddownload;



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

import android.app.Activity;
import android.os.Bundle;
import android.os.Environment;
import android.text.TextUtils;
import android.view.View;
import android.widget.EditText;
import android.widget.Toast;

public class MainActivity extends Activity {

private EditText et_path;
private EditText et_threadCount;


@Override
protected void onCreate(Bundle savedInstanceState) {
	super.onCreate(savedInstanceState);
	setContentView(R.layout.activity_main);
	
	et_path = (EditText) findViewById(R.id.et_path);

	et_threadCount = (EditText) findViewById(R.id.et_threadCount);
}

public void downLoad(View view){
	
	final String path = et_path.getText().toString().trim();
	

	String threadCountStr = et_threadCount.getText().toString().trim();
	
	
	
	if(TextUtils.isEmpty(path) || TextUtils.isEmpty(threadCountStr)){
		
		Toast.makeText(this, "下载地址或线程个数不能为空", 0).show();
		return;
	}else{
		//
		final int threadCount = Integer.valueOf(threadCountStr);
		
		new Thread(){
			
			public void run() {
				try {
//						String path = "http://192.168.22.136:8080/sogou.exe";
					URL url = new URL(path);
					
					HttpURLConnection conn = (HttpURLConnection) url.openConnection();
					
					conn.setRequestMethod("GET");
					conn.setConnectTimeout(3000);
					
					int code = conn.getResponseCode();
					if(code == 200){
					int length =	conn.getContentLength();
					//1、在客户端创建一个与服务端文件一样大小的文件
					RandomAccessFile file = new RandomAccessFile(Environment.getExternalStorageDirectory()+"/temp.exe", "rw");
					file.setLength(length);
					//3、每个子线程下载数据块 ,下载的起始位置和结束位置
					int blockSize = length/threadCount;
					
					// threadId * blockSize  ---- （threadId+1）* blockSize -1
					for(int threadId =0; threadId < threadCount; threadId++){
						//下载的起始位置和结束位置
						int startIndex = threadId * blockSize;
						int endIndex = 0;
						
						if(threadId != (threadCount -1)){
							 endIndex = (threadId + 1) * blockSize - 1;
						}else{
							endIndex = length-1;
						}
						
						//开启子线程下载数据
						new ThreadDownLoader(path, startIndex, endIndex, threadId, threadCount).start();
						
					}
					
						
					}else{
						//抛出异常
					}
				} catch (Exception e) {
					e.printStackTrace();
				}
			};
		}.start();
	}
}

}

使用xutils实现多线程下载（重点）

1. 导入xutils包

2. 初始化httputils对象

    HttpUtils http = new HttpUtils();
     /**
     * 2 进行下载 
     * url 下载的路径
     * target 存放目标地址 
     * autoResume  是否支持断点续传下载 
     */
    http.download(path, "/mnt/sdcard/feiq.exe", true, new RequestCallBack<File>() {
    	
    	//下载成功的回调
    	@Override
    	public void onSuccess(ResponseInfo<File> responseInfo) {
    		Toast.makeText(getApplicationContext(), "下载成功", 0).show();
    		
    	}
    	
    	//下载失败的回调
    	@Override
    	public void onFailure(HttpException error, String msg) {
    	}
    	//当前进度 
    	@Override
    	public void onLoading(long total, long current, boolean isUploading) {
    		
    		pb.setMax((int) total); //设置进度条的最大值
    		pb.setProgress((int) current);
    		
    		super.onLoading(total, current, isUploading);
    	}
    	
    });