安卓第八天笔记--网络编程二-移动端开发-火龙果软件工程

捐助

安卓第八天笔记--网络编程二

作者：森林森来自于：博客园发布于 2016-3-23

2889 次浏览

1.网络图片查看器

网络图片查看器

1.获取输入的URL地址,判断是否为空

2.建立子线程,获取URl对象new URL(path)

3.打开连接获取HttpURLConnection conn = (HttpURLConnection) url.openConnection();

4.设置连接超时时间conn.setConnectionTimeOut(5000)毫秒

5.设置请求方式setRequestMethod

GET或者POST要大写

6.获取响应码 conn.getResponseCode()

7.判断是不是200,是200就一切正常

8.获取conn.getInputStream() ,

9.使用BitmapFactory.decode(in),将流转换为Bitmap对象

10.使用Message msg = Message.obtain(),

11.设置msg.what是int 类型用来表示标识

符如SUCCESS,ERROR 与msg.obj为Object类型msg.obj=bitmap,用来传递数据

12.handler.sendMessage(msg)发送给主线程的Handler对象

13.主线程中Handler handler = newHandler(){

重写handleMessage方法判断msg.what,做主线程中的UI更新或者提示用户错误信息}

14.添加网络权限Internet

布局

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"

android:layout_width="match_parent"

android:layout_height="match_parent"

android:orientation="vertical" >

<EditText

android:id="@+id/et_path"

android:layout_width="wrap_content"

android:layout_height="wrap_content"

android:text="http://188.188.3.79:8080/itest/test.png" />

<Button

android:onClick="display"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:text="显示图片"/>

<ImageView

android:id="@+id/iv_show"

android:layout_width="match_parent"

android:layout_height="match_parent"/>

</LinearLayout>

Activity

* 网络图片查看器

* 1.获取输入的URL地址,判断是否为空

* 2.建立子线程,获取URl对象new URL(path)

* 3.打开连接获取HttpURLConnection conn = (HttpURLConnection) url.openConnection();

* 4.设置连接超时时间conn.setConnectionTimeOut(5000)毫秒

* 5.设置请求方式setRequestMethod

* GET或者POST要大写

* 6.获取响应码 conn.getResponseCode()

* 7.判断是不是200,是200就一切正常

* 8.获取conn.getInputStream() ,

* 9.使用BitmapFactory.decode(in),将流转换为Bitmap对象

* 10.使用Message msg = Message.obtain(),

* 11.设置msg.what是int 类型用来表示标识

* 符如SUCCESS,ERROR 与msg.obj为Object类型msg.obj=bitmap,用来传递数据

* 12.handler.sendMessage(msg)发送给主线程的Handler对象

* 13.主线程中Handler handler = newHandler(){

* 重写handleMessage方法判断msg.what,做主线程中的UI更新或者提示用户错误信息

* }

* 14.添加网络权限Internet

public class MainActivity extends Activity {

* 标识常量

protected static final int ERROR = 0;

protected static final int SUCCESS = 1;

* 用户输入的url地址

private EditText et_path;

* 显示图片

private ImageView iv_show;

* Handler 处理

private Handler handler;

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.activity_main);

* 用户输入的url地址

et_path = (EditText) findViewById(R.id.et_path);

* 显示图片

iv_show = (ImageView) findViewById(R.id.iv_show);

* 13.主线程中Handler handler = newHandler(){

* 重写handleMessage方法判断msg.what,做主线程中的UI更新或者提示用户错误信息

* }

handler = new Handler(){

@Override

public void handleMessage(Message msg) {

switch (msg.what) {

case SUCCESS:

iv_show.setImageBitmap((Bitmap)msg.obj);

break;

case ERROR:

Toast.makeText(MainActivity.this, "网络连接超里", Toast.LENGTH_SHORT).show();

break;

}

};

}

* 显示图片的按键获取用户输入的URL, 并显示在下方

* @param v

* 按键display

public void display(View v) {

// *1.获取输入的URL地址,判断是否为空

final String path = et_path.getText().toString().trim();

if(TextUtils.isEmpty(path)){

Toast.makeText(this, "输入的url路径不能为空", Toast.LENGTH_SHORT).show();

return ;

}

// * 2.建立子线程,获取URl对象new URL(path)

new Thread(new Runnable() {

@Override

public void run() {

try {

// * 3.打开连接获取HttpURLConnection conn = (HttpURLConnection)

URL url = new URL(path);

// url.openConnection();

HttpURLConnection conn= (HttpURLConnection) url.openConnection();

// * 4.设置连接超时时间conn.setConnectionTimeOut(5000)毫秒

conn.setConnectTimeout(5000);

// * 5.设置请求方式setRequestMethod GET或者POST要大写

conn.setRequestMethod("GET");

// * 6.获取响应码 conn.getResponseCode()

int code = conn.getResponseCode();

// * 7.判断是不是200,是200就一切正常

if(code==200){

// * 8.获取conn.getInputStream() ,

InputStream in = conn.getInputStream();

// * 9.使用BitmapFactory.decodeStream(in),将流转换为Bitmap对象

Bitmap bitmap = BitmapFactory.decodeStream(in);

// * 10.使用Message msg = Message.obtain(),

Message msg = Message.obtain();

// * 11.设置msg.what是int 类型用来表示标识符如SUCCESS,ERROR

msg.what=SUCCESS;

// 与msg.obj为Object类型msg.obj=bitmap,用来传递数据

msg.obj=bitmap;

// * 12.handler.sendMessage(msg)发送给主线程的Handler对象

handler.sendMessage(msg);

}else{

sendError();

}

} catch (MalformedURLException e) {

e.printStackTrace();

sendError();

} catch (ProtocolException e) {

e.printStackTrace();

sendError();

} catch (IOException e) {

e.printStackTrace();

sendError();

}

private void sendError() {

Message msg = Message.obtain();

// * 11.设置msg.what是int 类型用来表示标识符如SUCCESS,ERROR

msg.what=ERROR;

// * 12.handler.sendMessage(msg)发送给主线程的Handler对象

handler.sendMessage(msg);

}

}).start();

}

添加网络权限

<uses-permission android:name="android.permission.INTERNET"/>

2.HTMLView查看

布局

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"

android:layout_width="match_parent"

android:layout_height="match_parent"

android:orientation="vertical">

<!--

用户输入的URL -->

<EditText

android:id="@+id/et_path"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:text="http://188.188.3.79:8080/"/>

<Button

android:id="@+id/btn_show"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:text="显示"/>

<ScrollView

android:layout_width="match_parent"

android:layout_height="match_parent">

<TextView

android:id="@+id/tv_result"

android:layout_width="match_parent"

android:layout_height="match_parent"/>

</ScrollView>

</LinearLayout>

流转换工具类


 * 将流转换为字符的工具类

public class StreamUtils {

public static String decode(InputStream in) throws IOException {

ByteArrayOutputStream baos = new ByteArrayOutputStream();

int len =0;

byte [] buf = new byte[1024];

while((len=in.read(buf))!=-1){

baos.write(buf, 0, len);

}

in.close();

baos.close();

return baos.toString();

}

Activitty

* HTML查看器

* 步骤:

* 1.获取用户输入的url

* 2.判断是否为空

* 3.建立子线程

* 4.建立url对象

* 5. 建立HttpURLConnection连接

* 6.设置请求方式,与连接超时

* 7.获取响应码

* 8.判断是否为200

* 9.获取输入流

* 10.解析为字符串

* 11.handler发送message

* 12.主线程中的Handler做更新UI的操作

public class MainActivity extends Activity implements OnClickListener {

protected static final int ERROR = 0;

protected static final int SUCCESS = 1;

* 用户输入的URL

private EditText et_path;

* 输入完成后点击的按键

private Button btn_show;

* 结果显示

private TextView tv_result;

* 消息处理

private Handler handler;

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.activity_main);

* 用户输入的URL

et_path = (EditText) findViewById(R.id.et_path);

* 输入完成后点击的按键

btn_show = (Button) findViewById(R.id.btn_show);

btn_show.setOnClickListener(this);

* 结果显示

tv_result = (TextView) findViewById(R.id.tv_result);

* 消息处理

handler = new Handler(){

@Override

public void handleMessage(Message msg) {

//判断msg.what

switch (msg.what) {

case SUCCESS:

//成功就处理数据

tv_result.setText(msg.obj.toString());

break;

case ERROR:

//失败就提示用户失败

Toast.makeText(MainActivity.this, "网络连接超时", Toast.LENGTH_SHORT).show();

break;

}

};

}

* 单击事件监听器

@Override

public void onClick(View v) {

switch (v.getId()) {

case R.id.btn_show:

display();

break;

}

* 显示图片的方法单击事件

private void display() {

//1.获取用户输入的url

final String path = et_path.getText().toString().trim();

//2.判断是否为空

if(TextUtils.isEmpty(path)){

Toast.makeText(this, "url不能为空", Toast.LENGTH_SHORT).show();

return;

}

//3.建立子线程

new Thread(new Runnable() {

@Override

public void run() {

try {

//4.建立url对象

URL url = new URL(path);

//5. 建立HttpURLConnection连接

HttpURLConnection conn = (HttpURLConnection) url.openConnection();

//6.设置请求方式,与连接超时

conn.setRequestMethod("GET");

conn.setConnectTimeout(5000);

//7.获取响应码

int code = conn.getResponseCode();

//8.判断是否为200

if(code==200){

//9.获取输入流

InputStream in = conn.getInputStream();

//10.解析为字符串

String data = StreamUtils.decode(in);

//是200表示成功设置成功消息

Message msg = Message.obtain();

//设置成功标识

msg.what=SUCCESS;

//传递数据

msg.obj=data;

//发送消息

handler.sendMessage(msg);

}else{

//发送错误消息

sendError();

}

} catch (MalformedURLException e) {

e.printStackTrace();

//发送错误消息

sendError();

} catch (IOException e) {

e.printStackTrace();

//发送错误消息

sendError();

}

private void sendError() {

//错误发送错误消息

Message msg = Message.obtain();

//设置错误标识

msg.what=ERROR;

//发送消息

handler.sendMessage(msg);

}

} ).start();

}

添加网络权限

<uses-permission android:name="android.permission.INTERNET"/>

3.ANR现象:

Anr( application not responding) ---- 应用程序无响应

如果点击了某个按钮 ,按钮背后干了比较耗时的事儿 , 长时间的没有相应, 并且这个长时间的事儿是运行在主线程的

那么就会出现ANR现象.

主线程中不能干耗时的事儿, 主线程不能够被阻塞.

4. 手机号码吉凶测试(xml数据的解析):

实体类

* 解析XML封装的JAVABEAN

* <phones>

<address>广东深圳移动</address>

</phone>

</phones>

public class Phone {

* 手机类型

private String type;

* 手机号码

private String phoneNum;

* 归属地

private String address;

* 手机号吉凶

private String phoneJx;

* Getter与Setter方法

public String getType() {

return type;

}

public void setType(String type) {

this.type = type;

}

public String getPhoneNum() {

return phoneNum;

}

public void setPhoneNum(String phoneNum) {

this.phoneNum = phoneNum;

}

public String getAddress() {

return address;

}

public void setAddress(String address) {

this.address = address;

}

public String getPhoneJx() {

return phoneJx;

}

public void setPhoneJx(String phoneJx) {

this.phoneJx = phoneJx;

}

public String show(){

return "手机号码:"+this.phoneNum+",手机类型:"+this.type+",归属地:"+this.address+",手机号吉凶";

}

工具类

* XML流解析工具类

public class StreamUtils {

* 获取URLConnection的InputStream

* @param in 输入流

* @return 返回一个phone对象

public static Phone decode(InputStream in){

Phone p = new Phone();

try {

XmlPullParser pullParser = Xml.newPullParser();

pullParser.setInput(in,"UTF-8");

int eventType = pullParser.getEventType();

while(eventType!=XmlPullParser.END_DOCUMENT){

if(eventType==XmlPullParser.START_TAG){

if("phone".equals(pullParser.getName())){

String type = pullParser.getAttributeValue(null, "type");

p.setType(type);

}else if("phoneNum".equals(pullParser.getName())){

String phoneNum = pullParser.nextText();

p.setPhoneNum(phoneNum);

}else if("address".equals(pullParser.getName())){

String address = pullParser.nextText();

p.setAddress(address);

}else if("phoneJx".equals(pullParser.getName())){

String phoneJx = pullParser.nextText();

p.setPhoneJx(phoneJx);

}

eventType=pullParser.next();

}

in.close();

} catch (XmlPullParserException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

return p;

}

布局

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"

android:layout_width="match_parent"

android:layout_height="match_parent"

android:orientation="vertical">

<EditText

android:id="@+id/et_path"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:hint="请输入URL"

android:text="http://188.188.3.79:8080/itest/phone.xml"/>

<Button

android:onClick="send"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:text="请求"/>

<TextView

android:id="@+id/tv_result"

android:layout_width="match_parent"

android:layout_height="wrap_content"/>

</LinearLayout>

Activity

* 网络请求XML

1.获取用户输入的URL地址

2.判断用户输入是否为空,为空就提示用户

3.不为空就创建子线程

4.创建URL对象new

* URL(paht)

5.url.openConnection();

* 6.设置请求方法setRequestMethod("GET"),设置连接超时时间setConnectTimeOut(5000)

* 7.获取响应码,判断是否为200,不为200就使用handler发送Error的message

* 8.是200,就获取输入流conn.getInputStream()

9.使用Xml.PullParse解析xml,并封装为对象,返回一个对象

* 10.使用handler发送message,messag.what=SUCCESS,message.obj=封装的对象

* 11.主线程handler重写handlMessage方法,判断msg.what 执行更新UI信息或者提示用户错误信息

public class MainActivity extends Activity {

* 标识符常量

protected static final int SUCCESS = 0;

protected static final int ERROR = 1;

* 用户输入的URL

private EditText et_path;

* 显示结果

private TextView tv_result;

private Handler handler;

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.activity_main);

et_path = (EditText) findViewById(R.id.et_path);

tv_result = (TextView) findViewById(R.id.tv_result);

handler = new Handler() {

@Override

public void handleMessage(Message msg) {

// 11.主线程handler重写handlMessage方法,判断msg.what 执行更新UI信息或者提示用户错误信息

switch (msg.what) {

case SUCCESS:

Phone phone = (Phone) msg.obj;

tv_result.setText(phone.show());

break;

case ERROR:

Toast.makeText(MainActivity.this, "网络异常",

Toast.LENGTH_SHORT).show();

break;

}

};

}

* 发送用户输入的URL,获取XML数据

* @param v

public void send(View v) {

// 1.获取用户输入的URL地址

final String path = et_path.getText().toString().trim();

// 2.判断用户输入是否为空,为空就提示用户

if (TextUtils.isEmpty(path)) {

Toast.makeText(this, "url地址不能为空", Toast.LENGTH_SHORT).show();

return;

}

// 3.不为空就创建子线程

new Thread(new Runnable() {

@Override

public void run() {

try {

// 4.创建URL对象new URL(path)

URL url = new URL(path);

// 5.url.openConnection();

HttpURLConnection conn = (HttpURLConnection) url.openConnection();

// 6.设置请求方法setRequestMethod("GET"),设置连接超时时间setConnectTimeOut(5000)

conn.setRequestMethod("GET");

conn.setConnectTimeout(5000);

// 7.获取响应码,判断是否为200,不为200就使用handler发送Error的message

int code = conn.getResponseCode();

if(code==200){

// 8.是200,就获取输入流conn.getInputStream()

InputStream in = conn.getInputStream();

// 9.使用Xml.PullParse解析xml,并封装为对象,返回一个对象

Phone phone = StreamUtils.decode(in);

// 10.使用handler发送message,messag.what=SUCCESS,message.obj=封装的对象

Message msg = Message.obtain();

msg.what=SUCCESS;

msg.obj = phone;

handler.sendMessage(msg);

}else{

//发送错误消息

sendErrorMessage();

}

} catch (MalformedURLException e) {

e.printStackTrace();

} catch (ProtocolException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

* 发送的消息

private void sendErrorMessage() {

Message msg = Message.obtain();

msg.what=ERROR;

handler.sendMessage(msg);

}

}).start();

}

5.解析JSON

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"

android:layout_width="match_parent"

android:layout_height="match_parent"

android:gravity="center_horizontal"

android:orientation="vertical" >

<EditText

android:id="@+id/et_city"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:hint="请输入要查寻的城名称"/>

<Button

android:onClick="search"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:text="查询天气"/>

<TextView

android:id="@+id/tv_result"

android:gravity="center_horizontal"

android:layout_width="match_parent"

android:layout_height="wrap_content" />

<ListView

android:id="@+id/lv"

android:layout_width="match_parent"

android:layout_height="match_parent"

android:divider="#ff0000"

android:dividerHeight="2dp">

</ListView>

</LinearLayout>

weather_ithem

<?xml version="1.0" encoding="utf-8"?>

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"

android:layout_width="match_parent"

android:layout_height="match_parent"

android:orientation="vertical" >

<TextView

android:id="@+id/fengxiang"

android:layout_width="match_parent"

android:layout_height="wrap_content"/>

<TextView

android:id="@+id/fengli"

android:layout_width="match_parent"

android:layout_height="wrap_content"/>

<TextView

android:id="@+id/high"

android:layout_width="match_parent"

android:layout_height="wrap_content"/>

<TextView

android:id="@+id/type"

android:layout_width="match_parent"

android:layout_height="wrap_content"/>

<TextView

android:id="@+id/low"

android:layout_width="match_parent"

android:layout_height="wrap_content"/>

<TextView

android:id="@+id/date"

android:layout_width="match_parent"

android:layout_height="wrap_content"/>

</LinearLayout>

工具类

/**

* 解析流的工具类,

* 把流解析为字符串

public class StreamUtils {

public static String decode(InputStream in) throws IOException {

ByteArrayOutputStream baos = new ByteArrayOutputStream();

int len =0;

byte [] buff = new byte[1024];

while((len=in.read(buff))!=-1){

baos.write(buff, 0, len);

}

in.close();

baos.close();

return baos.toString();

}

Activity


 * 查询天气预报

* 1.获取输入的城市

* 2.判断是否为空

* 3.获取string中的资源与用户输入的拼接为访问的url

* 4.建立HttpURLConnection

* 5.设置请求方式与连接超时时间

* 6.获取响应码

* 7.判断是否为200

* 8.是200就,使用自定义的流工具类,将流转换为字符串

* 9.获取DESC判断是否为OK,分别处理

* 10,是OK,继续使用JSON解析

* 11.将数组发给主线程中的handler做处理

* 12.handler做更新UI或者提示用户错误信息等

public class MainActivity extends Activity {

protected static final int SUCCESS = 0;

protected static final int INVALID_CITY = 1;

protected static final int ERROR = 2;

private static final String TAG = "R.string.weather";

* 用户输入的城市

private EditText et_city;

* 容器用于显示结果

private ListView lv;

private TextView tv_result;

private BaseAdapter adapter;

* handler

private Handler handler;

private ProgressDialog dialog;

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.activity_main);

et_city = (EditText) findViewById(R.id.et_city);

lv = (ListView) findViewById(R.id.lv);

tv_result = (TextView) findViewById(R.id.tv_result);

handler = new Handler(){

@Override

public void handleMessage(Message msg) {

switch (msg.what) {

case SUCCESS:

final JSONArray array =(JSONArray) msg.obj;

//tv_result.setText(array.toString());

adapter = new BaseAdapter() {

@Override

public View getView(int position, View convertView, ViewGroup parent) {

View view ;

if(convertView==null){

view = View.inflate(MainActivity.this, R.layout.weather_item, null);

}else{

view = convertView;

}

try {

JSONObject obj = array.getJSONObject(position);

TextView fengxiang =(TextView) view.findViewById(R.id.fengxiang);

fengxiang.setText("风向:"+obj.getString("fengxiang"));

TextView fengli =(TextView) view.findViewById(R.id.fengli);

fengli.setText("风力:"+obj.getString("fengli"));

TextView high =(TextView) view.findViewById(R.id.high);

high.setText("高温:"+obj.getString("high"));

TextView type =(TextView) view.findViewById(R.id.type);

type.setText("天气:"+obj.getString("type"));

TextView low =(TextView) view.findViewById(R.id.low);

low.setText("低温:"+obj.getString("low"));

TextView data =(TextView) view.findViewById(R.id.date);

data.setText("日期:"+obj.getString("data"));

} catch (JSONException e) {

e.printStackTrace();

}

return view;

}

@Override

public long getItemId(int position) {

// TODO Auto-generated method stub

return position;

}

@Override

public Object getItem(int position) {

// TODO Auto-generated method stub

return position;

}

@Override

public int getCount() {

// TODO Auto-generated method stub

return array.length();

}

};

dialog.dismiss();

lv.setAdapter(adapter);

break;

case ERROR:

Toast.makeText(MainActivity.this, "网络异常", Toast.LENGTH_SHORT).show();

break;

case INVALID_CITY:

Toast.makeText(MainActivity.this, "输入的城市不存在", Toast.LENGTH_SHORT).show();

break;

}

};

}

* 查询天气

* @param v 查询按键

public void search(View v){

//获取用户化输入的城市

final String city = et_city.getText().toString().trim();

if(TextUtils.isEmpty(city)){

Toast.makeText(this, "城市不能为空", Toast.LENGTH_SHORT).show();

return;

}

System.out.println(city);

dialog = ProgressDialog.show(MainActivity.this, "努力加载", "请稍后..........");

new Thread(new Runnable() {

@Override

public void run() {

try {

//请求路径

String path=getResources().getString(R.string.weather);

Log.i(TAG, path);

//建立URL

URL url = new URL(path+URLEncoder.encode(city, "UTF-8"));

//打开连接

HttpURLConnection conn = (HttpURLConnection) url.openConnection();

//设置主求方式与连接超时时间

conn.setRequestMethod("GET");

conn.setConnectTimeout(5000);

//获取响应码

int code = conn.getResponseCode();

//判断是否为成功

if(code==200){

//获取输入流

InputStream in = conn.getInputStream();

String data = StreamUtils.decode(in);

JSONObject dataObj = new JSONObject(data);

String desc = dataObj.getString("desc");

Log.i(TAG, desc);

if("ok".equalsIgnoreCase(desc)){

/**

* {"desc":"OK",

* "status":1000,

* "data":{"wendu":"13","ganmao":"天气较凉，较易发生感冒，请适当增加衣服。体质较弱的朋友尤其应该注意防护。",

* "forecast":

* [{"fengxiang":"无持续风向","fengli":"微风级","high":"高温 15℃","type":"小雨","low":"低温 11℃","date":"23日星期二"},

* {"fengxiang":"无持续风向","fengli":"微风级","high":"高温 15℃","type":"阴","low":"低温 12℃","date":"24日星期三"},

* {"fengxiang":"无持续风向","fengli":"微风级","high":"高温 16℃","type":"小雨","low":"低温 12℃","date":"25日星期四"},

* {"fengxiang":"无持续风向","fengli":"微风级","high":"高温 17℃","type":"阴","low":"低温 13℃","date":"26日星期五"},

* {"fengxiang":"无持续风向","fengli":"微风级","high":"高温 18℃","type":"阴","low":"低温 13℃","date":"27日星期六"}],

* "yesterday":{"fl":"微风","fx":"无持续风向","high":"高温 21℃","type":"多云","low":"低温 16℃","date":"22日星期一"},"aqi":"28","city":"深圳"}}

//获取data:每一天的信息

JSONObject dataJsonObject = dataObj.getJSONObject("data");

//获取一周的数据

JSONArray array = dataJsonObject.getJSONArray("forecast");

Message msg =Message.obtain();

msg.what =SUCCESS;

msg.obj = array;

handler.sendMessage(msg);

}else {

Message msg = Message.obtain();

msg.what= INVALID_CITY;

handler.sendMessage(msg);

}

}else{

//网络异常

sendErrorMessage();

}

} catch (MalformedURLException e) {

e.printStackTrace();

sendErrorMessage();

//网络异常

} catch (IOException e) {

e.printStackTrace();

//网络异常

sendErrorMessage();

} catch (JSONException e) {

e.printStackTrace();

}

//发送错误信息

private void sendErrorMessage() {

Message msg = Message.obtain();

msg.what= ERROR;

handler.sendMessage(msg);

}

}).start();

}

6.模拟新闻客户端

本地tomcat服务器提供一个XML文件与图片

<?xml version="1.0" encoding="UTF-8" ?> 
<channel>
<item>
  <title>军报评徐才厚</title> 
  <description>人死账不消 反腐步不停，支持，威武，顶，有希望了。
  </description>
  <image>http://192.168.1.104:8080/img/a.jpg</image>
  <type>1</type>
  <comment>163</comment>
  </item>
 <item>
  <title>女司机翻车后直奔麻将室</title> 
  <description>女司机翻车后直奔麻将室，称大难不死手气必红
  </description>
  <image>http://192.168.1.104:8080/img/b.jpg</image>
  <type>2</type>
  </item>
  <item>
  <title>小伙当“男公关”以为陪美女</title> 
  <description>来源：中国青年网，小伙当“男公关”以为陪美女，上工后被大妈吓怕  </description>
  <image>http://192.168.1.104:8080/img/c.jpg</image>
  <type>3</type>
  </item>
  <item>
  <title>男子看上女孩背影欲强奸</title> 
  <description> 来源：新京报， 看到正脸后放弃仍被捕
  </description>
  <image>http://192.168.1.104:8080/img/d.jpg</image>
  <type>1</type>
  <comment>763</comment>
  </item>
</channel>

添加权限

<uses-permission android:name="android.permission.INTERNET"/>

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

</LinearLayout>
//listView使用的
<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent" >

<com.itheima.newsclient.smartview.MySmartView
android:id="@+id/iv_icon"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:layout_marginLeft="10dp"
android:layout_marginTop="10dp"
android:src="@drawable/ic_launcher" />

实体JAVABEAN

/**
 * 新闻封装类
 * <item>
<title>军报评徐才厚</title>
<description>人死账不消 反腐步不停，支持，威武，顶，有希望了。</description>
<image>http://188.188.3.100:8080/img/a.jpg</image>
<type>1</type>
<comment>163</comment>
</item>
 */
public class NewsItems {

private String title;
private String description;
private String imageUrl;
private String type;
private String comment;

public String getTitle() {
return title;
}

public void setTitle(String title) {
this.title = title;
}

public String getDescription() {
return description;
}

public void setDescription(String description) {
this.description = description;
}

public String getImageUrl() {
return imageUrl;
}

public void setImageUrl(String imageUrl) {
this.imageUrl = imageUrl;
}

public String getType() {
return type;
}

public void setType(String type) {
this.type = type;
}

public String getComment() {
return comment;
}

public void setComment(String comment) {
this.comment = comment;
}
}

工具类

/**
 * 解析XML
public class NewsClientService {

public static List<NewsItems> getNewsInfo(InputStream in) throws XmlPullParserException, IOException {
List<NewsItems> list = new ArrayList<NewsItems>();
//XML解析器
XmlPullParser pullParser = Xml.newPullParser();
//设置输入编码
pullParser.setInput(in,"UTF-8");

//获取事件
int eventType = pullParser.getEventType();

//开始解析
NewsItems newsItem=null;
while(eventType!=XmlPullParser.END_DOCUMENT){

if(eventType==XmlPullParser.START_TAG){
if("item".equals(pullParser.getName())){
//如果是开始就新对象
newsItem = new NewsItems();
}else if("title".equals(pullParser.getName())){
//设置标题
newsItem.setTitle(pullParser.nextText());
}else if("description".equals(pullParser.getName())){
//设置描述内容
newsItem.setDescription(pullParser.nextText());
}else if("image".equals(pullParser.getName())){
//设置image
newsItem.setImageUrl(pullParser.nextText());

}else if("type".equals(pullParser.getName())){
//设置类型
newsItem.setType(pullParser.nextText());
}else if("comment".equals(pullParser.getName())){
//设置评论数
newsItem.setComment(pullParser.nextText());
}

}else if(eventType==XmlPullParser.END_TAG){
if("item".equals(pullParser.getName())){
//添加对象到集合
list.add(newsItem);
}
}

//移动指针
eventType=pullParser.next();
}
return list;
}

}

自定义的

/**
 * 自定义显示地址为path的图片
public class MySmartView extends ImageView {

public MySmartView(Context context) {
super(context);
}

public MySmartView(Context context, AttributeSet attrs, int defStyle) {
super(context, attrs, defStyle);
}

public MySmartView(Context context, AttributeSet attrs) {
super(context, attrs);
}
* 设置图像
public void setImage(String url){
ViewAsyncTask viewAsyncTask = new ViewAsyncTask(getContext());

try {
viewAsyncTask.execute(new URL(url));
} catch (MalformedURLException e) {
e.printStackTrace();
}
}
private class ViewAsyncTask extends AsyncTask<URL, Integer, Bitmap>{
private Context mContext;
public ViewAsyncTask(Context mContext){
this.mContext=mContext;
}

@Override
protected Bitmap doInBackground(URL... params) {

try {
HttpURLConnection conn = (HttpURLConnection) params[0].openConnection();
//设置请求方法
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);
int code = conn.getResponseCode();
if(code==200){
InputStream in = conn.getInputStream();
Bitmap bitmap = BitmapFactory.decodeStream(in);
return bitmap;
}
} catch (IOException e) {
e.printStackTrace();
}
return null;

}

@Override
protected void onPostExecute(Bitmap result) {
setImageBitmap(result);
}
}
}

Activity

/**
 * 模拟新闻客户端 1.
public class MainActivity extends Activity {

private ListView lv;

private List<NewsItems> list;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);

lv = (ListView) findViewById(R.id.lv);

NewsAsyncTask newsAsyncTask = new NewsAsyncTask(this);
try {
newsAsyncTask.execute(new URL(getResources().getString(R.string.path)));
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (NotFoundException e) {
e.printStackTrace();
}

}

private class NewsAsyncTask extends AsyncTask<URL, Integer, List<NewsItems>>{
private List<NewsItems> list = null ;
//对话框
private ProgressDialog pDialog;
//上下文
private Context mContext;
//构造函数
public NewsAsyncTask(Context mContext){
this.mContext = mContext;
}

@Override
protected List<NewsItems> doInBackground(URL... params) {

try {

//获取连接
HttpURLConnection conn = (HttpURLConnection) params[0].openConnection();

//设置连接连接方法
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);
//获取响应码
int code = conn.getResponseCode();
if(code == 200){
//获取输入流
InputStream in = conn.getInputStream();
//解析XML
list=NewsClientService.getNewsInfo(in);
}
return list;
} catch (IOException e) {
e.printStackTrace();
} catch (XmlPullParserException e) {
e.printStackTrace();
}
return null;
}

@Override
protected void onPostExecute(List<NewsItems> result) {
lv.setAdapter(new MyBaseAdapter(result));
//设置对话框消失
pDialog.dismiss();

}

@Override
protected void onPreExecute() {
//初始化对象话进度条
pDialog = new ProgressDialog(MainActivity.this);
//设置标题
pDialog.setTitle("新闻加载中");
//设置内容
pDialog.setMessage("正在加载中........惊喜稍后呈现");
//设置是否可以取消 true可以取消
pDialog.setIndeterminate(true);
//设置风格
pDialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);
//设置最大进度
pDialog.setMax(100);
//显示
pDialog.show();
}

@Override
protected void onProgressUpdate(Integer... values) {
//设置时度
pDialog.setProgress(values[0]);

}

}

* ListView 适配器
private class MyBaseAdapter extends BaseAdapter {
private static final String TAG = "MyBaseAdapter";
private List<NewsItems> list ;
public MyBaseAdapter(List<NewsItems> list){
this.list=list;
}

@Override
public int getCount() {
return list.size();
}

@Override
public Object getItem(int position) {
return position;
}

@Override
public long getItemId(int position) {
return position;
}

@Override
public View getView(int position, View convertView, ViewGroup parent) {

NewsItems newsItems = list.get(position);
Log.i(TAG, newsItems.getTitle());
View view;
if(convertView==null){
view = View.inflate(MainActivity.this, R.layout.news_items, null);
}else{
view = convertView;
}
//图片
com.itheima.newsclient.smartview.MySmartView iv_icon =(com.itheima.newsclient.smartview.MySmartView) view.findViewById(R.id.iv_icon);

iv_icon.setImage(newsItems.getImageUrl());

//标题
TextView tv_title = (TextView) view.findViewById(R.id.tv_title);
tv_title.setText(newsItems.getTitle());
//描述
TextView tv_desc = (TextView) view.findViewById(R.id.tv_desc);
tv_desc.setText(newsItems.getDescription());
//评论
TextView tv_comm = (TextView) view.findViewById(R.id.tv_comm);

String type = newsItems.getType();

if(type.equals("1")){
tv_comm.setBackgroundColor(Color.RED);
tv_comm.setText("军报"+newsItems.getComment());
}else if(type.equals("2")){
tv_comm.setBackgroundColor(Color.BLUE);
tv_comm.setText("实时"+newsItems.getComment());
}else if(type.equals("3")){
tv_comm.setBackgroundColor(Color.GREEN);
tv_comm.setText("娱乐"+newsItems.getComment());
}else if(type.equals("4")){
tv_comm.setBackgroundColor(Color.GRAY);
tv_comm.setText("生活"+newsItems.getComment());
}

return view;
}

}
}

7.源生GET与POST请求

本地TOMCAT运行服务端写了一个Servlet

/**
 * LoginServlet
* @Decription 处理登录请求的Servlet
@WebServlet(urlPatterns={"/login"})
public class LoginServlet extends HttpServlet {

@SuppressWarnings("deprecation")
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
/*
* 获取用户名与密码并转换为UTF-8
*/
String user = request.getParameter("username");
/*String encode = URLEncoder.encode(user,"iso8859-1");
String decode = URLDecoder.decode(encode, "UTF-8");*/
System.out.println("================get===============");
String username =new String(user.getBytes("iso8859-1"),"utf-8");
System.out.println("get用户名:"+username);

String pwd=request.getParameter("password");

String password = new String(pwd.getBytes("iso8859-1"), "UTF-8");
System.out.println("get密码:"+password);

/*
* 这里写死用户名与密码,
* 正常是去数据库查询
*/
PrintWriter writer = response.getWriter();

if("admin".equals(username)&& "admin".equals(password)){
writer.write("SUCCESS");

}else{
writer.write("FAILURE");
}
}

public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
System.out.println("================post===============");
request.setCharacterEncoding("UTF-8");
String username = request.getParameter("username");

String password = request.getParameter("password");
System.out.println("post username:"+username+",password: "+password);

if("admin".equals(username) && "admin".equals(password)){
response.getWriter().print("SUCCESS");
}else{
response.getWriter().print("failure");
}
}

}

工具类

public class StreamUtils {

public static String decode(InputStream in) throws IOException {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
int len=0;
byte [] buf = new byte[1024];
while((len=in.read(buf))!=-1){
baos.write(buf, 0, len);
}
in.close();
baos.close();
return baos.toString();
}

}

布局

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

Activity

public class MainActivity extends Activity {
    protected static final int ERROR = 0;
    protected static final int SUCCESS = 1;
     * 用户名
    private EditText et_name;
     * 密码
    private EditText et_pwd;
     * 结果
    private TextView tv_result;

@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);

tv_result = (TextView) findViewById(R.id.tv_result);
}

private Handler handler = new Handler(){
public void handleMessage(Message msg) {
switch (msg.what) {
case SUCCESS:
tv_result.setText(msg.obj.toString());
break;
case ERROR:
Toast.makeText(MainActivity.this, "网络异常", Toast.LENGTH_SHORT).show();
break;

}
};
};
* 登录点击事件
* @param v
* 按键
public void login(View v) {

new Thread() {
public void run() {
String path = getResources().getString(R.string.path);
try {
path = path + "?username="
+ URLEncoder.encode(username, "UTF-8")
+ "&password="
+ URLEncoder.encode(password, "UTF-8");
//建立连接
URL url = new URL(path);

//打开连接
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
//设置请求方式与连接超时时间
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);

//获取响应码
int code = conn.getResponseCode();
//判断响应异常
if(code==200){
//获取输入
InputStream in = conn.getInputStream();
//解析
String result=StreamUtils.decode(in);
//设置消息
Message msg= Message.obtain();
msg.what=SUCCESS;
msg.obj=result;
//发送消息
handler.sendMessage(msg);

}else{
sendErrorMessage();
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
sendErrorMessage();
} catch (IOException e) {
e.printStackTrace();
sendErrorMessage();
}

}

private void sendErrorMessage() {
//设置消息
Message msg= Message.obtain();
msg.what=ERROR;
//发送消息
handler.sendMessage(msg);
};

}.start();

}

Post

public class MainActivity extends Activity {
    protected static final int ERROR = 0;
    protected static final int SUCCESS = 1;
     * 用户名
    private EditText et_name;
     * 密码
    private EditText et_pwd;

* 结果
*/
private TextView tv_result;

@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);

tv_result = (TextView) findViewById(R.id.tv_result);
}

private Handler handler = new Handler() {
public void handleMessage(Message msg) {
switch (msg.what) {
case SUCCESS:
tv_result.setText(msg.obj.toString());
break;
case ERROR:
Toast.makeText(MainActivity.this, "网络异常", Toast.LENGTH_SHORT)
.show();
break;

}
};
};
* 登录点击事件
* @param v
* 按键
public void login(View v) {

new Thread() {
public void run() {
String path = getResources().getString(R.string.path);
try {

String params = "username="
+ URLEncoder.encode(username, "UTF-8")
+ "&password="
+ URLEncoder.encode(password, "UTF-8");
* String params = "username=" + username + "&password=" +
* password;
// 建立连接
URL url = new URL(path);

// 打开连接
HttpURLConnection conn = (HttpURLConnection) url
.openConnection();
// 设置请求方式与连接超时时间
conn.setRequestMethod("POST");
conn.setConnectTimeout(5000);
// 设置请求头
// Content-Type: application/x-www-form-urlencoded
// Content-Length: 25
conn.setRequestProperty("Content-Type",
"application/x-www-form-urlencoded");
conn.setRequestProperty("Content-Length", params.length()
+ "");

// 设置输出
conn.setDoOutput(true);
// 把参数输出到服务器
OutputStream out = conn.getOutputStream();
out.write(params.getBytes());
// 获取响应码
int code = conn.getResponseCode();
// 判断响应异常
if (code == 200) {
// 获取输入
InputStream in = conn.getInputStream();
// 解析
String result = StreamUtils.decode(in);
// 设置消息
Message msg = Message.obtain();
msg.what = SUCCESS;
msg.obj = result;
// 发送消息
handler.sendMessage(msg);

} else {
sendErrorMessage();
}

} catch (UnsupportedEncodingException e) {
e.printStackTrace();
sendErrorMessage();
} catch (IOException e) {
e.printStackTrace();
sendErrorMessage();
}

}

private void sendErrorMessage() {
// 设置消息
Message msg = Message.obtain();
msg.what = ERROR;
// 发送消息
handler.sendMessage(msg);
};

}.start();

}

8.使用Apache的HttpClient完成

8.1get

public class MainActivity extends Activity {
    protected static final int ERROR = 0;
    protected static final int SUCCESS = 1;
     * 用户名
    private EditText et_name;
     * 密码
  private EditText et_pwd;   
  * 结果
    private TextView tv_result;

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);

}
};
};
* 登录点击事件
* @param v
* 按键
public void login(View v) {

new Thread() {
public void run() {
String path = getResources().getString(R.string.path);
try {
path = path + "?username="
+ URLEncoder.encode(username, "UTF-8")
+ "&password="
+ URLEncoder.encode(password, "UTF-8");
HttpClient client = new DefaultHttpClient();
HttpGet httpGet = new HttpGet(path);
//建立获取响应
HttpResponse response = client.execute(httpGet);
//获取响应码
int code = response.getStatusLine().getStatusCode();
//判断响应异常
if(code==200){
//获取输入
InputStream in = response.getEntity().getContent();
//解析
String result=StreamUtils.decode(in);
//设置消息
Message msg= Message.obtain();
msg.what=SUCCESS;
msg.obj=result;
//发送消息
handler.sendMessage(msg);

}else{
sendErrorMessage();
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
sendErrorMessage();
} catch (IOException e) {
e.printStackTrace();
sendErrorMessage();
}

}

private void sendErrorMessage() {
//设置消息
Message msg= Message.obtain();
msg.what=ERROR;
//发送消息
handler.sendMessage(msg);
};

}.start();

}

8.2 post

public class MainActivity extends Activity {
    protected static final int ERROR = 0;
    protected static final int SUCCESS = 1;
     * 用户名
    private EditText et_name;
     * 密码
    private EditText et_pwd;
     * 结果
    private TextView tv_result;

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);

}
};
};

/**
* 登录点击事件
*
* @param v
* 按键
*/
public void login(View v) {

new Thread() {
public void run() {
String path = getResources().getString(R.string.path);
try {
/* String params = "username="
+ URLEncoder.encode(username, "UTF-8")
+ "&password="
+ URLEncoder.encode(password, "UTF-8");*/
HttpClient client = new DefaultHttpClient();
HttpPost httpPost = new HttpPost(path);
List<NameValuePair> list = new ArrayList<NameValuePair>();
list.add(new BasicNameValuePair("username",username));
list.add(new BasicNameValuePair("password",password));
httpPost.setEntity(new UrlEncodedFormEntity(list, "UTF-8"));
//建立获取响应
HttpResponse response = client.execute(httpPost);
//获取响应码
int code = response.getStatusLine().getStatusCode();
//判断响应异常
if(code==200){
//获取输入
InputStream in = response.getEntity().getContent();
//解析
String result=StreamUtils.decode(in);
//设置消息
Message msg= Message.obtain();
msg.what=SUCCESS;
msg.obj=result;
//发送消息
handler.sendMessage(msg);
}else{
sendErrorMessage();
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
sendErrorMessage();
} catch (IOException e) {
e.printStackTrace();
sendErrorMessage();
}

}

private void sendErrorMessage() {
//设置消息
Message msg= Message.obtain();
msg.what=ERROR;
//发送消息
handler.sendMessage(msg);
};

}.start();

}

9.使用开源的框架完成

https://github.com/loopj/android-async-http

9.1 get

/**
     * 登录点击事件
     * 
     * @param v
     *            按键
     */
    public void login(View v) {

final String username = et_name.getText().toString().trim();
final String password = et_pwd.getText().toString().trim();
if (TextUtils.isEmpty(username) || TextUtils.isEmpty(password)) {
Toast.makeText(this, "用户名或者密码不能为空", Toast.LENGTH_SHORT).show();
return;
}
String path = getResources().getString(R.string.path);
/* try {
path = path + "?username="
+ URLEncoder.encode(username, "UTF-8")
+ "&password="
+ URLEncoder.encode(password, "UTF-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}*/
//使用开源框架 https://github.com/loopj/android-async-http

AsyncHttpClient httpClient = new AsyncHttpClient();

/* httpClient.get(path, new AsyncHttpResponseHandler() {

@Override
public void onSuccess(int statusCode, Header[] headers, byte[] responseBody) {
tv_result.setText("code"+statusCode+"响应体"+new String(responseBody));

}

@Override
public void onFailure(int statusCode, Header[] headers,
byte[] responseBody, Throwable error) {
tv_result.setText("code"+statusCode+"响应体"+new String(responseBody));
}
});*/

RequestParams params = new RequestParams();
params.put("username", username);
params.put("password", password);
httpClient.get(path, params, new AsyncHttpResponseHandler() {

@Override
public void onSuccess(int statusCode, Header[] headers, byte[] responseBody) {
tv_result.setText("code"+statusCode+"响应体"+new String(responseBody));

}

@Override
public void onFailure(int statusCode, Header[] headers,
byte[] responseBody, Throwable error) {
tv_result.setText("code"+statusCode+"响应体"+new String(responseBody));

}
});

}

9.2post

 /**
     * 登录点击事件
     * 
     * @param v
     *            按键
     */
    public void login(View v) {

final String username = et_name.getText().toString().trim();
final String password = et_pwd.getText().toString().trim();
if (TextUtils.isEmpty(username) || TextUtils.isEmpty(password)) {
Toast.makeText(this, "用户名或者密码不能为空", Toast.LENGTH_SHORT).show();
return;
}
String path = getResources().getString(R.string.path);
/* try {
path = path + "?username="
+ URLEncoder.encode(username, "UTF-8")
+ "&password="
+ URLEncoder.encode(password, "UTF-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}*/

AsyncHttpClient httpClient = new AsyncHttpClient();

/* httpClient.get(path, new AsyncHttpResponseHandler() {

@Override
public void onSuccess(int statusCode, Header[] headers, byte[] responseBody) {
tv_result.setText("code"+statusCode+"响应体"+new String(responseBody));

}

@Override
public void onFailure(int statusCode, Header[] headers,
byte[] responseBody, Throwable error) {
tv_result.setText("code"+statusCode+"响应体"+new String(responseBody));
}
});*/

RequestParams params = new RequestParams();
params.put("username", username);
params.put("password", password);
httpClient.post(path, params, new AsyncHttpResponseHandler() {

@Override
public void onSuccess(int statusCode, Header[] headers, byte[] responseBody) {
tv_result.setText("code"+statusCode+"响应体"+new String(responseBody));

}

@Override
public void onFailure(int statusCode, Header[] headers,
byte[] responseBody, Throwable error) {
tv_result.setText("code"+statusCode+"响应体"+new String(responseBody));

}
});

}

10.使用开源框架上传文件

服务器,使用Servlet完成使用Apache的commons-fileupload,commons-io写的文件上传

public class UploadServlet extends HttpServlet {

public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {

doPost(request, response);
}

public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
try {
//ArrayList<String> list=initList();

// 获取磁盘文件工厂
DiskFileItemFactory factory = new DiskFileItemFactory();
// 设置初始值
setFactory(factory);
/*
* // 配置初始化值缓冲区 factory.setSizeThreshold(1024 * 1024); // 设置缓冲区文件
* String bufPath = getServletContext().getRealPath("/temp");
*
* factory.setRepository(new File(bufPath));
*/
// 获取上传对象解析器
ServletFileUpload upload = new ServletFileUpload(factory);
// 判断是不是多部分组成
if (!upload.isMultipartContent(request)) {
request.setAttribute("msg", "表单不是多部分组成,查看enctype");
request.getRequestDispatcher("/upload.jsp").forward(request,
response);
return;
}
// 初始化
setFileUpload(upload);
// 设置字符编码
/*
* upload.setHeaderEncoding("utf-8"); // 设置单个文件大小
* upload.setFileSizeMax(1024 * 1024 * 5); // 设置总文件大小
* upload.setSizeMax(1024 * 1024 * 20);
*
* // 设置上传监听器 upload.setProgressListener(new ProgressListener() {
*
* public void update(long pBytesRead, long pContentLength, int
* pItems) { System.out.println("已经读:" + pBytesRead + "总共大小 :" +
* pContentLength + "第" + pItems + "个");
*
* } });
*/

// 获取请求的列表
List<FileItem> parseRequest = upload.parseRequest(request);
// 遍历
for (FileItem item : parseRequest) {
// 判断是不是普通表单数据
if (item.isFormField()) {
String fieldname = item.getFieldName();
String fieldValue = item.getString("UTF-8");
System.out.println("表单:" + fieldname + "," + fieldValue);
} else {
// 上传路径
String uploadPath = getServletContext().getRealPath(
"/WEB-INF/upload");
// 获取文件名
String filename = item.getName();
int index=filename.lastIndexOf(".");
String extname=filename.substring(index);
//判断上传的文件是否在上传列表中
/*if(!list.contains(extname)){
request.setAttribute("msg", "文件类型"+extname+"不在上传的类型中");
request.getRequestDispatcher("/upload.jsp").forward(request,
response);
return;
}*/

// 获取输入流
InputStream in = item.getInputStream();
filename = UUID.randomUUID().toString().replace("-", "")
+ "_" + filename;
System.out.println(filename);
String savePath = genera(uploadPath, filename);
System.out.println(savePath);
//上传文件
uploadFile(in,savePath,filename);
//删除缓存
item.delete();
}
//上传失败的缓冲也清除
item.delete();
}

} catch (FileUploadBase.FileSizeLimitExceededException e) {
request.setAttribute("msg", "单个文件大小超过限制");
request.getRequestDispatcher("/upload.jsp").forward(request,
response);
return;
} catch (FileUploadBase.SizeLimitExceededException e) {
request.setAttribute("msg", "文件总大小超过限制");
request.getRequestDispatcher("/upload.jsp").forward(request,response);
return;
} catch (MyException e) {
request.setAttribute("msg", "文件类型不正确");
request.getRequestDispatcher("/upload.jsp").forward(request,
response);
return;
}catch (Exception e) {
e.printStackTrace();
request.setAttribute("msg", "出错了");
request.getRequestDispatcher("/upload.jsp").forward(request,
response);
return;
}
request.setAttribute("msg", "上传成功");
request.getRequestDispatcher("/upload.jsp").forward(request, response);

}
* 初始化可以上传的文件列表
* @return
private ArrayList<String> initList() {
ArrayList<String> list=new ArrayList<String>();
list.add(".jpg");
list.add(".rar");
list.add(".txt");
list.add(".png");
return list;
}

/**
* 上传文件
* @param in 输入流
* @param savePath 保存路径
* @param filename 文件名称
* @throws Exception
*/
private void uploadFile(InputStream in, String savePath, String filename) throws Exception {
File file = new File(savePath, filename);
// 设置输出流
OutputStream out = new FileOutputStream(file);
int len = 0;
byte[] buf = new byte[1024];
while ((len = in.read(buf)) != -1) {
out.write(buf, 0, len);
}
in.close();
out.close();

}

/**
* 使用哈希值,做散列的文件目录
*
* @param uploadPath
* @param filename
* @return
*/
private String genera(String uploadPath, String filename) {
System.out.println(uploadPath);
int hashCode = filename.hashCode();
StringBuilder sb = new StringBuilder();
while (hashCode > 0) {
int tmp = hashCode & 0xf;
sb.append("/");
sb.append(tmp + "");
hashCode = hashCode >> 4;
}
System.out.println(sb.toString());
String path = uploadPath + sb.toString();
File file = new File(path);
if (!file.exists()) {
file.mkdirs();
}
return path;
}

/**
* 对象解析器进行初始化
*
* @param upload
*/
private void setFileUpload(ServletFileUpload upload) {
// 设置字符编码
upload.setHeaderEncoding("utf-8");
// 设置单个文件大小
upload.setFileSizeMax(1024 * 1024 * 20);
// 设置总文件大小
upload.setSizeMax(1024 * 1024 * 100);
// 设置上传监听器
upload.setProgressListener(new ProgressListener() {

public void update(long pBytesRead, long pContentLength, int pItems) {
System.out.println("已经读:" + pBytesRead + "总共大小 :"
+ pContentLength + "第" + pItems + "个");

}
});

}

/**
* 为工厂设置初始值
*/
private void setFactory(DiskFileItemFactory factory) {
// 配置初始化值缓冲区
factory.setSizeThreshold(1024 * 1024);
// 设置缓冲区文件
String bufPath = getServletContext().getRealPath("/temp");

factory.setRepository(new File(bufPath));
}
}

客户端

权限

<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />

布局

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

</LinearLayout>

Activity

public class MainActivity extends Activity {

protected static final String TAG = "MainActivity";
/*
* 输入的文件地址
*/
private EditText et_file;

/*
* 进度条
*/
private ProgressBar pb;
/*
* 显示时度值
*/
private TextView tv_display;

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);

et_file = (EditText) findViewById(R.id.et_file);

pb = (ProgressBar) findViewById(R.id.pb);

tv_display = (TextView) findViewById(R.id.tv_display);
}

/**
* 上传文件
*
* @param v
* 上传按键
*/
public void upload(View v) {
//获取输入的文件地址
String str = et_file.getText().toString().trim();

File file = new File(str);

// 使用开源框架地址https://github.com/wyouflf/xUtils
HttpUtils httpUtils = new HttpUtils();

RequestParams params = new RequestParams();

params.addBodyParameter("file", file);

// 获取上传路径,写在values--strings中
String url = "http://192.168.1.104:8080/MyDay11upload/upload";
Log.i(TAG, url);

// 发送文件
httpUtils.send(HttpMethod.POST, url, params,
new RequestCallBack<String>() {

@Override
public void onFailure(HttpException error, String msg) {
Toast.makeText(MainActivity.this, "上传失败:=====" + msg,
Toast.LENGTH_SHORT).show();

}

@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
Toast.makeText(MainActivity.this, "上传成功:=====",
Toast.LENGTH_SHORT).show();
Header[] headers = responseInfo.getAllHeaders();
for (Header header : headers) {
Log.i(TAG, "key:---->" + header.getName()
+ "values---->" + header.getValue());
}
}

@Override
public void onLoading(long total, long current,
boolean isUploading) {
pb.setMax((int) total);
pb.setProgress((int) current);
tv_display.setText("当前进度:"+current+" 总进度:"+total);
}

});

}

11.AsyncTask

 * 使用异步下载
 * 1.创建AsyncTaskr子类,并为三个泛型参数指定类型,如果某个泛型参数不需要指定类型则可以指定为Void
 * 2.根据需要实现AsyncTAsk的方法
 * doInBackground 重写这个方法,后台线程将要完成的任务,
该方法可以调用publishProgress(Progresss....values)方法更新任务的进度
 * onProExecute():该方法将在后台耗时操作前被调用,通常该方法,
用于完成一些初始化准备工作,比如在界面显示初始化进度等
 * onPostExcute(Result result) 当doInBackground完成以后,系统会自动调用onPostExecute()方法,
并将doInBackground方法的返回值传给该方法
 *
 * 3.调用AsyncTask子类的实例execute(Params..params)开始执行耗时任务
 * 注意:
 * 必须在UI线程中创建AsyncTasck的实例
 * 必须在UI线程中调用AsyncTask的execute()方法
 * doInBackground,onProExecute,onPostExcute,opProgressUpdate()方法,
不应该用程序员代码调用,而是用Android系统负责调用
 * 每个AsyncTask只能执行一次,多次调用将会引发异常

/**
 * 使用异步下载
 * 1.创建AsyncTaskr子类,并为三个泛型参数指定类型,如果某个泛型参数不需要指定类型则可以指定为Void
 * 2.根据需要实现AsyncTAsk的方法
 * doInBackground 重写这个方法,后台线程将要完成的任务,
该方法可以调用publishProgress(Progresss....values)方法更新任务的进度
 * onProExecute():该方法将在后台耗时操作前被调用,通常该方法,
用于完成一些初始化准备工作,比如在界面显示初始化进度等
 * onPostExcute(Result result) 当doInBackground完成以后,
系统会自动调用onPostExecute()方法,并将doInBackground方法的返回值传给该方法
 * 3.调用AsyncTask子类的实例execute(Params..params)开始执行耗时任务
 * 注意:
 * 必须在UI线程中创建AsyncTasck的实例
 * 必须在UI线程中调用AsyncTask的execute()方法
 * doInBackground,onProExecute,onPostExcute,opProgressUpdate()方法,
不应该用程序员代码调用,而是用Android系统负责调用
 * 每个AsyncTask只能执行一次,多次调用将会引发异常
public class MainActivity extends AppCompatActivity {

用户输入的url
private EditText tv_path;
*显示结果
private TextView tv_show;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);

tv_path = (EditText) findViewById(R.id.tv_path);

tv_show = (TextView) findViewById(R.id.tv_show);
}
* 响应按键点击下载事件
* @param v 当前按键
public void download(View v){

String path = tv_path.getText().toString().trim();

if(TextUtils.isEmpty(path)){

Toast.makeText(this,"下载路径不能为空",Toast.LENGTH_SHORT).show();
return;
}

DownloadTask task = new DownloadTask(this);

try {
//开始执行
task.execute(new URL(path));
} catch (MalformedURLException e) {
e.printStackTrace();
}

}
* 可变参数
* 第一个:param 表示传入的参数
* 第二个:progress后台任务成的进度值的类型
* 第三个:Result,返回的类型
private class DownloadTask extends AsyncTask<URL,Integer,String>{
上下文
private Context mContext;
进度条
private ProgressDialog progressDialog;
定义记录读取的行数
private int hasRead = 0;

public DownloadTask(Context context) {
this.mContext = context;
}

@Override
protected String doInBackground(URL... params) {

StringBuilder sb = new StringBuilder();

try {
//打开连接
URLConnection conn = params[0].openConnection();

//开始读读
BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(),"UTF-8"));

String line=null;
//开始读
while((line=br.readLine())!=null){
sb.append(line+"\n");
}
//返回将因被OnPostexecute方法调用接收返回值
return sb.toString();

} catch (IOException e) {
e.printStackTrace();
}

return null;
}
* 初始化操作
@Override
protected void onPreExecute() {

progressDialog = new ProgressDialog(mContext);
//设置对话框标题
progressDialog.setTitle("任务正在执行中");
//设置对话显示的内容
progressDialog.setMessage("任务在拼命加载中...请稍后......");
//设置对话框不能用取消按键关闭
progressDialog.setCancelable(false);

//设置该进度条最在时度值
progressDialog.setMax(100);
//设置时度条的风格
progressDialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);

//设置是否显示时度条不确定的是否显示true为不显示,
progressDialog.setIndeterminate(false);
progressDialog.show();
}

@Override
protected void onProgressUpdate(Integer... values) {
tv_show.setText("已经读取====" + values[0] + "=====行");

progressDialog.setProgress(values[0]);
}
* 调用 doInBackground,并接收其返回值
* @param s
@Override
protected void onPostExecute(String s) {
//设置显示
tv_show.setText(s);
//进度对话框消失不可见

progressDialog.dismiss();
}
}
}

12.多线程断点下载

JAVA实现

package com.it.download;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;

import java.net.URL;
* 多线程断点下载,续传
* @Decription TODO
public class DownTask {

// 下载地址
public static String path = "http://192.168.1.104:8080/itest/gm.mp3";
/*
* 线程数
*/
public static int threadCount = 5;

/*
* 当前运行的线程数
*/
public static int runninThreadCount =threadCount;
public static void main(String[] args) {

// 开始连接网络
try {
URL url = new URL(path);
// 打开网络连接
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
// 设置请求方式与连接超时时间
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);
// 获取获取码
int code = conn.getResponseCode();
if (code == 200) {
int length = conn.getContentLength();
System.out.println("长度:" + length);
// 在本地创建一个与服务一样大小的文件
String fileName = getFileName(path);
RandomAccessFile raf = new RandomAccessFile(fileName, "rw");
// 设置文件的大小
raf.setLength(length);
raf.close();

// 计算每个线程下载的大小
int blockSize = length % threadCount == 0 ? length
/ threadCount : length / threadCount + 1;
//
for (int threadId = 0; threadId < threadCount; threadId++) {
// 计算开始下载的位置与结束下载的文置
int startIndex = threadId * blockSize;
int endIndex = startIndex + blockSize;
if (endIndex >= length) {
endIndex = length;
}
new DownThread(threadId, startIndex, endIndex).start();

}

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

}

/**
* 获取文件名称
*
* @param path
* 路径
* @return 返回文件名称
*/
public static String getFileName(String path) {
int index = path.lastIndexOf("/");
return path.substring(index + 1);
}

/**
* 下载的线程
*
* @Decription TODO
private static class DownThread extends Thread {
// 线程IP
private int threadId;
// 开始位置
private int startIndex;
// 结束位置
private int endIndex;
private int currentPosition;

public DownThread(int threadId, int startIndex, int endIndex) {
super();
this.threadId = threadId;
this.startIndex = startIndex;
this.endIndex = endIndex;
this.currentPosition = startIndex;
}

@Override
public void run() {
System.out.println("线程:" + threadId + ",==开始下载位置:" + startIndex
+ "=========>结束位置:" + endIndex);

// 开始连接网络
try {
URL url = new URL(path);
// 打开连接
HttpURLConnection conn = (HttpURLConnection) url
.openConnection();
// 设置请求方式与连接超时时间
conn.setRequestMethod("GET");
conn.setConnectTimeout(5000);
// 设置请求头,多线程下载,只获取一部分数据

String fileName = getFileName(path);
RandomAccessFile rf = new RandomAccessFile(fileName, "rw");

// 首先确认有没有下载过拿到文件
File fFile = new File(threadId + ".position");
// 判断文件是不是存在,存在就说明下载过
if (fFile.exists()) {
//读取出下载的进度
BufferedReader br = new BufferedReader(new FileReader(fFile));
String readLine = br.readLine();

currentPosition = Integer.parseInt(readLine);
conn.setRequestProperty("range", "bytes=" + currentPosition
+ "-" + endIndex);

rf.seek(currentPosition);
br.close();
} else {
// 说明没有下载过
conn.setRequestProperty("range", "bytes=" + startIndex
+ "-" + endIndex);

rf.seek(currentPosition);

}

// 获取获取码部分数据为206
int code = conn.getResponseCode();

if (code == 206) {

InputStream in = conn.getInputStream();
// 设置开始位置

// 开始写放
int len = 0;
byte[] buf = new byte[1024];
while ((len = in.read(buf)) != -1) {
rf.write(buf, 0, len);
// 用来记录当前的下载位置
currentPosition += len;
RandomAccessFile positionFile = new RandomAccessFile(
threadId + ".position", "rwd");
// 写入文件建立缓存
positionFile.write((currentPosition + "").getBytes());
positionFile.close();
}

rf.close();
in.close();
System.out.println("线程:" + threadId + "下载完成了");
//把下载完成的文件标记为完成
File file = new File(threadId+".position");
file.renameTo(new File(threadId+".position.finished"));
synchronized (DownTask.class) {
//线程数-1
runninThreadCount--;
if(runninThreadCount<=0){
for(int i=0;i<threadCount;i++){
File delFile = new File(i+".position.finished");
//删除
delFile.delete();
}

}
}
}

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

}
}

2889 次浏览