pooledremotefileserver.java

java socket基础编程实例

   /*
	* Name of the Application     : PooledRemoteFileServer .java
	* Development Environment     : Eclipse3.0M8
	* @Version 1.0
	* Describtion 
	* 
	*	1)response requests from the client for the file 
	*
	*
	* Creation / Modification History
	*	wsl	20:01 06/29/2004	Creation       
	*
	* Copyright ® 2004 www.cnlab.net
	* All right reserved. 
	*/
package net.cnlab.wsl.testsocket.pool;

import java.io.*;
import java.net.*;


public class PooledRemoteFileServer {
	
	protected int maxConnections;
	protected int listenPort;
	protected ServerSocket serverSocket;
	
	public PooledRemoteFileServer(int aListenPort, int maxConnections) {
		listenPort = aListenPort;
		this.maxConnections = maxConnections;
	}
	public void acceptConnections() {
		try {
			ServerSocket server = new ServerSocket(listenPort, 5);
			Socket incomingConnection = null;
			System.out.println("the PooledServer is running...");
			while (true) {
				incomingConnection = server.accept();
				handleConnection(incomingConnection);
			}
		} catch (BindException e) {
			System.out.println("Unable to bind to port " + listenPort);
		} catch (IOException e) {
			System.out.println("Unable to instantiate a ServerSocket on port: " + listenPort);
		}
	}
	protected void handleConnection(Socket connectionToHandle) {
		PooledConnectionHandler.processRequest(connectionToHandle);
	}
	public static void main(String[] args) {
		PooledRemoteFileServer server = new PooledRemoteFileServer(3002, 3);
		server.setUpHandlers();
		server.acceptConnections();
	}
	public void setUpHandlers() {
		for (int i = 0; i < maxConnections; i++) {
			PooledConnectionHandler currentHandler = new PooledConnectionHandler();
			new Thread(currentHandler, "Handler " + i).start();
		}
	}
}