[JAVA100例]044、多线程服务器:每个人都有份[Java编程]

// 文件名: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);
　 }
}