eventsenderhome.java

原创

package serviceServer;

import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class EventSenderHome {
	private static EventSenderHome sImrh = new EventSenderHome();
	private ExecutorService pool;
	private ServerSocket serverSocket = null;
	private Socket mSocket = null;
	private ObjectOutputStream oout = null;

	private EventSenderHome() {
		pool = Executors.newSingleThreadExecutor();
	}

	public static EventSenderHome getInstance() {
		return sImrh;
	}

	public void createSocket() {
		if (mSocket == null) {
			try {
				serverSocket = new ServerSocket(Common.sEPort);
				mSocket = serverSocket.accept();
				oout = new ObjectOutputStream(mSocket.getOutputStream());
			} catch (IOException e) {
				System.err.println("EventServer: Could not listen on port!");
				System.exit(-1);
			}
		}
	}

	public void sendEvent(Object event) {
		if (oout != null)
			pool.execute(new EventSender(event, oout));
	}
}