java中使用多线程实现多服务功能.doc

import java.io.*;import .*;import java.util.*;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 .*; 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