workthread.java

j2me实例代码

package socket;

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

public class WorkThread extends Thread {
	String query;
	Display display;
	public WorkThread(String query,Display d){
		this.query=query;
		display=d;
	}
	
	public void run(){
		String url="socket://127.0.0.1:8189";
		SocketConnection conn=null;
		InputStream is=null;
		OutputStream os=null;
		DataInputStream dis=null;
		DataOutputStream dos=null;
		String line="";
		try{
			conn=(SocketConnection)Connector.open(url);
			is=conn.openInputStream();
			os=conn.openOutputStream();
			dis=new DataInputStream(is);
			dos=new DataOutputStream(os);
			dos.writeUTF(query);
			dos.flush();
			while(true){
				line=line+dis.readUTF();
			}
		}catch(Exception e){}
		finally{
			try{
				if(conn!=null){
					conn.close();
				}
			}catch(Exception e){}
		}
		Alert al=new Alert("query result",line,null,AlertType.CONFIRMATION);
		al.setTimeout(Alert.FOREVER);
		display.setCurrent(al);
	}
	

}