sender.java

来自「手机游戏对战平台。自己做的一个东东。 支持多个手机联网打游戏；采用socket」· Java 代码 · 共 56 行

package clientInf;


import java.io.DataOutputStream;
import java.io.IOException;

public class Sender extends Thread {
    private DataOutputStream os;
    private Serializable message;

    public Sender(DataOutputStream os) {
	this.os = os;
	start();
    }
    public synchronized void send(Serializable msg) {      
        System.out.println(msg.toString());
        System.out.flush();
	message = msg;
	notify();
    }
    public void close(){
    	try {
			os.close();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
    }
    public synchronized void run() {
	 while (true) {
            // If no client to deal, wait until one connects
            try {
                wait();
            } catch (InterruptedException e) {
                System.out.println(e);
            }
            try {
                message.serialize(os);
            } catch (Exception e) {
                System.out.println(e + "");
                try {
                    os.close();
                } catch (IOException e1) {
                    e1.printStackTrace();
                }
                break;
            }
            message = null;
        }
   }
    public synchronized void stop() {
	message = null;
	notify();
    }
}