multithreadclient.java

java课后题的详细答案

//package com.liwei.JavaSocket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class MultiThreadClient {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		int numberTask = 10 ;
		ExecutorService exec = Executors.newCachedThreadPool();
		for(int i = 0 ; i < 10 ; i++){
			exec.execute(createTask(i));
		}
	}
	private static Runnable createTask(final int taskID) {
		
		return new Runnable(){
				private int port = 8821;
				private Socket socket = null ;
				
				public void run() {
					// TODO Auto-generated method stub
					System.out.println("task " + taskID + ":start");
					try {
						socket = new Socket("localhost",port);
						OutputStream socketOut = socket.getOutputStream();
						socketOut.write("shutdown\r\n".getBytes());
						BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
						String msg = null;
						while((msg = br.readLine()) != null){
							System.out.println(msg);
							
						}
					} catch (UnknownHostException e) {
						System.err.println(e.getMessage());
					} catch (IOException e) {
						System.err.println(e.getMessage());
					}
				}
			};
	}
		
}