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

1、import java.io.*;import .*;import java.util.*;class moreServerpublic 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

2、 (Accepting Connection.n);/启动服务线程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 InputStreamReader (sk.getI

3、nputStream (); 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 (

4、BYE) out.println (BYE); break;else out.println ( 你好，我是服务器！ );catch (IOException e)System.out.println (e.toString ();finallySystem.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.prin

5、tln(close err+e);*SocketClient.java* */ import java.io.*;import .*;class SocketThreadClient extends Threadpublic static int count = 0;/构造器，实现服务public SocketThreadClient (InetAddress addr)count+;BufferedReader in = null;PrintWriter out = null;Socket sk = null;try/使用 8000 端口sk = new Socket (ad

6、dr, 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.r

7、eadLine ();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 (IOException e)/客户端public class SocketClientpublic static void main(String args) throws IOException,InterruptedExceptionInetAddress addr =