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

【 tulaoshi.com - 编程语言 】

// 文件名：moreServer.java
import java.io.*;
import java.net.*;
import java.util.*;
/**
 * pTitle: 多线程服务器/p
 * pDescription: 本实例使用多线程实现多服务功能。/p
 * pCopyright: Copyright (c) 2003/p
 * pFilename: /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;i10;i++)
　　　　   new SocketThreadClient(addr);
　　　  Thread.currentThread().sleep(1000);
　  }
}