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

《jv中使用多线程实现多服务功能.doc》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、importjava.io.*;importjava.net.*;importjava.util.*;classmoreServer{publicstaticvoidmain(String[]args)throwsIOException{System.out.println("Serverstarting...");//使用8000端口提供服务ServerSocketserver=newServerSocket(8000);while(true){//阻塞，直到有客户连接Socketsk=server.accept();System.out.pr

2、intln("AcceptingConnection...");//启动服务线程newServerThread(sk).start();}}}//使用线程，为多个客户端服务classServerThreadextendsThread{privateSocketsk;ServerThread(Socketsk){this.sk=sk;}//线程运行实体publicvoidrun(){BufferedReaderin=null;PrintWriterout=null;try{InputStreamReaderisr;isr=newInputStrea

3、mReader(sk.getInputStream());in=newBufferedReader(isr);out=newPrintWriter(newBufferedWriter(newOutputStreamWriter(sk.getOutputStream())),true);while(true){//接收来自客户端的请求，根据不同的命令返回不同的信息。Stringcmd=in.readLine();System.out.println(cmd);if(cmd==null)break;cmd=cmd.toUpperCase();if(cmd

4、.startsWith("BYE")){out.println("BYE");break;}else{out.println("你好，我是服务器！");}}}catch(IOExceptione){System.out.println(e.toString());}finally{System.out.println("ClosingConnection...");//最后释放资源try{if(in!=null)in.close();if(out!=null)out.close();if(sk!=null)sk.close();}catch(IO

5、Exceptione){System.out.println("closeerr"+e);}}}}/********************************SocketClient.java************************************/importjava.io.*;importjava.net.*;classSocketThreadClientextendsThread{publicstaticintcount=0;//构造器，实现服务publicSocketThreadClient(InetAddressadd

6、r){count++;BufferedReaderin=null;PrintWriterout=null;Socketsk=null;try{//使用8000端口sk=newSocket(addr,8000);InputStreamReaderisr;isr=newInputStreamReader(sk.getInputStream());in=newBufferedReader(isr);//建立输出out=newPrintWriter(newBufferedWriter(newOutputStreamWriter(sk.getOutputStr

7、eam())),true);//向服务器发送请求System.out.println("count:"+count);out.println("Hello");System.out.println(in.readLine());out.println("BYE");System.out.println(in.readLine());}catch(IOExceptione){System.out.println(e.toString());}finally{out.println("END");//释放资源try{if(in!=null)in.clos

8、e();if(out!=null)out.close();if(sk!=null)sk.close();}c