在J2ME中实现基于UDP协议通讯程序

package com.siemens.datagramtest;

import java.io.IOException;

import javax.microedition.io.ConnectionNotFoundException;
import javax.microedition.io.Connector;
import javax.microedition.io.Datagram;
import javax.microedition.io.DatagramConnection;
import javax.microedition.lcdui.Alert;
import javax.microedition.lcdui.AlertType;
import javax.microedition.lcdui.Command;
import javax.microedition.lcdui.CommandListener;
import javax.microedition.lcdui.Display;
import javax.microedition.lcdui.Displayable;
import javax.microedition.lcdui.Form;
import javax.microedition.lcdui.StringItem;
import javax.microedition.lcdui.TextField;

public class Client implements Runnable, CommandListener
{

　 private DatagramMIDlet parent;

　 private Display display;

　 private Form f;

　 private StringItem si;

　 private TextField tf;

　 private Command sendCommand = new Command("Send", Command.ITEM, 1);

　 Sender sender;

　 public Client(DatagramMIDlet m)
　 {
　　　 parent = m;
　　　 display = Display.getDisplay(parent);
　　　 f = new Form("Datagram Client");
　　　 si = new StringItem("Status:", " ");
　　　 tf = new TextField("Send:", "", 30, TextField.ANY);
　　　 f.append(si);
　　　 f.append(tf);
　　　 f.addCommand(sendCommand);
　　　 f.setCommandListener(this);
　　　 display.setCurrent(f);

　 }

　 public void start()
　 {
　　　 Thread t = new Thread(this);
　　　 t.start();
　 }

　 public void run()
　 {
　　　 try
　　　 {

　　　　　 DatagramConnection dc = (DatagramConnection) Connector
　　　　　　　　　 .open("datagram://localhost:5555");
　　　　　

　　　　　 si.setText("Connected to server");

　　　　　 sender = new Sender(dc);

　　　　　 while (true)
　　　　　 {
　　　　　　　 Datagram dg = dc.newDatagram(100);
　　　　　　　 dc.receive(dg);
　　　　　　　 // Have we actually received something or is this just a timeout
　　　　　　　 // ?
　　　　　　　 if (dg.getLength() > 0)
　　　　　　　 {
　　　　　　　　　 si.setText("Message received - "
　　　　　　　　　　　　　 + new String(dg.getData(), 0, dg.getLength()));
　　　　　　　 }
　　　　　 }

　　　 } catch (ConnectionNotFoundException cnfe)
　　　 {
　　　　　 Alert a = new Alert("Client", "Please run Server MIDlet first",
　　　　　　　　　 null, AlertType.ERROR);
　　　　　 a.setTimeout(Alert.FOREVER);
　　　　　 display.setCurrent(a);
　　　 } catch (IOException ioe)
　　　 {
　　　　　 ioe.printStackTrace();
　　　 }
　 }

　 public void commandAction(Command c, Displayable s)
　 {
　　　 if (c == sendCommand && !parent.isPaused())
　　　 {
　　　　　 sender.send(null, tf.getString());
　　　 }
　 }

　 public void stop()
　 {
　 }

}

package com.siemens.datagramtest;

import javax.microedition.lcdui.Choice;
import javax.microedition.lcdui.ChoiceGroup;
import javax.microedition.lcdui.Command;
import javax.microedition.lcdui.CommandListener;
import javax.microedition.lcdui.Display;
import javax.microedition.lcdui.Displayable;
import javax.microedition.lcdui.Form;
import javax.microedition.midlet.MIDlet;

public class DatagramMIDlet extends MIDlet implements CommandListener
{

　 private static final String SERVER = "Server";

　 private static final String CLIENT = "Client";

　 private static final String[] names = { SERVER, CLIENT };

　 private static Display display;

　 private Form f;

　 ChoiceGroup cg;

　 private boolean isPaused;

　 private Command exitCommand = new Command("Exit", Command.EXIT, 1);

　 private Command startCommand = new Command("Start", Command.ITEM, 1);

　 public DatagramMIDlet()
　 {
　　　 display = Display.getDisplay(this);
　　　 f = new Form("Datagram Demo");
　　　 cg = new ChoiceGroup("Please select peer", Choice.EXCLUSIVE, names,
　　　　　　　 null);
　　　 f.append(cg);

　　　 f.addCommand(exitCommand);
　　　 f.addCommand(startCommand);
　　　 f.setCommandListener(this);

　　　 display.setCurrent(f);
　 }

　 public static Display getDisplay()
　 {
　　　 return display;
　 }

　 public boolean isPaused()
　 {
　　　 return isPaused;
　 }

　 public void startApp()
　 {
　　　 isPaused = false;
　 }

　 public void pauseApp()
　 {
　　　 isPaused = true;
　 }

　 public void destroyApp(boolean unconditional)
　 {
　 }

　 public void commandAction(Command c, Displayable s)
　 {
　　　 if (c == exitCommand)
　　　 {
　　　　　 destroyApp(true);
　　　　　 notifyDestroyed();
　　　 } else if (c == startCommand)
　　　 {
　　　　　 String name = cg.getString(cg.getSelectedIndex());
　　　　　 if (name.equals(SERVER))
　　　　　 {
　　　　　　　 Server server = new Server(this);
　　　　　　　 server.start();
　　　　　 } else
　　　　　 {
　　　　　　　 Client client = new Client(this);
　　　　　　　 client.start();
　　　　　 }
　　　 }
　 }

}