开发J2ME低级联网应用[1]

作者：mingjava   文章来源：http://www.j2medev.com/Article/ShowArticle.asp?ArticleID=46

在开发J2ME联网应用程序中介绍了如何通过Http协议进行联网，通常我们把通过Http联网叫做高级联网，在这片文章中我们讲述如何使用Socket在TCP/IP层进行联网操作。如果你还不清楚J2ME平台的通用联网框架，那么请参考介绍J2ME通用联网框架。

    在MIDP2.0中提供了如下重要的类对TCP/IP和UDP进行支持。
javax.microedition.io.SocketConnection
javax.microedition.io.ServerSocketConnection
javax.microedition.io.UDPDatagramConnection
今天主要讲述在客户端使用SocketConnection和TCP/IP服务器进行通信，后面的两个类将在后续的文章中介绍，SocketConnection定义了socket流连接。调用Connector.open("socket://host:port")会返回一个SocketConnection的实例。通过调用socket.openInputStream()和socket.openOutputStream()两个方法我们将得到InputStream和OutputStream的实例，这样我们就可以和服务器进行通信了，如下所示：
SocketConnection client = (SocketConnection) Connector.open("socket://" + hostname + ":" + port);
client.setSocketOption(DELAY, 0);
client.setSocketOption(KEEPALIVE, 0);
InputStream is = client.openInputStream();
OutputStream os = client.openOutputStream();
os.write("some string".getBytes());
int c = 0;
while((c = is.read()) != -1) {
   // do something with the response
}
is.close();
os.close();
client.close();

    注意在联网的时候我们还是必须要在另一个线程内进行联网操作，而不能再主线程进行。这样的目的是为了避免用户界面的堵塞。通常我们可以定义一个类扩展Thread类并提供一个把MIDlet作为参数的构造器，为了提高效率我们通过使用wait()和notify()方法，这样只有在用户按下按钮的时候，线程才被唤醒去执行联网操作，否则再启动后他一直出去"wait"的状态。
class CommandThread extends Thread {
    MIDlet parent;

    StreamConnection socket = null;
    InputStream is = null;

    boolean exit = false;

    public CommandThread(MIDlet parent) {
      this.parent = parent;
    }

      public void run() {
        while (!exit) {
          synchronized(parent) {
            while(!commandAvailable) {
              try {
                parent.wait();
              }
              catch (InterruptedException e) {
              }
            }
          }

    ......................
    ..................

    TCP/IP服务器的写法和一般的服务器写法是一样的，因此不再多介绍。如果有问题可以参考java.net包的内容。下面通过例子演示一下，我们构建一个时间服务器，在手机端来通过socket访问并得到当前时间显示在屏幕上。代码如下：
import java.io.BufferedOutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.ServerSocket;
import java.util.Date;

public class DayTimeServer {

  public static void main(String args[]) {

    int dayTimePort = 13;

    if (args.length == 1) {
      try {
        dayTimePort = Integer.parseInt(args[0]);
      }
      catch (NumberFormatException e) {
        System.out.println("invalid port number");
        System.exit(0);
      }
    }

    ServerSocket serverSocket = null;
    Socket sock;

    DataOutputStream dataout;   

    try {
      serverSocket = new ServerSocket(dayTimePort);
    }
    catch (IOException e) {
      System.out.println(e.getMessage());
      e.printStackTrace();
      System.exit(0);
    }