configlistener.java

用java 实现的一个任务管理器

package com.fang.server.net;

import java.io.InputStream;
import java.io.ObjectInput;
import java.io.ObjectInputStream;
import java.io.ObjectOutput;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

import com.fang.common.core.TaskChangeEvent;
import com.fang.server.config.FTaskConfig;

public class ConfigListener implements Runnable{

	private ServerSocket ser=null;
	
	public ConfigListener(){
		try{
			ser=new ServerSocket(8020);
			}catch(Exception  e){
				System.out.println(e.getMessage());
			}
			new Thread(this).start();
	}
	
	public void run() {
		try{
	        while(true)
	        { 
			new Connection(ser.accept());
			
	        }
			}catch(Exception e){
				System.out.println(e.getMessage());
			}
	}
}

class Connection extends Thread{
	private Socket soc;
	
	public Connection(Socket s){
		 this.soc=s;
		 this.start();
	}
	
	public void run(){
		
		try{
		InputStream o = soc.getInputStream();
		ObjectInput s = new ObjectInputStream(o);
		
		OutputStream oo=soc.getOutputStream();
		ObjectOutput out=new ObjectOutputStream(oo);
		
		
		TaskChangeEvent  configure=(TaskChangeEvent)s.readObject();
	  
		//TODO do something about the configure
		FTaskConfig config=new FTaskConfig();
	    if(configure.getModifyType()==TaskChangeEvent.ADD){
	    	config.addTask(configure.getEventSource());
	    	
	    }else if(configure.getModifyType()==TaskChangeEvent.DEL){
	    	config.delTaskByTaskID(configure.getEventSource().getId());
	    }else if(configure.getModifyType()==TaskChangeEvent.UPDATE){
	    	config.updateTask(configure.getEventSource());
	    }
        		
		System.out.println(configure);

		out.writeObject("KO");
		
		s.close();
		out.close();
		
		}catch(Exception e){
			System.out.println(e.getMessage());
		}
		
	}
	
}