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

1、java中使用多线程实现多服务 功能import java.io.*;import .*;import java.util.*;class moreServerpublic static void main (String args) throws lOExceptionSystem.out.println ("Server startingn");使用8000端口提供服务ServerSocket server = new ServerSocket (8000);while (true)阻塞，直到有客户连接Socket sk = server.accept ();Syste

2、m.out.println("AcceptingConnectionn");启动服务线程new ServerThread (sk).start ();使用线程，为多个客户端服务class ServerThread extends Threadprivate Socket sk;ServerThread (Socket sk) this.sk = sk;线程运行实体public void run ()BufferedReader in = null;PrintWriter out = null;tryInputStreamReader isr;isr = new InputS

3、treamReader (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 (c

4、md.startsW让h ("BYE")out.println ("BYE");break;elseout.println ("你好，我是服务器！");catch (IOException e)System.out.println (e.toString (); finally System.out.println("ClosingConnectionn");最后释放资源tryif (in != null) in.close ();if (out != null) out.close ();if (sk != nu

5、ll) sk.close ();catch (IOException e) System.out.println("close err"+e);/*Socketdi ent.java */ import java.io.*;import .*;class SocketThreadClient extends Thread public static int count = 0;构造器，实现服务public SocketThreadClient (InetAddress addr)count+;BufferedReader in = null;PrintWriter out

6、= null;Socket sk = null;try使用8000端口sk = new Socket (addr, 8000);InputStreamReader isr;isrnew InputStreamReader(sk.getInputStream ();in = new BufferedReader (isr);建立输出out = new PrintWriter (new BufferedWriter(new OutputStreamWriter(sk.getOutputStream (), true);向服务器发送请求System.out.println("count:&

7、quot;+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 ();finallyout.println("END");释放资源tryif (in != null) in.close ();if (out != null) out.close ();if (sk != null) sk.close ();catch (lOException e)客户端public class SocketClientpublic static void main(String口 args) throws IOException,InterruptedExceptionInetAddressa