portalcollectorserver.java

一个小的门户的实现。

/**
 *
 * <p>Title:PortalCollectorServer </p>
 *
 * <p>Description:线程 </p>
 *
 * <p>作用：建立一个服务器端端口8086接受请求，对每个请求建立一个CollectorThead，接受请求</p>
 *
 * <p>使用方法：PortalCollectorServer -> CollectorThead </p>
 *
 * <p>Copyright: Copyright (c) 2006-03-23</p>
 *
 * <p>Company:HIT </p>
 *
 * @author Yao Yuanzhe
 */


package portal.collector;


import java.io.*;
import java.net.*;
//import java.util.Hashtable;

public class PortalCollectorServer  {
    

    private int port;
    private ServerSocket ss ;
 
    /*打开一个端口，监听生产者发送的数据文件(XML格式)*/  
    public PortalCollectorServer(int listenPort) {
        
        port = listenPort ;
        try {
        	
            ss = new ServerSocket(port);
            System.out.println("Start PortalCollectorServer thread, listen on port " + port + " to receive data from producers");
            System.out.println("IP is " + ss.getLocalSocketAddress());
        }catch(IOException e) {
            System.out.println(e);
        };
    }
    
    
    public void run() {
          
            /*每接收到一个请求命令，启动一个CollectorThead进行处理*/
            while(true){
            	try {  
                	Socket socket = ss.accept() ; 
                	System.out.println("IP is " + socket.getLocalSocketAddress());
                	CollectorThread collectorthead = new CollectorThread(socket);               
                	Thread thread = new Thread(collectorthead);
                	thread.start() ;
                }catch(Exception e) {
            		System.out.println(e);
        	      }
            }
   }
    
    public static void main(String[] args) {
    	PortalCollectorServer pcs = new PortalCollectorServer(8086);
    	//Thread thread = new Thread(pcs);
    	//thread.start() ;
    	pcs.run();
    	System.out.println("hello!");
    	}


}