querythread.java

手机版的旅游信息系统

package com.wy.ch16;

import javax.microedition.lcdui.*;
import java.io.*;
import javax.microedition.io.*;
import java.util.*;

public class QueryThread extends Thread {
    private String location;
    private String date;
    private Displayable diaplay;
    private HttpConnection con;
    private DataInputStream dis;
    Vector v = new Vector(10);
    
    public QueryThread(String l,String da, Displayable d) {
        location = l;
        date=da;
        diaplay = d;
    }
    
    public void run() {
        StringBuffer stringbuffer=new StringBuffer("http://127.0.0.1:8080/travelserver/Query?location=");
        stringbuffer.append(location);
        stringbuffer.append("&date=");
        stringbuffer.append(date);
        String url =stringbuffer.toString();
        try {
            con = (HttpConnection) Connector.open(url);
            dis = con.openDataInputStream();
            int ch;
            StringBuffer buffer = new StringBuffer();
            while ((ch = dis.read()) != -1) {
                buffer.append((char) ch);
            }
            String result = new String(buffer.toString().getBytes("iso-8859-1"),"gb2312");
            if (result.length() == 0) {
                v =null;
            } else {
                boolean i = false;
                boolean a = false;
                boolean t = false;
                boolean p = false;
                int begin = 0;
                char c;
                TravelInfo travelinfo=new TravelInfo();
                for (int j = 0; j < result.length(); j++) {
                    c = result.charAt(j);
                    if (c == '#') {
                        i = false;
                        a = false;
                        t = false;
                        p = false;
                        begin = j + 1;
                        continue;
                    }
                    if (c == '*') {
                        if (!i) {
                            travelinfo.setId(result.substring(begin, j));
                            i = true;
                            begin = j + 1;
                            if(i&&a&&t&&p){
                                v.addElement(travelinfo);
                            }
                            continue;
                        }
                        if (!a) {
                            travelinfo.setAgency(result.substring(begin, j));
                            a = true;
                            begin = j + 1;
                            if(i&&a&&t&&p){
                                v.addElement(travelinfo);
                            }
                            continue;
                        }
                        if (!t) {
                            travelinfo.setTime(result.substring(begin, j));
                            t = true;
                            begin = j + 1;
                            if(i&&a&&t&&p){
                                v.addElement(travelinfo);
                            }
                            continue;
                        }
                        if (!p) {
                            travelinfo.setPrice(result.substring(begin, j));
                            p = true;
                            begin = j + 1;
                            if(i&&a&&t&&p){
                                v.addElement(travelinfo);
                            }
                            continue;
                        }
                        
                    }
                } //for
            }
        } catch (IOException ex) {
        }
        Display.getDisplay(MainMIDlet.getInstance()).setCurrent(new ChoiceList(diaplay,v));
    }
}