小议J2ME手机游戏引擎程序架构

　　随着国内3G的启动，新一代移动通信大潮已经到来。技术的进步使得无线网络取得不错的发展，移动互联网巨大前景也随着显现。无线网络速度的提高，催生大量的手机联网应用程序。手机联网功能的强化，使得手机应用更具价值，进一步扩展了手机功能。

　　现在我们就来实现一个基于J2ME的手机联网程序。考虑到手机运算资源的限制，我们采用客户端/服务器 style="COLOR: #000000" href="http://server.it168.com/" target=_blank>服务器的模式来实现，J2ME只做为客户端运行于手机上，负责展现和处理简单的业务逻辑，保存少量的关键数据;服务器端采用J2EE实现，负责保存用户数据，以及响应在线用户的复杂业务逻辑。

　　在这里，服务端J2EE的实现不是本文的重点，所以只进行简单的描述，我们主要对手机客户端J2ME的讲解。

　　在J2ME客户端，我们可以采用的MVC软件架构模式，进行逻辑分层，使代码更为清晰，权责更为明确，也利于代码维护和功能升级。

　　1、Handle(Controller)：它既做为控制器，也做为简单逻辑处理器。如处理网络请求，网络消息分发。它是关键层，涉及到整体结构的每一层，用于控制应用程序的流程。它处理事件并作出响应。因为复杂业务逻辑的处理权责已经分化到服务器端，只处理简单的逻辑和少量的数据访问，所以此层没有进一步划分出业务层，统一划为处理层。

　　2、DAO：数据访问对象(Data Access Object)，用于封装数据的于Database的读取和存储 style="COLOR: #000000" href="http://storage.it168.com/" target=_blank>存储操作。便于Handle的调用完成简单业务逻辑的处理。

　　3、Database：用来存储少量数据，即负责关键数据的持久化。在J2ME中，RMS(Record Management System)是这个层次主要承担者。在实际应用中，如果数据间关系很简单，也可以选用文件进行保存，如XML格式或普通文本格式。Handler会控制对Database的存储和提取，用来View层显示。

　　4、Model：数据模型用于封装与应用程序的业务逻辑相关的数据以及对数据的处理方法。数据的抽象化分离了具体的View，也方便Handle对数据持久化操作。

　　5、View: 这层用来显示用户界面，并且响应和处理键盘的指令。将Handler层指派的一些信息显示出来，并且将需求信息送给Handler去处理。所以这层直接于Handler沟通，不会直接涉及到Database或网络信息。

　　我们这里做的这个联网程序是一个即时读取互联网资讯的工具，从任意一个网站的资讯列表页面获取其中的资讯标题和链接，返回给手机客户端。而在手机客户端选取一条资讯进行打开时，又去联网获取文章的文本内容。从服务器端返回的数据中只包含文本信息，无任何除资讯资讯URL的HTML数据。这样就大大减少了无用数据传输，降低了网络通信费用，提高访问速度，更为方便地访问WWW网站。

　　服务端要处理的业务逻辑有：根据提供的链接地址，获取页面内容并进行分析，提取资讯条目或资讯内容数据。返回给手机客户端。这部分的处理逻辑有一定的复杂，需要耗费一定的资源，所以将其划分到服务端进行处理。

　　客户端只负责发送请求和接收服务端返回的数据，进行简单处理后将内容呈现到用户浏览界面。相当于一个网页浏览器。

　　--演示截图-

-

1 package com.efan.wb.view;
2
3 import javax.microedition.lcdui.Command;
4 import javax.microedition.lcdui.CommandListener;
5 import javax.microedition.lcdui.Display;
6 import javax.microedition.lcdui.Displayable;
7 import javax.microedition.lcdui.Form;
8 import javax.microedition.lcdui.TextBox;
9 import javax.microedition.midlet.MIDlet;
10 import com.efan.wb.handle.WbAction;
11
12 public class WebBrowser extends MIDlet implements CommandListener {
13
14 private TextBox textbox;
15 private Display display = null;
16 private Form mainForm = null;
17 public static final Command exitCommand = new Command("Exit", Command.OK, 1);
18
19 public void startApp() {
20   Display.getDisplay(this).setCurrent(textbox);
21   if (display == null) {
22    display = Display.getDisplay(this);
23   }
24   mainForm = new Form("News Form");
25
26   // 从控制器加载
27   WbAction action = new WbAction();
28   String newsList = action.getNews();
29
30   mainForm.append(newsList);// 加载默认新闻标题列表
31   mainForm.addCommand(exitCommand);
32   mainForm.setCommandListener(this);
33   display.setCurrent(mainForm);
34 }
35
36 public void commandAction(Command cmd, Displayable displayable) {
37   if (cmd == exitCommand) {
38    destroyApp(false);
39    notifyDestroyed();
40   }
41 }
42
43 public void pauseApp() {
44 }
45
46 public void destroyApp(boolean unconditional) {
47 }
48 }
49
1 package com.efan.wb.handle;
2
3 import java.io.DataInputStream;
4 import java.io.IOException;
5
6 import javax.microedition.io.Connector;
7 import javax.microedition.io.HttpConnection;
8 import com.efan.wb.dao.WbDao;
9 import com.efan.wb.model.UrlEntity;
10
11 public class WbAction {
12
13 public String getNews() {
14
15   // 从RMS中获取默认的URL
16   WbDao dao = new WbDao();
17   UrlEntity ue = dao.getDefaultURL();
18   String url = ue.getUrl();
19
20   WebExplorer we = new WebExplorer(url);
21   we.start();// 启动网络新闻获取线程
22
23   // 轮循等待操作完成
24   while (!we.isComplete()) {
25    // 超时处理，此略
26   }
27   return we.getNewsList();
28 }
29
30 // 为了简化代码，把这个访问网络的线程类作为内部类
31 class WebExplorer extends Thread {
32
33   private String newsList;
34
35   private String url;
36
37   public WebExplorer(String url) {
38    this.url = url;
39   }
40
41   public WebExplorer() {
42   }
43
44   public void setUrl(String url) {
45    this.url = url;
46   }
47
48   private boolean isComplete() {
49    return this.newsList == null ? false : true;
50   }
51
52   public String getNewsList() {
53    return newsList;
54   }
55
56   public void run() {
57    try {  
58     HttpConnection conn = (HttpConnection) Connector.open(this.url);  
59     DataInputStream is = conn.openDataInputStream();
60     this.newsList = is.readUTF();
61    } catch (IOException e) {
62     e.printStackTrace();
63    }
64   }
65 }
66 }
67
1 package com.efan.wb.dao;
2
3 import com.efan.wb.model.UrlEntity;
4
5 public class WbDao {
6
7 public UrlEntity getDefaultURL() {
8
9   UrlEntity ue = new UrlEntity();
10   // 访问RMS，查询默认的URL，此略，直接硬编码来测试
11   String url = "http://localhost:8080/rss/news";
12   String name = "Test Web URL";
13
14   ue.setName(name);
15   ue.setUrl(url);
16
17   return ue;
18 }
19 }
1 package com.efan.wb.model;
2
3 public class UrlEntity {
4
5 private String name;
6
7 private String url;
8
9 public String getName() {
10   return name;
11 }
12
13 public void setName(String name) {
14   this.name = name;
15 }
16
17 public String getUrl() {
18   return url;
19 }
20
21 public void setUrl(String url) {
22   this.url = url;
23 }
24
25 }
1 package cn.rssweb.site.web;
2
3 import java.io.DataOutputStream;
4 import java.io.IOException;
5 import java.util.Iterator;
6 import java.util.List;
7
8 import javax.servlet.ServletException;
9 import javax.servlet.http.HttpServlet;
10 import javax.servlet.http.HttpServletRequest;
11 import javax.servlet.http.HttpServletResponse;
12
13 import cn.rssweb.edp.component.spider.RobotFactory;
14 import cn.rssweb.edp.component.spider.model.DataModel;
15 import cn.rssweb.edp.component.spider.robot.Robot;
16
17 public class NewsListServlet extends HttpServlet {
18
19 @Override
20 protected void doGet(HttpServletRequest request, HttpServletResponse response)
21    throws ServletException, IOException {
22   
23   String url = "http://www.techweb.com.cn/news/20.shtml";
24   
25   Robot robot = RobotFactory.getInstance(Robot.HTML,url);//服务器逻辑处理核心类，此略
26   List list = robot.parseList();
27   
28   Iterator it = list.iterator();
29   int i=0;
30   StringBuffer sb = new StringBuffer();
31   while(it.hasNext()){
32    i++;
33    DataModel data = (DataModel)it.next();
34    String title = data.getLinkText();
35    sb.append(i).append(".").append(title).append("\n");
36   }
37
38   DataOutputStream dos = new DataOutputStream(response.getOutputStream());
39
40   dos.writeUTF(sb.toString());
41   dos.flush();
42   dos.close();
43   
44 }
45
46 @Override
47 protected void doPost(HttpServletRequest arg0, HttpServletResponse arg1)
48    throws ServletException, IOException {
49   
50   super.doPost(arg0, arg1);
51 }
52
53 }