}

[1] [2] [3] [4] [5] 下一页  

　　HttpThread是负责处理Http连接的线程类，它接受一个URL和HttpListener：

class HttpThread extends Thread {

  private static final int MAX_LENGTH = 20 * 1024; // 20K

  private boolean cancel = false;

  private String url;

  private byte[] buffer = null;

  private HttpListener listener;

  public HttpThread(String url, HttpListener listener) {

    this.url = url;

    this.listener = listener;

  }

  public void cancel() { cancel = true; }

}

(2). 使用GET获取内容

　　我们先讨论最简单的GET请求。GET请求只需向服务器发送一个URL，然后取得服务器响应即可。在HttpThread的run()方法中实现如下：

public void run() {

  HttpConnection hc = null;

  InputStream input = null;

  try {

    hc = (HttpConnection)Connector.open(url);

    hc.setRequestMethod(HttpConnection.GET); // 默认即为GET

    hc.setRequestProperty("User-Agent", USER_AGENT);

    // get response code:

    int code = hc.getResponseCode();

    if(code!=HttpConnection.HTTP_OK) {

        listener.onError(code, hc.getResponseMessage());

        return;

    }

    // get size:

    int size = (int)hc.getLength(); // 返回响应大小，或者-1如果大小无法确定

    listener.onSetSize(size);

    // 开始读响应：

    input = hc.openInputStream();

    int percent = 0; // percentage

    int tmp_percent = 0;

    int index = 0; // buffer index

    int reads; // each byte

    if(size!=(-1))

        buffer = new byte[size]; // 响应大小已知，确定缓冲区大小

    else

        buffer = new byte[MAX_LENGTH]; // 响应大小未知，设定一个固定大小的缓冲区

    while(!cancel) {

        int len = buffer.length - index;

        len = len>128 ? 128 : len;

        reads = input.read(buffer, index, len);

        if(reads<=0)

          break;

        index += reads;

        if(size>0) { // 更新进度

          tmp_percent = index * 100 / size;

          if(tmp_percent!=percent) {

            percent = tmp_percent;

            listener.onProgress(percent);

          }

上一页  [1] [2] [3] [4] [5] 下一页