searchcity.java

《Java程序设计实践教程》代码

/***************************************************
*  程序文件名称：　searchCity.java
*  功能：连接服务器，与服务器进行数据交换
***************************************************/
import javax.microedition.midlet.*;
import javax.microedition.lcdui.*;
import javax.microedition.io.*;
import java.io.*;

public class searchCity extends Thread{
  //临时字符变量
  private String s=null;						
  //连接对象
  private SocketConnection  mysocket;		
  //输入流
  private DataInputStream in=null;			
  //输出流
  private DataOutputStream out=null;			
  //查询的地区名称
  private String city;							
  
  public searchCity(String m) {
   //传入地区名称
  	city = m;								
  	//线程开始
  	this.start();							
  }

  public void run(){
    try {
    	//创建连接,端口为5000
      mysocket=(SocketConnection)Connector.open("socket://localhost:5000");
      //创建输入数据流
      in = mysocket.openDataInputStream();			
      //创建输出数据流
      out = mysocket.openDataOutputStream();		
      //发送地区名称
      out.writeUTF(city);							
      //循环监听消息返回
      while(true){									
		//读取返回的信息
        s=in.readUTF();
        //检查收到的消息
        if(s!=""){									
         	//回应服务器
          out.writeUTF("Get");					
			//显示"已查信息"窗口用来显示信息
          Info_client.instance.preDisplay.setInfo(s);
          Info_client.instance.display.setCurrent(Info_client.instance.preDisplay);
          //断开连接
          mysocket.close();							
          //完成查询，跳出循环
          break;									
        }
      }
    }catch(ConnectionNotFoundException cnfe){
    	//显示连接错误提示
      Alert a = new Alert("Error","找不到服务器",null,AlertType.ERROR);
      a.setTimeout(Alert.FOREVER);
      Info_client.instance.display.setCurrent(a);
    }catch(IOException ioe){
    }
  }
}