sender.java

j2me学习 简单例子

package example.demowireless.datagram;

import javax.microedition.io.Datagram;
import javax.microedition.io.DatagramConnection;

/**
 * <p>
 * J2ME Socket Demo -- Client
 * </p>
 * 
 * @author 刘光辉
 * @version 2009.02.04
 */
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;
		}
	}

}