在GCF中提供了DatagramConnection和Datagram兩個接口，借助他們我們可以在J2ME中基於UDP協議開發聯網應用程序，在MIDP2.0中，添加了UDPDatagramConnection這個接口。他擴展了DatagramConnection並添加了兩個方法getLocalAddress()和getLocalPort()。我們知道UDP服務是不可靠的，假如你希望開發更可靠的聯網應用的話可以采用SocketConnection，因為TCP服務是面向連接且可靠的。我們還必須清楚地一點是以上所說的各種連接方式都不是MIDP規范中規定必須實現的。因此在使用之前請參考特定設備的開發文檔。MIDP中只有Http連接是必須支持的。
同樣，我們要獲得DatagramConnection的話，必須通過Connector的open方法，其中的URL應該滿足如下的形式。
datagram://localhost:5555 這樣的話表示建立了一個客戶端模式的連接。在指定ip:localhost和指定端口:5555
datagram://:5555 這樣建立的是一個服務器端模式的連接，在本地的5555端口。
建立連接後，我們可以通過DatagramConnection的newDatagram()方法構造一個Datagram，然後調用DatagramConnection的send()方法。這樣數據報將會發送到指定的接受方。例如你可以構建這個一個負責發送數據的Sender類。
package com.siemens.datagramtest;
import Javax.microedition.io.Datagram;
import javax.microedition.io.DatagramConnection;
public class Sender extends Thread
{
private DatagramConnection dc;
private String address;
private String message;
public Sender(DatagramConnection dc)
{
this.dc = dc;
start();
}
public synchronized void send(String addr, String msg)
{
address = addr;
message = msg;
notify();
}
public synchronized void run()
{
while (true)
{
// If no client to deal, wait until one connects
if (message == null)
{
try
{
wait();
} catch (InterruptedException e)
{
}
}
try
{
byte[] bytes = message.getBytes();
Datagram dg = null;
// Are we a sender thread for the client ？ If so then there's
// no address parameter
if (address == null)
{
dg = dc.newDatagram(bytes, bytes.length);
} else
{
dg = dc.newDatagram(bytes, bytes.length, address);
System.out.println(address);
}
dc.send(dg);
} catch (Exception ioe)
{
ioe.printStackTrace();
}
// Completed client handling, return handler to pool and
// mark for wait
message = null;
}
}
}
注重聯網的時候我們應該在另外一個線程中而不是在主線程中。
服務器端的目的就是啟動後監聽指定的端口，當客戶端連接過來後接受數據並記錄下客戶端的地址，以便服務器端向客戶端發送數據。
package com.siemens.datagramtest;
import java.io.IOException;
import javax.microedition.io.Connector;
import javax.microedition.io.Datagram;
import javax.microedition.io.DatagramConnection;
import javax.microedition.io.UDPDatagramConnection;
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 Server 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;
private String address;
public Server(DatagramMIDlet m)
{
parent = m;
display = Display.getDisplay(parent);
f = new Form("Datagram Server");
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
{
si.setText("Waiting for connection");
DatagramConnection dc =(DatagramConnection)Connector.open("datagram://:5555");
sender = new Sender(dc);
while (true)
{
Datagram dg = dc.newDatagram(100);
dc.receive(dg);
address = dg.getAddress();
si.setText("Message received - "
+ new String(dg.getData(), 0, dg.getLength()));
}
} catch (IOException ioe)
{
Alert a = new Alert("Server", "Port 5000 is already taken.", null,
AlertType.ERROR);
a.setTimeout(Alert.FOREVER);
a.setCommandListener(this);
display.setCurrent(a);
} catch (Exception e)
{
e.printStackTrace();
}
}
public void commandAction(Command c, Displayable s)
{
if (c == sendCommand && !parent.isPaused())
{
if (address == null)
{
si.setText("No destination address");
} else
{
sender.send(address, tf.getString());
}
}
if (c == Alert.DISMISS_COMMAND)
{
parent.destroyApp(true);
parent.notifyDestroyed();
}
}
public void stop()
{
}
}
客戶端代碼則是建立連接後向服務器端發送數據，並等待接受服務器返回的數據。
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 Da
