Welcome 微信登录
编程资源 图片资源库 蚂蚁家优选 PDF转换器 软件资源

软件开发、小程序制作、系统集成与运维、空间租用、硬件开发、视频监控、技术咨询与支持——联系电话：0311-88999002/88999003

首页 / 操作系统 / Linux / JAVA 多线程实现聊天（UDP通信 ）

JAVA 多线程实现聊天（UDP通信 ）
  1. /* 
  2.  * UDP实现相互传递消息 
  3.  *  
  4.  */  
  5. import java.io.BufferedReader;  
  6. import java.io.IOException;  
  7. import java.io.InputStreamReader;  
  8. import java.net.DatagramPacket;  
  9. import java.net.DatagramSocket;  
  10. import java.net.InetAddress;  
  11.   
  12. /* 
  13.  * 客服端/发送端 
  14.  */  
  15. class Send implements Runnable{  
  16.     private DatagramPacket dPacket;  
  17.     private DatagramSocket dSocket;  
  18.     public Send（DatagramSocket dSocket）  
  19.     {  
  20.         this.dSocket=dSocket;  
  21.     }  
  22.     @Override  
  23.     public void run（） {  
  24.         // TODO Auto-generated method stub   
  25.         try {  
  26.             BufferedReader bufferedReader=new BufferedReader（new InputStreamReader（System.in））;//从键盘读取数据   
  27.             String string;  
  28.             while （（string=bufferedReader.readLine（））！=null） {//循环读取   
  29.                 if （string.equals（"Bye"））   
  30.                 {  
  31.                 System.err.println（"我下线了"）;  
  32.                 System.exit（0）;  
  33.                   
  34.                 }  
  35.                 byte []buf=string.getBytes（）;//将输入的字符串转换为字节数组   
  36.                 /* 
  37.                  * 获取本机ＩＰ（外网ＩＰ，我是发送到本机IP,也可以试试其它IP），然后从本机端口号为18888的端口发送出去 
  38.                  */  
  39.                 String IP=InetAddress.getLocalHost（）.getHostAddress（）.toString（）;  
  40.                 dPacket=new DatagramPacket（buf, buf.length, InetAddress.getByName（IP）, 18888）;  
  41.                 dSocket.send（dPacket）;  
  42.             }  
  43.         } catch （Exception e） {  
  44.             // TODO: handle exception   
  45.             System.err.println（"发送数据失败"）;  
  46.             e.printStackTrace（）;  
  47.         }  
  48.     }  
  49.       
  50. }  
  51. /* 
  52.  *服务器/ 接受端 
  53.  */  
  54. class Recive implements Runnable{  
  55.     private DatagramPacket dPacket;  
  56.     private DatagramSocket dSocket;  
  57.     public Recive（DatagramSocket dSocket）  
  58.     {  
  59.         this.dSocket=dSocket;  
  60.     }  
  61.     @Override  
  62.     public void run（） {  
  63.         // TODO Auto-generated method stub   
  64.         while （true） {  
  65.             byte[] buf=new byte[1024];  
  66.             dPacket=new DatagramPacket（buf, buf.length）;  
  67.             try {  
  68.                 dSocket.receive（dPacket）;  
  69.                 String IP=dPacket.getAddress（）.getHostAddress（）;  
  70.                 String data=new String（dPacket.getData（）, 0, dPacket.getLength（））;  
  71.                 int portString=dPacket.getPort（）;  
  72.                 System.out.println（"IP:"+IP+"端口:"+portString+" "+data）;  
  73.             } catch （IOException e） {  
  74.                 // TODO Auto-generated catch block   
  75.                 e.printStackTrace（）;  
  76.             }  
  77.               
  78.               
  79.         }  
  80.     }  
  81.       
  82. }  
  83. public class test {  
  84.   
  85.     /** 
  86.      * @param args 
  87.      */  
  88.     public static void main（String[] args） throws Exception{  
  89.         // TODO Auto-generated method stub   
  90.       
  91.       new Thread（new Send（new DatagramSocket（）））.start（）;  
  92.       
  93.       new Thread（new Recive（new DatagramSocket（18888）））.start（）;  
  94.     }  
  95.   
  96. }  
版权所有©石家庄振强科技有限公司2024 冀ICP备08103738号-5 网站地图