package com.fang.client.net;

import java.io.InputStream;
import java.io.ObjectInput;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;

import com.fang.client.config.StatusChangeFirer;
import com.fang.common.core.StatusChangeEvent;

public class StatusChangeListener implements Runnable{
	
	private ServerSocket ser=null;
	
	public  StatusChangeListener(){
		try{
		ser=new ServerSocket(12345);
		}catch(Exception e){
			System.out.println(e.getMessage());
		}
        new Thread(this).start();
	}
	

	public void run() {
		
		while(true){
			Socket socket;
			try{
			socket=ser.accept();
			InputStream o = socket.getInputStream();
			ObjectInput s = new ObjectInputStream(o);
			
			StatusChangeEvent eventMsg=(StatusChangeEvent)s.readObject();
			StatusChangeFirer firer=new StatusChangeFirer();
			firer.update(eventMsg);
			
			s.close();
			
			}catch(Exception e){
				System.out.println(e.getMessage());
			}
		}
		
	}
	
    
	
	

}