|
序列化方法serialize()很简单，仅仅是按照HTTP GET方法的格式进行查询条件组装，就像之前说到的，这里因为没有涉及到中文字符，所以无需进行UTF-8编码转换。”deserializes()”方法进行多对象的反序列化，并构造成TransAuto数组在手机上显示，需要强调的是根据分页策略，进行一次反序列化的TransAuto对象实例条数最多20条。服务器端返回的数据并不是按照HTTP GET方法的格式，而是根据表中字段的顺序再在中间加”&”进行分割的字符串，遗憾的是手机上String对象未提供”split()”方法，”Split.split(recString,"&")”方法化解了这一问题，下面是实现代码(来自于互联网)。 /** * 分割字符串 * * @param original 需要分割的字符串 * @paran regex 表达式 * @return 分割后生成的字符串数组 */ public static String[] split(String original, String regex) { int startIndex = 0; Vector v = new Vector(); String[] str = null; int index = 0; startIndex = original.indexOf(regex); while (startIndex < original.length() && startIndex != -1) { String temp = original.substring(index, startIndex); v.addElement(temp); index = startIndex + regex.length(); startIndex = original.indexOf(regex, startIndex + regex.length()); } v.addElement(original.substring(index + 1 - regex.length())); str = new String[v.size()]; for (int i = 0; i < v.size(); i++) { str[i] = (String) v.elementAt(i); } return str; } 一旦所有前期工作都准备好，将是最关键的GoodsFindAutoThread线程类连接服务器返回数据，为了让界面美观，在进入线程类之后GoodsFindAuto类马上通过”Navigator.display.setCurrent(WaitForm.getInstance())”代码把画面转移到WaitForm，一个等待画面，上面写着“正在连接服务器，请稍等...”，直到线程类和服务器交互完毕，这个画面将由线程类负责切换。 package com.forbidden.thread; import java.io.ByteArrayInputStream; import java.io.DataInputStream; import java.io.InputStream; import javax.microedition.io.Connector; import javax.microedition.io.HttpConnection; import javax.microedition.lcdui.Alert; import javax.microedition.lcdui.AlertType; import javax.microedition.rms.RecordStore; import com.forbidden.screen.*; import com.forbidden.util.Split; import com.forbidden.vo.TransAuto; /* 货主找车线程 * @author rosen jiang * @since 2005-12 */ public class GoodsFindAutoThread extends Thread{ private String url; //服务器地址 private String autoFrom; //车辆出发地 private String autoTarget; //车辆目的地 private String pubDate; //发布日期 /** * 构造函数 * * @param page 请求页数 * @param perPage 每页条数 * @param ta 构造好的条件对象 */ public GoodsFindAutoThread(int page,int perPage,TransAuto ta){ String userName=null; try { //取出当前用户名，以便进行数据库端日志记录。 RecordStore rs = RecordStore.openRecordStore("app",false); userName = new String(rs.getRecord(1)); rs.closeRecordStore(); } catch (Exception e) { } this.url = "http://127.0.0.1:8080/AirTransport/servlet/GoodsFindAuto?userName=" + userName+"&page="+page+"&perPage="+perPage+"&"+ta.serialize(); this.autoFrom = ta.getAutoFrom(); this.autoTarget = ta.getAutoTarget(); this.pubDate = ta.getPubDate(); } public void run(){ InputStream is = null; HttpConnection c = null; try { c = (HttpConnection)Connector.open(url); //接收输出流 is = new DataInputStream(c.openInputStream()); int i = (int) c.getLength(); byte [] recData = new byte[i]; is.read(recData); is.close(); c.close(); //未找到符合条件的车辆 if (recData[0]+recData[1]!=0) { ByteArrayInputStream bin = new ByteArrayInputStream(recData); DataInputStream din = new DataInputStream(bin); Alert al = new Alert ("查询结果",din.readUTF(),null,AlertType.CONFIRMATION); al.setTimeout(Alert.FOREVER); din.close(); bin.close(); Navigator.display.setCurrent(al,GoodsFindAuto.getInstance()); } else { //找到符合条件的车辆 //丢掉两个错误信息字节数据 byte[] reRecData = new byte[recData.length-2]; System.arraycopy(recData,2,reRecData,0,recData.length-2); ByteArrayInputStream bin = new ByteArrayInputStream(reRecData); //结果数据输入流 DataInputStream dis = new DataInputStream(bin); int count = Integer.parseInt(dis.readUTF()); //总数 int total = Integer.parseInt(dis.readUTF()); //总页数 int current = Integer.parseInt(dis.readUTF()); //当前页码 TransAuto ta = new TransAuto(null, null, null, null, null, null, null, null); TransAuto[] tas = null; tas = ta.deserializes(autoFrom,20,dis); dis.close(); bin.close(); Navigator.display.setCurrent(GFAList.getInstance(count,total,current,autoFrom,autoTarget,pubDate,tas)); } } catch(Exception e){ Alert al = new Alert ("查询发生错误",e.toString(),null,AlertType.ERROR); al.setTimeout(Alert.FOREVER); Navigator.display.setCurrent(al,GoodsFindAuto.getInstance()); } } } 在GoodsFindAutoThread()构造函数中，首先取出了记录在RMS中的当前登陆者名，以便服务器记录用户的查询条件，以后为不同的客户提供个性化服务，接着把用户输入的检索条件记录下来，取第5页的时候要用到，然后按照之前构造好的TransAuto实例进行序列化生成URL字符串。在”run()”方法中，为了判断是否返回了正确数据，我在服务器端的代码中设置了标识，既：如果查询结果为0条或服务器端发生任何错误，那么返回数据的前个两字节不为空，反之则亦然。收到正确的查询结果之后，先丢弃前两个字节，然后转换成输入流，”int count = Integer.parseInt(dis.readUTF())”第一组字节流是总记录数，”int total = Integer.parseInt(dis.readUTF())”第二组字节流是总页数，”int current = Integer.parseInt(dis.readUTF())”第三组字节流是当前页码。取完基本信息后，接着取车辆数据，通过”tas = ta.deserializes(autoFrom,20,dis)”反序列化之后得到TransAuto数组对象。最后进入GFAList类进行数据列表，代码” Navigator.display.setCurrent(GFAList.getInstance(count,total,current,autoFrom,autoTarget,pubDate,tas))”把检索条件全部记录下来，其做用也是为了再次分页的需要。 package com.forbidden.screen; import javax.microedition.lcdui.Alert; import javax.microedition.lcdui.AlertType; import javax.microedition.lcdui.Command; import javax.microedition.lcdui.CommandListener; import javax.microedition.lcdui.Displayable; import javax.microedition.lcdui.List; import com.forbidden.thread.GoodsFindAutoThread; import com.forbidden.vo.TransAuto; /* 货主找车列表 * @author rosen jiang * @since 2005-12 */ public class GFAList extends List implements CommandListener{ private Command backCommand; private Command funCommand; private Command preCommand; private Command nextCommand; private static String autoFrom; //车辆出发地 private static String autoTarget; //车辆目的地 private static String pubDate; //发布日期 private static int count; //总数 private static int total; //总页数 private int current; //当前页码 private TransAuto[] newTas; //车辆数组 public static Displayable instance; //对象实例 /** * 获取对象实例 * * @param coun //总数 * @param tot //总页数 * @param curr //当前页码 * @param from //车辆出发地 * @param target //车辆目的地 * @param date //发布日期 * @param tas //车辆数组 * @return */ synchronized public static Displayable getInstance(int coun,int tot,int curr,String from,String target,String date,TransAuto[] tas){ autoFrom = from; count = coun; autoTarget = target; pubDate = date; total = tot; instance = new GFAList(curr,tas,List.IMPLICIT); return instance; } /** * 构造函数 * @param curr //当前页码 * @param tas //车辆数组 * @param i //表现方式 */ public GFAList(int curr,TransAuto[] tas,int i){ super(curr+"/"+total+"页 共"+count+"条记录",i); this.current = curr; this.newTas = tas; for(int j=0; j<5; j++){ try{ TransAuto ta = null; if(curr%4==0){ ta = tas[j+15]; }else if(curr%4==1){ ta = tas[j]; }else if(curr%4==2){ ta = tas[j+5]; }else if(curr%4==3){ ta = tas[j+10]; } append(ta.getName()+"," +ta.getPhone()+".",null); }catch(java.lang.NullPointerException e){ break; } } backCommand = new Command("货主找车", Command.BACK, 1); funCommand = new Command("详情", Command.SCREEN, 1); preCommand = new Command("上一页", Command.SCREEN, 1); nextCommand = new Command("下一页", Command.SCREEN, 1); addCommand(backCommand); addCommand(funCommand); addCommand(preCommand); addCommand(nextCommand); setCommandListener(this); } /** * 对用户输入命令作出反应 * @param c 命令 * @param s Displayable 对象 */ public void commandAction(Command c, Displayable s) { String cmd = c.getLabel(); if (cmd.equals("货主找车")){ Navigator.flow(cmd); //翻页(下一页)处理 } else if (cmd.equals("下一页")){ if(total == current){ Alert al = new Alert ("提示","已到达最后一页。",null,AlertType.CONFIRMATION); al.setTimeout(Alert.FOREVER); Navigator.display.setCurrent(al); } else if (current % 4 != 0){ Navigator.display.setCurrent(getInstance(count,total,current+1,autoFrom,autoTarget,pubDate,newTas)); //如果当前页已经是4的倍数页，那么连接服务器取下20条数据。 } else if (current % 4 == 0){ TransAuto ta = new TransAuto(null,null,null,null, pubDate,autoFrom,autoTarget, null); GoodsFindAutoThread gfat = new GoodsFindAutoThread(current+1,20,ta); Navigator.display.setCurrent(WaitForm.getInstance()); gfat.start(); } //翻页(上一页)处理 } else if (cmd.equals("上一页")){ if(current == 1){ Alert al = new Alert ("提示","这是第一页。",null,AlertType.CONFIRMATION); al.setTimeout(Alert.FOREVER); Navigator.display.setCurrent(al); } else if ((current - 1) % 4 != 0){ Navigator.display.setCurrent(getInstance(count,total,current-1,autoFrom,autoTarget,pubDate,newTas)); //如果当前页已经是4的倍数页，那么连接服务器取上20条数据。 } else if ((current - 1) % 4 == 0){ TransAuto ta = new TransAuto(null,null,null,null, pubDate,autoFrom,autoTarget, null); GoodsFindAutoThread gfat = new GoodsFindAutoThread(current-1,20,ta); Navigator.display.setCurrent(WaitForm.getInstance()); gfat.start(); } //详情处理 } else if (cmd.equals("详情")){ if(current % 4 == 0){ Navigator.display.setCurrent(GFAInfo.getInstance(newTas[getSelectedIndex()+15])); } else if (current % 4 == 1){ Navigator.display.setCurrent(GFAInfo.getInstance(newTas[getSelectedIndex()])); } else if (current % 4 == 2){ Navigator.display.setCurrent(GFAInfo.getInstance(newTas[getSelectedIndex()+5])); } else if (current % 4 == 3){ Navigator.display.setCurrent(GFAInfo.getInstance(newTas[getSelectedIndex()+10])); } } } } 构造函数GFAList除了创建几个命令以外，最主要的工作是显示本页数据，通过当前页码与4取模之后再从TransAuto数组得到准确数据并显示在屏幕上。还是让我们先睹为快吧，这次截图不是模拟器上，而是运行在我的索爱K700c上真实环境。 看完截图，回到”commandAction()”方法上，当用户进行”下一页”操作的时候，首先判定当前页是不是最后一页，如果是”Alert al = new Alert ("提示","已到达最后一页。",null,AlertType.CONFIRMATION)”代码给用户一个Alert提示。如果当前页是4的倍数页，”GoodsFindAutoThread gfat = new GoodsFindAutoThread(current+1,20,ta)”代码连接服务器取回下20条数据，这个时候要进入WaitForm画面进行等待，就像首次进行查询一样，之前一直保存着的查询参数也就派上用场了。如果还不是4的倍数，”Navigator.display.setCurrent(getInstance(count,total,current+1,autoFrom,autoTarget,pubDate,newTas))”这行代码就把修改后的数据再次送到GFAList对象的构造函数中，重新实例化画面，也就在手机上实现了不用连接服务器的快速翻页。”上一页”操作和刚才谈到的”下一页”操作类似，就不多说了。如果用户点击”详情”看某条车辆信息的时候，需要计算被点击信息所处的绝对位置，比如当前页码正好是4的倍数，那么可以断定该条信息处于整个TransAuto数组的末端，也就是最后一页，然后取得这条记录的相对位置(例如3)再加上15，就是这条记录的绝对位置了，其他位置以此类推，”Navigator.display.setCurrent(GFAInfo.getInstance(newTas[getSelectedIndex()+15]))”代码把某个选中的车辆信息送入GFAInfo对象以显示详细信息。 package com.forbidden.screen; import javax.microedition.lcdui.Command; import javax.microedition.lcdui.CommandListener; import javax.microedition.lcdui.Displayable; import javax.microedition.lcdui.Form; import javax.microedition.lcdui.TextField; import com.forbidden.vo.TransAuto; /* 车辆详情 * @author rosen jiang * @since 2005-12 */ public class GFAInfo extends Form implements CommandListener{ private Command backCommand; private static Displayable instance; private TextField nameField; private TextField autoNoFiled; private TextField phoneFiled; private TextField autoCapField; private TextField pubDateField; private TextField autoFromField; private TextField autoTargetField; private TextField memoField; /** * 获取对象实例 * @param ta 车辆对象 * @return */ synchronized public static Displayable getInstance(TransAuto ta){ instance = new GFAInfo(ta); return instance; } /** * 构造函数 * * @param ta 车辆对象 */ public GFAInfo(TransAuto ta){ super("车辆详情"); backCommand = new Command("返回", Command.BACK, 1); nameField = new TextField("车主", ta.getName(), 25, TextField.ANY); autoNoFiled = new TextField("车牌号", ta.getAutoNo(), 25, TextField.ANY); phoneFiled = new TextField("电话", ta.getPhone(), 25, TextField.ANY); autoCapField = new TextField("重量", ta.getAutoCap(), 25, TextField.ANY); pubDateField = new TextField("发布日期", ta.getPubDate(), 25, TextField.ANY); autoFromField = new TextField("起始地", ta.getAutoFrom(), 25, TextField.ANY); autoTargetField = new TextField("目的地", ta.getAutoTarget(), 25, TextField.ANY); memoField = new TextField("备注", ta.getMemo(), 300, TextField.ANY); append(nameField); append(autoNoFiled); append(phoneFiled); append(autoCapField); append(pubDateField); append(autoFromField); append(autoTargetField); append(memoField); addCommand(backCommand); setCommandListener(this); } /** * 对用户输入命令作出反应 * @param c 命令 * @param s Displayable 对象 */ public void commandAction(Command c, Displayable s) { Navigator.display.setCurrent(GFAList.instance); } } GFAInfo 类代码显得很简单了，”getInstance()”方法每次都根据数据的不同重新构造实例，”GFAInfo()”构造函数则把TransAuto对象属性一一呈现出来，手机端实现也就告一段落了。 |
