[JAVA100例]044、多線程服務器：每個人都有份

// 文件名：moreServer.java
import java.io.*;
import java.net.*;
import java.util.*;
/**
* <p>Title: 多線程服務器</p>
* <p>Description: 本實例使用多線程實現多服務功能。</p>
* <p>Copyright: Copyright (c) 2003</p>
* <p>Filename: </p>
* @version 1.0
*/
class moreServer
{
public static void main (String [] args) throws IOException
{
　 System.out.println ("Server starting...\n");
　 //使用8000端口提供服務
　 ServerSocket server = new ServerSocket (8000);
　 while (true)
　 {
　　 //阻塞，直到有客戶連接
　　 Socket sk = server.accept ();
　　 System.out.println ("Accepting Connection...\n");
　　 //啟動服務線程
　　 new ServerThread (sk).start ();
　 }
}
}
//使用線程，為多個客戶端服務
class ServerThread extends Thread
{
private Socket sk;

ServerThread (Socket sk)
{
　 this.sk = sk;
}
//線程運行實體
public void run ()
{
　 BufferedReader in = null;
　 PrintWriter out = null;
　 try{
　　 InputStreamReader isr;
　　 isr = new InputStreamReader (sk.getInputStream ());
　　 in = new BufferedReader (isr);
　　 out = new PrintWriter (
　　　　　 new BufferedWriter(
　　　　　　 new OutputStreamWriter(
　　　　　　　 sk.getOutputStream ())), true);
while(true){
　　　 //接收來自客戶端的請求，根據不同的命令返回不同的信息。
　　　 String cmd = in.readLine ();
　　　 System.out.println(cmd);
　　　 if (cmd == null)
　　　　　 break;
　　　 cmd = cmd.toUpperCase ();
　　　 if (cmd.startsWith ("BYE")){
　　　　 out.println ("BYE");
　　　　 break;
　　　 }else{
　　　　 out.println ("你好，我是服務器！");
　　　 }
　　 }
　　 }catch (IOException e)
　　 {
　　　 System.out.println (e.toString ());
　　 }
　　 finally
　　 {
　　　 System.out.println ("Closing Connection...\n");
　　　 //最後釋放資源
　　　 try{
　　　 if (in != null)
　　　　 in.close ();
　　　 if (out != null)
　　　　 out.close ();
　　　　 if (sk != null)
　　　　　 sk.close ();
　　　 }
　　　 catch (IOException e)
　　　 {
　　　 System.out.println("close err"+e);
　　　 }
　　 }
}
}
//文件名：SocketClient.java
import java.io.*;
import java.net.*;
class SocketThreadClient extends Thread
{
public static int count = 0;
//構造器，實現服務
public SocketThreadClient (InetAddress addr)
{
　 count++;
　 BufferedReader in = null;
　 PrintWriter out = null;
　 Socket sk = null;
　 try{
　 //使用8000端口
　 sk = new Socket (addr, 8000);
　 InputStreamReader isr;
　 isr = new InputStreamReader (sk.getInputStream ());
　 in = new BufferedReader (isr);
　 //建立輸出
　 out = new PrintWriter (
　　　　　 new BufferedWriter(
　　　　　 new OutputStreamWriter(
　　　　　　 sk.getOutputStream ())), true);
　 //向服務器發送請求
　 System.out.println("count:"+count);
　 out.println ("Hello");
　 System.out.println (in.readLine ());
　 out.println ("BYE");
　 System.out.println (in.readLine ());
}
　 catch (IOException e)
　 {
　 System.out.println (e.toString ());
　 }
　 finally
　 {
　 out.println("END");
　 //釋放資源
　 try
　 {
　　 if (in != null)
　　 in.close ();
　　 if (out != null)
　　 out.close ();
　　 if (sk != null)
　　 sk.close ();
　 }
　 catch (IOException e)
　 {
　 }
　 }
}
}
//客戶端
public class SocketClient{
　 public static void main(String[] args) throws IOException,InterruptedException
　 {
　　 InetAddress addr = InetAddress.getByName(null);
　　　 for(int i=0;i<10;i++)
　　　　 new SocketThreadClient(addr);
　　　 Thread.currentThread().sleep(1000);
　 }
}