异步网络操作

lukang

package com.RSSReader;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;

import android.os.Message;

public class HttpLoad  implements Runnable {
static String url = "http://rss.news.yahoo.com/rss/topstories";
private static InputStream is;

public void run() {

Message msg = Message.obtain();
msg.what = RssTitleList.MSG_UPDATE_TEXT;
try {
msg.obj = new String(HttpLoad.get(url));
} catch (IOException e) {
e.printStackTrace();
}
RssTitleList.handler.handleMessage(msg);
}

public final static byte[] readDataFromStream(InputStream aIs, int aCache) {

byte[] sData = null;

java.io.ByteArrayOutputStream bos = new ByteArrayOutputStream();

try {

byte[] sCaceh = new byte[aCache];

int pos = 0;

int hasRead = 0;

while ((pos = aIs.read(sCaceh, 0, aCache)) != -1) {

hasRead += pos;

bos.write(sCaceh, 0, pos);

}

sData = bos.toByteArray();

} catch (Exception e) {

}

return sData;

}

private static HttpURLConnection hc = null;

public static InputStream getConnection(String url) {
try {
URL u = new URL(url);

HttpURLConnection.setFollowRedirects(true);
hc = (HttpURLConnection) u.openConnection();
hc.setRequestMethod("GET");
hc.setUseCaches(false);
hc.addRequestProperty("Accept", "*/*");
hc.addRequestProperty("User-Agent",
"Mozilla/4.0 (compatible; MSIE)");
hc.connect();
int code = hc.getResponseCode();
if (code != 200) {
throw new IOException("Response code not ok");
} else {
is = hc.getInputStream();
}
} catch (IOException e) {
e.printStackTrace();
} finally {

}
return is;
}

public static byte[] get(String url) throws IOException {
byte[] rs = HttpLoad.readDataFromStream(HttpLoad.getConnection(url),
2048);
// 关闭连接:
if (is != null) {
try {
is.close();
} catch (IOException e) {

}
}
if (hc != null) {
hc.disconnect();
}
return rs;
}
}