远程获取文件4-线程池服务器[1]

本文程序摘自:ibm.com/developerworks

使用线程池的好处就不必我多说了,主要是减少socket初始化的代价,这里的描述只设计到服务器的实现,关于客户端的代码和前面多线程服务器相同,可参考:http://blog.csdn.net/notruiyi/archive/2005/10/26/517047.aspx

-------------------------------------------------------------------------------------------------------------

//服务器实现

import java.io.*;

import java.net.*;

import java.util.*;

public class PooledFileServer{

    private int maxConnections;//设置的线程数

    private int listenPort;//侦听端口号

    private ServerSocket serverSocket;

    public PooledFileServer(int port , int maxCon){

        this.listenPort = port;

        this.maxConnections = maxCon;

    }

    //启动线程池

    public void setupHandlers(){

        for(int i=0 ; i<maxConnections ; ++i){

           //创建PooledConnectionHandle对象,该类实现了runnable接口

            PooledConnectionHandle connectionHandle = new PooledConnectionHandle();

            //启动线程

            new Thread(connectionHandle,"handle"+i).start();

        }   

    }

    //开始接收请求

    public void acceptConnection(){

        try{

            ServerSocket server = new ServerSocket(listenPort,5);

            Socket IncomingSocket = null;

            while(true){

                incomingSocket  = server.accept();

                hancleConnection(incomingSocket);

            }

        }catch(BindException e){

            System.out.println("Unable to bind to port.");

        }catch(IOException e){

            System.out.println("Unable to init ServerSocket.");

        }

    }

    //处理连接请求,将客户socket传给PooledConnectionHandle的静态方法processRequest,后者将该socket放入请求队列

    private void handleConnection(incomingSocket){

        PooledConnectionHandle.processRequest(incomingSocket);

    }

}

-------------------------------------------------------------------------------------------------------------------------

//连接处理器

import java.io.*;

import java.net.*;

import java.util.*;

public class PooledConnectionHandle implements Runnable{

        private Socket socket;

        //存放所有请求的socket,使用链表模拟队列

        private static List pool = new LinkedList();

        public PooledConnectionHandle(){}

        //处理文件传输

        public void handleConnection(){

            try{

            BufferedReader inputReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            BufferedReader outputReader = new BufferReader(new OutputStreamReader(socket.getOutputStream()));

            //获取要读取的文件名

            FileReader fileReader = new FileReader(new File(inputReader.readLine()));

            BufferedReader bufferedFileReader = new BufferReader(fileReader);

            PrintWriter printWriter = new PrintWriter(socket.getOutputStream());

            String line = null;