getuserdatathread.java

j2me实例代码

package serverlet;

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

public class GetUserDataThread extends Thread {
	String url;
	Vector data=new Vector();
	public GetUserDataThread(String url) {
		this.url=url;
		System.out.println("准备连接："+this.url);
	}

	public void run(){
		boolean error=false;
		HttpConnection conn=null;
		InputStream is=null;
		DataInputStream dos=null;
		try{
			System.out.println("open conn.......");
			conn=(HttpConnection)Connector.open(url);
			System.out.println("open conn.......");
			is=conn.openInputStream();
			dos=new DataInputStream(is);
			while(true){
				String line=dos.readUTF();
				System.out.println("this is line:"+line);
				parseAndInsert(data,line);
			}
		}catch(EOFException e){
			
		}catch(Exception e){
			error=true;
			Alert al=new Alert("联机时期发生错误！",e.toString(),null,AlertType.ALARM);
			al.setTimeout(Alert.FOREVER);
			Navigator.display.setCurrent(al);
		}finally{
			try{
				if(conn!=null)
					conn.close();
			}catch(Exception e){}
		}
		
		if(!error){
			Navigator.current=Navigator.USERDATA_SCREEN;
			Navigator.show(data);
		}
	}
	public void parseAndInsert(Vector v,String s){
		int i=s.indexOf(",");
		String id=s.substring(0,i);
		s=s.substring(i+1);
		i=s.indexOf(",");
		String ps=s.substring(0,i);
		s=s.substring(i+1);
		i=s.indexOf(";");
		String ds=s.substring(0,i);
		v.addElement(id+" / "+ps+" / "+ds);
	}
}