您的位置: 首页  >  IT文章  >  java Socket(2)

java Socket(2)

分类: IT文章 • 2024-03-13 17:06:55
java Socket(二)

上次做了一个java socket一对一通信的例子这次来写一个一对多的通信,这里我们使用java的多线程来实现

首先来看一下服务类

 

[java] view plaincopy
  1. /** 
  2.  *  
  3.  */  
  4. package com.dnion.socket;  
  5.   
  6. import java.io.IOException;  
  7. import java.net.ServerSocket;  
  8. import java.net.Socket;  
  9.   
  10. /** 
  11.  ***************************************************************  
  12.  * 项目名称：JavaThread 
  13.  * 程序名称：MultiJabberServer 
  14.  * 日期：2012-8-23 下午02:38:20 
  15.  * 作者： 
  16.  * 模块： 
  17.  * 描述： 
  18.  * 备注： 
  19.  * ------------------------------------------------------------ 
  20.  * 修改历史 
  21.  * 序号               日期              修改人       修改原因 
  22.  *  
  23.  * 修改备注： 
  24.  * @version  
  25.  *************************************************************** 
  26.  */  
  27. public class MultiJabberServer {  
  28.   
  29.       
  30.     /** 
  31.      * 方法名：main 
  32.      * 描述： 
  33.      * 作者： 
  34.      * 日期：2012-8-23 下午02:38:20 
  35.      * @param @param args 
  36.      * @return void 
  37.      */  
  38.     public static void main(String[] args) {  
  39.         ServerSocket s = null;  
  40.         Socket socket  = null;  
  41.         try {  
  42.             s = new ServerSocket(8080);  
  43.             //等待新请求、否则一直阻塞  
  44.             while(true){  
  45.                 socket = s.accept();  
  46.                 System.out.println("socket:"+socket);  
  47.                 new ServeOneJabbr(socket);  
  48.                   
  49.             }  
  50.         } catch (Exception e) {  
  51.             try {  
  52.                 socket.close();  
  53.             } catch (IOException e1) {  
  54.                 // TODO Auto-generated catch block  
  55.                 e1.printStackTrace();  
  56.             }  
  57.         }finally{  
  58.             try {  
  59.                 s.close();  
  60.             } catch (IOException e) {  
  61.                 // TODO Auto-generated catch block  
  62.                 e.printStackTrace();  
  63.             }  
  64.         }  
  65.           
  66.   
  67.     }  
  68.   
  69. }  

 

接着我们要写一个服务端响应请求的类也就是一个socket

 

[java] view plaincopy
  1. /** 
  2.  *  
  3.  */  
  4. package com.dnion.socket;  
  5.   
  6. import java.io.BufferedReader;  
  7. import java.io.BufferedWriter;  
  8. import java.io.IOException;  
  9. import java.io.InputStreamReader;  
  10. import java.io.OutputStreamWriter;  
  11. import java.io.PrintWriter;  
  12. import java.net.Socket;  
  13.   
  14. /** 
  15.  ***************************************************************  
  16.  * 项目名称：JavaThread 
  17.  * 程序名称：ServeOneJabbr 
  18.  * 日期：2012-8-23 下午02:34:13 
  19.  * 作者： 
  20.  * 模块： 
  21.  * 描述： 
  22.  * 备注： 
  23.  * ------------------------------------------------------------ 
  24.  * 修改历史 
  25.  * 序号               日期              修改人       修改原因 
  26.  *  
  27.  * 修改备注： 
  28.  * @version  
  29.  *************************************************************** 
  30.  */  
  31. public class ServeOneJabbr extends Thread{  
  32.   
  33.     private Socket socket = null;  
  34.     private BufferedReader br = null;  
  35.     private PrintWriter pw = null;  
  36.       
  37.     public ServeOneJabbr(Socket s){  
  38.         socket = s;  
  39.         try {  
  40.             br = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
  41.             pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);  
  42.             start();  
  43.         } catch (Exception e) {  
  44.               
  45.             e.printStackTrace();  
  46.         }  
  47.     }  
  48.       
  49.     @Override  
  50.     public void run() {  
  51.         while(true){  
  52.             String str;  
  53.             try {  
  54.                 str = br.readLine();  
  55.                 if(str.equals("END")){  
  56.                     br.close();  
  57.                     pw.close();  
  58.                     socket.close();  
  59.                     break;  
  60.                 }  
  61.                 System.out.println("Client Socket Message:"+str);  
  62.                 pw.println("Message Received");  
  63.                 pw.flush();  
  64.             } catch (Exception e) {  
  65.                 try {  
  66.                     br.close();  
  67.                     pw.close();  
  68.                     socket.close();  
  69.                 } catch (IOException e1) {  
  70.                     // TODO Auto-generated catch block  
  71.                     e1.printStackTrace();  
  72.                 }  
  73.             }  
  74.         }  
  75.     }  
  76.       
  77.       
  78.       
  79. }  


接下来利用我们上一次的客户端socket

 

 

这样一个简单地多客户端响应socket就成了

 

每次有一个请求发送过来服务端都会新建一个线程来单独服务。

相关推荐