教程：在J2ME中基于UDP協議編程

2019-11-17 06:23:57

字體：大中小

來源：轉載

供稿：網友

　　在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

上一篇：深入解析：J2ME 的平臺體系結構

下一篇：J2ME游戲開發中如何使用層的概念