012_04Thread+Handler实例应用之号码归属地查询

　　在Android的应用启动时，会创建一个主线程，主线程会创建一个消息队列来处理各种消息。当你创建子线程时，你可以在你的子线程中拿到父线程中创建的Handler 对象，就可以通过该对象向父线程的消息队列发送消息了。由于Android要求在UI线程中更新界面，因此，可以通过该方法在其它线程中更新界面。

　　每个handler 对应一个线程 thread , 在子线程中 handler 发送的消息会进入到 Message Queue当中去，由 looper 再来分发给 Handler 处理。





　　我们创建的Service、Activity以及Broadcast均是一个主线程处理，这里我们可以理解为UI线程。但是在操作一些耗时操作时，比如I/O读写的大文件读写，数据库操作以及网络下载需要很长时间，为了不阻塞用户界面，出现ANR（Application Not Responding）的响应提示窗口，这个时候我们可以考虑使用Thread线程来解决。

使用以下链接去浏览器中访问：
http://api.k780.com:88/app=phone.get&phone=18566669900
&appkey=14114&sign=ede788f7bf8d0678e281f660654ef995&format=xml

得到xml格式的如下结果：（代码中需要获取的城市和运营商黄色标注）

<root>

　　<success>1</success>

　　<result>

　　　　<status>ALREADY_ATT</status>
　　　　<phone>18566669900</phone>
　　　　<area>0755</area>
　　　　<postno>518000</postno>
　　　　<att>中国,广东,深圳</att>
　　　　<ctype>联通185卡</ctype>
　　　　<par>1856666</par>
　　　　<prefix>185</prefix>
　　　　<operators>联通</operators>
　　　　<style_simcall>中国,广东,深圳</style_simcall>
　　　　<style_citynm>中华人民共和国,广东省,深圳市</style_citynm>

　　</result>

</root>

使用以下链接去浏览器中访问：
http://api.k780.com:88/app=phone.get&phone=18566669900
&appkey=14114&sign=ede788f7bf8d0678e281f660654ef995&format=json

得到json格式的如下结果：（代码中需要获取的城市和运营商黄色标注）

{"success":"1","result":{"status":"ALREADY_ATT","phone":"18566669900","area":"0755","postno":"518000","att":"中国,广东,深圳","ctype":"联通185卡","par":"1856666","prefix":"185","operators":"联通","style_simcall":"中国,广东,深圳","style_citynm":"中华人民共和国,广东省,深圳市"}}

查询效果图：

　　第一个按钮“查询”是使用HttpURLConnection+Thread+Handler+xml解析去获取;

　　第二个按钮“json查询”是使用HttpURLConnection+Thread+Handler+json解析去获取；

　　第三个按钮“使用Async-http-master xml查询”是使用AsyncHttpClient+AsyncHttpResponseHandler+xml解析去获取；

　　第四个按钮“使用Async-http-master json查询”是使用AsyncHttpClient+AsyncHttpResponseHandler+json解析去获取；

package com.example.day12_04phonenumberqurey;

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

import org.apache.http.Header;
import org.json.JSONException;
import org.json.JSONObject;
import org.xmlpull.v1.XmlPullParser;

import com.cskaoyan.webutils.WebUtils;
import com.loopj.android.http.AsyncHttpClient;
import com.loopj.android.http.AsyncHttpResponseHandler;

import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.util.Xml;
import android.view.View;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;

public class MainActivity extends Activity {

public static final String TAG = "phonenumberqurey";
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
}

Handler hanlder = new Handler(){
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
switch (msg.what) {
case 1:
TextView tv_loaction = (TextView) findViewById(R.id.tv_location);
tv_loaction.setText((String)msg.obj);
break;
case 2:
Toast.makeText(MainActivity.this, (String)msg.obj, 0).show();
break;
default:
break;
}
}
};

public void query(View v){
//先获取电话号码
EditText et_number = (EditText) findViewById(R.id.et_number);
String number = et_number.getText().toString();
//http://api.k780.com:88...提供电话号码归属地查询的数据接口
final String path ="http://api.k780.com:88/?app=phone.get&phone="
+number+"&appkey=14114&sign=ede788f7bf8d0678e281f660654ef995&format=xml";

//发请求的线程
Thread thread = new Thread(){
public void run() {
try {
URL url = new URL(path);
HttpURLConnection conn= (HttpURLConnection) url.openConnection();
conn.setReadTimeout(5000);
conn.setConnectTimeout(5000);
conn.setRequestMethod("GET");
conn.connect();

String city =null;
String operator = null;
if(conn.getResponseCode()==200)
{
//登陆成功
//登陆失败？
InputStream is= conn.getInputStream();
//String text = WebUtils.gettextFromInputStream(is, null);
XmlPullParser pullparser = Xml.newPullParser();
pullparser.setInput(is, "UTF-8");

//得到读取到的某部分的类型
int evenType = pullparser.getEventType();
while(evenType!=XmlPullParser.END_DOCUMENT)
{
if (evenType==XmlPullParser.START_TAG)
{
Log.i(TAG, "START_TAG"+pullparser.getName());
if ("operators".equals(pullparser.getName()))
{
operator=pullparser.nextText();
}
if ("style_citynm".equals(pullparser.getName()))
{
city=pullparser.nextText();
}
}
evenType=pullparser.next();
}

Log.i(TAG,operator+":"+city);
Message msg = hanlder.obtainMessage();
msg.what=1;
if(city==null||operator==null)
{
msg.obj="没有查询到结果";
}

else
{
msg.obj= city+":"+operator;
}
hanlder.sendMessage(msg);
}
else
{
Message msg = hanlder.obtainMessage();
msg.what=2;
msg.obj="没有链接到服务器";
hanlder.sendMessage(msg);
}

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

public void querybyjson(View v){
//先获取电话号码
EditText et_number = (EditText) findViewById(R.id.et_number);
String number = et_number.getText().toString();
final String path ="http://api.k780.com:88/?app=phone.get&phone="+
number+"&appkey=14114&sign=ede788f7bf8d0678e281f660654ef995&format=json";

//发请求的线程
Thread thread = new Thread()
{
public void run()
{
try
{
URL url = new URL(path);
HttpURLConnection conn= (HttpURLConnection) url.openConnection();
conn.setReadTimeout(5000);
conn.setConnectTimeout(5000);
conn.setRequestMethod("GET");
conn.connect();

String city =null;
String operator = null;
if(conn.getResponseCode()==200)
{
//登陆成功
//登陆失败？
InputStream  is= conn.getInputStream();
String text = WebUtils.gettextFromInputStream(is, null);

JSONObject  jsonObject = new JSONObject(text);
JSONObject result = jsonObject.getJSONObject("result");
city= result.getString("style_citynm");
operator = result.getString("operators");
Log.i(TAG,operator+":"+city);

Message msg = hanlder.obtainMessage();
msg.what=1;

if(city==null||operator==null)
msg.obj="没有查询到结果";
else
msg.obj= city+":"+operator;

hanlder.sendMessage(msg);
}
else
{
Message msg = hanlder.obtainMessage();
msg.what=2;
msg.obj="没有链接到服务器";
hanlder.sendMessage(msg);
}

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

public void querybyxml_async(View v)
{
EditText et_number = (EditText) findViewById(R.id.et_number);
String number = et_number.getText().toString();
final String path ="http://api.k780.com:88/?app=phone.get&phone="+
number+"&appkey=14114&sign=ede788f7bf8d0678e281f660654ef995&format=xml";

AsyncHttpClient asyncHttpClient = new AsyncHttpClient();
asyncHttpClient.post(path, new Myhandler2());
}

public void querybyjson_aysnc(View v)
{
EditText et_number = (EditText) findViewById(R.id.et_number);
String number = et_number.getText().toString();
final String path ="http://api.k780.com:88/?app=phone.get&phone="+
number+"&appkey=14114&sign=ede788f7bf8d0678e281f660654ef995&format=json";

AsyncHttpClient asyncHttpClient = new AsyncHttpClient();
asyncHttpClient.post(path, new Myhandler());
}

class Myhandler extends AsyncHttpResponseHandler
{
@Override
public void onSuccess(int statusCode, Header[] headers, byte[] responseBody)
{
String city =null;
String operator = null;

JSONObject jsonObject =null;
try
{
jsonObject = new JSONObject(new String(responseBody));
JSONObject result = jsonObject.getJSONObject("result");
city=      result.getString("style_citynm");
operator = result.getString("operators");
}
catch (JSONException e)
{
e.printStackTrace();
}
TextView tv_loaction = (TextView) findViewById(R.id.tv_location);
tv_loaction.setText(city+":"+operator);
}

@Override
public void onFailure(int statusCode, Header[] headers,
byte[] responseBody, Throwable error) {
// TODO Auto-generated method stub

}
}

class Myhandler2 extends AsyncHttpResponseHandler
{

@Override
public void onSuccess(int statusCode, Header[] headers, byte[] responseBody) {
String city =null;
String operator = null;

XmlPullParser pullparser = Xml.newPullParser();
ByteArrayInputStream bais= new ByteArrayInputStream(responseBody);
try {
pullparser.setInput(bais, "utf-8");
//得到读取到的某部分的类型
int evenType = pullparser.getEventType();

while(evenType!=XmlPullParser.END_DOCUMENT){
if (evenType==XmlPullParser.START_TAG) {
Log.i(TAG, "START_TAG"+pullparser.getName())    ;
if ("operators".equals(pullparser.getName())) {
operator=pullparser.nextText();
}
if ("style_citynm".equals(pullparser.getName())) {
city=pullparser.nextText();
}
}
evenType=pullparser.next();
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
TextView tv_loaction = (TextView) findViewById(R.id.tv_location);
tv_loaction.setText(city+":"+operator);
}

@Override
public void onFailure(int statusCode, Header[] headers,
byte[] responseBody, Throwable error)
{
// TODO Auto-generated method stub

}
}
}

package com.cskaoyan.webutils;

import java.io.ByteArrayOutputStream;
import java.io.InputStream;

public class WebUtils {

public static String gettextFromInputStream(InputStream is ,String charset){
String text = null;

if(charset==null){
charset="utf-8";
}

try {
ByteArrayOutputStream baos= new ByteArrayOutputStream();

byte[] b = new byte[1024];
int len = 0;
while ((len=is.read(b))!=-1) {
baos.write(b, 0, len);
}
baos.close();

text = new String(baos.toByteArray(), charset);

} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return  text;
}
}

<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"
android:paddingBottom="@dimen/activity_vertical_margin"
android:paddingLeft="@dimen/activity_horizontal_margin"
android:paddingRight="@dimen/activity_horizontal_margin"
android:paddingTop="@dimen/activity_vertical_margin"
tools:context="com.example.day12_04phonenumberqurey.MainActivity" >

<TextView
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="归属地查询" />

<EditText
android:id="@+id/et_number"
android:layout_width="fill_parent"
android:layout_height="wrap_content" />

<Button
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:onClick="querybyxml"
android:text="查询" />

<Button
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:onClick="querybyjson"
android:text="json查询" />

<Button
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:onClick="querybyxml_async"
android:text="使用Async-http-master xml查询" />

<Button
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:onClick="querybyjson_aysnc"
android:text="使用Async-http-master json查询" />

<TextView
android:id="@+id/tv_location"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="归属地"/>
</LinearLayout>