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

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

2、t.println (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 InputStreamReade

3、r (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.startsWi

4、th (BYE)out.println (BYE);break;elseout.println (你好，我是服务器！ );catch (IOException e)System.out.println (e.toString ();finallySystem.out.println(ClosingConnection.n);/最后释放资源tryif (in != null)in.close ();if (out != null)out.close ();if (sk != null)sk.close ();catch (IOException e)System.out.println(clos

5、e 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)

6、;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 (

7、); 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,InterruptedExceptionInetAddressad