采用Java 5的ExecutorService实现线程池

采用Java 5的ExecutorService来进行线程池的方式实现多线程,模拟客户端多用户向同一服务器端发送请求。

1.服务端

 

# import java.io.BufferedReader;     
# import java.io.IOException;     
# import java.io.InputStream;     
# import java.io.InputStreamReader;     
# import java.io.OutputStream;     
# import java.io.PrintWriter;     
# import java.net.*;     
# import java.util.concurrent.*;     
#     
# public class MultiThreadServer {     
#     private int port=8821;     
#     private ServerSocket serverSocket;     
#     private ExecutorService executorService;//线程池     
#     private final int POOL_SIZE=10;//单个CPU线程池大小     
#          
#     public MultiThreadServer() throws IOException{     
#         serverSocket=new ServerSocket(port);     
#         //Runtime的availableProcessor()方法返回当前系统的CPU数目.     
#         executorService=Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*POOL_SIZE);     
#         System.out.println("服务器启动");     
#     }     
#          
#     public void service(){     
#         while(true){     
#             Socket socket=null;     
#             try {     
#                 //接收客户连接,只要客户进行了连接,就会触发accept();从而建立连接     
#                 socket=serverSocket.accept();     
#                 executorService.execute(new Handler(socket));     
#                      
#             } catch (Exception e) {     
#                 e.printStackTrace();     
#             }     
#         }     
#     }     
#          
#     public static void main(String[] args) throws IOException {     
#         new MultiThreadServer().service();     
#     }     
#     
# }     
#     
# class Handler implements Runnable{     
#     private Socket socket;     
#     public Handler(Socket socket){     
#         this.socket=socket;     
#     }     
#     private PrintWriter getWriter(Socket socket) throws IOException{     
#         OutputStream socketOut=socket.getOutputStream();     
#         return new PrintWriter(socketOut,true);     
#     }     
#     private BufferedReader getReader(Socket socket) throws IOException{     
#         InputStream socketIn=socket.getInputStream();     
#         return new BufferedReader(new InputStreamReader(socketIn));     
#     }     
#     public String echo(String msg){     
#         return "echo:"+msg;     
#     }     
#     public void run(){     
#         try {     
#             System.out.println("New connection accepted "+socket.getInetAddress()+":"+socket.getPort());     
#             BufferedReader br=getReader(socket);     
#             PrintWriter pw=getWriter(socket);     
#             String msg=null;     
#             while((msg=br.readLine())!=null){     
#                 System.out.println(msg);     
#                 pw.println(echo(msg));     
#                 if(msg.equals("bye"))     
#                     break;     
#             }     
#         } catch (IOException e) {     
#             e.printStackTrace();     
#         }finally{     
#             try {     
#                 if(socket!=null)     
#                     socket.close();     
#             } catch (IOException e) {     
#                 e.printStackTrace();     
#             }     
#         }     
#     }     
# } 

 

 2.客户端

   1. package sterning;     
   2.     
   3. import java.io.BufferedReader;     
   4. import java.io.IOException;     
   5. import java.io.InputStreamReader;     
   6. import java.io.OutputStream;     
   7. import java.net.Socket;     
   8. import java.util.concurrent.ExecutorService;     
   9. import java.util.concurrent.Executors;     
  10.     
  11. public class MultiThreadClient {     
  12.          
  13.     public static void main(String[] args) {     
  14.         int numTasks = 10;     
  15.              
  16.         ExecutorService exec = Executors.newCachedThreadPool();     
  17.     
  18.         for (int i = 0; i < numTasks; i++) {     
  19.             exec.execute(createTask(i));     
  20.         }     
  21.     
  22.     }     
  23.     
  24.     // 定义一个简单的任务     
  25.     private static Runnable createTask(final int taskID) {     
  26.         return new Runnable() {     
  27.             private Socket socket = null;     
  28.             private int port=8821;     
  29.     
  30.             public void run() {     
  31.                 System.out.println("Task " + taskID + ":start");     
  32.                 try {                         
  33.                     socket = new Socket("localhost", port);     
  34.                     // 发送关闭命令     
  35.                     OutputStream socketOut = socket.getOutputStream();     
  36.                     socketOut.write("shutdown\r\n".getBytes());     
  37.     
  38.                     // 接收服务器的反馈     
  39.                     BufferedReader br = new BufferedReader(     
  40.                             new InputStreamReader(socket.getInputStream()));     
  41.                     String msg = null;     
  42.                     while ((msg = br.readLine()) != null)     
  43.                         System.out.println(msg);     
  44.                 } catch (IOException e) {                         
  45.                     e.printStackTrace();     
  46.                 }     
  47.             }     
  48.     
  49.         };     
  50.     }     
  51. }   

 

 

从而实现了多个客户端向服务器端发送请求,服务器端采用多线程的方式来处理的情况。

 

原文摘自：http://blog.csdn.net/flowerknight/archive/2009/06/14/4269052.aspx