SockClient.java
上传用户:cctqzzy
上传日期:2022-03-14
资源大小:12198k
文件大小:1k
源码类别:

搜索引擎

开发平台:

Java

  1. package chapter10;
  2. import java.io.BufferedReader;
  3. import java.io.BufferedWriter;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.io.OutputStreamWriter;
  7. import java.io.PrintWriter;
  8. import java.net.InetAddress;
  9. import java.net.Socket;
  10. class SockClient extends Thread{
  11. private Socket socket;
  12. private BufferedReader in;
  13. private PrintWriter out;
  14. private  int counter =0;
  15. private int id= counter++;
  16. private static int threadcount=0;
  17. final int port=5000;
  18. public  static int threadCount(){
  19. return threadcount;
  20. }
  21. public SockClient(InetAddress addr){
  22. System.out.println("Making client:"+id);
  23. threadcount++;
  24. try{
  25. socket=new Socket(addr,port);
  26. }catch(IOException e){
  27. }
  28. try{
  29. in=new BufferedReader(
  30. new InputStreamReader(
  31. socket.getInputStream()));
  32. out=new PrintWriter(
  33. new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);  
  34. start();
  35. }catch(IOException e){
  36. try{
  37. socket.close();
  38. }catch(IOException e2){}
  39. }
  40. }
  41. public void run(){
  42. try{
  43. for (int i=0;i<25;i++){
  44. out.println("Client:"+id+":"+i);
  45. String str=in.readLine();
  46. System.out.println(str);
  47. }
  48. out.println("END");
  49. }catch(IOException e){
  50. }finally{
  51. try{
  52. socket.close();
  53. }catch(IOException e){}
  54. threadcount--;
  55. }
  56. }
  57. }