sender.java

J2ME socket通信示例代码

import java.io.*;

public class Sender extends Thread{
	private OutputStream os;
	private String message;
	public Sender(OutputStream os){
		this.os=os;
		start();
	}
	
	public synchronized void send(String msg){
		message=msg;
		notify();
	}
	public synchronized void run(){
		while(true){
			if(message==null){
				try{
					wait();
				}catch(InterruptedException e){
					e.printStackTrace();
				}
			}
			if(message==null){
				break;
			}
			try {
				os.write(message.getBytes());
				os.write("\r\n".getBytes());
			} catch (IOException e) {
				e.printStackTrace();
			}
			message=null;
		}
	}
	
	public synchronized void stop(){
		message=null;
		notify();
	}
}