1 import java.net.*; 2 import java.io.*; 3 class UDPSendThread implements Runnable 4 { 5     private DatagramSocket ds=null; 6     public UDPSendThread(DatagramSocket ds) 7     { 8         this.ds=ds; 9     }10     public void run()11     {12         BufferedReader br=new BufferedReader(new InputStreamReader(System.in));13         String line=null;14         try15         {16             while((line=br.readLine())!=null)17             {18                 if("886".equals(line))19                 {20                     break;21                 }22                 byte[]buf=line.getBytes();23                 DatagramPacket dp=new DatagramPacket(buf,buf.length,InetAddress.getByName24 25 ("127.0.0.1"),10002);26                 ds.send(dp);27             }28         }29         catch(Exception ex)30         {31             System.out.println(ex);32             throw new RuntimeException("发送失败");33         }34     }35 }36 37 class UDPReceiveThread implements Runnable38 {39     private DatagramSocket ds=null;40     public UDPReceiveThread(DatagramSocket ds)41     {42         this.ds=ds;43     }44     public void run()45     {46         47         try48         {49             while(true)50             {51                 byte[] buf=new byte[1024];52                 DatagramPacket dp=new DatagramPacket(buf,buf.length);53                 ds.receive(dp);54                 String ip=dp.getAddress().getHostAddress();55                 String data=http://www.mamicode.com/new String(dp.getData(),0,dp.getLength());56                 System.out.println(ip+"......"+data);57                 58             }59         }60         catch(Exception ex)61         {62             throw new RuntimeException("接收失败");63         }64     }65 }66 67 class UDPThreadDemo68 {69     public static void main(String[]args) throws Exception70     {71         DatagramSocket dsSend=new DatagramSocket();72         DatagramSocket dsReceive=new DatagramSocket(10002);73         new Thread(new UDPSendThread(dsSend)).start();74         new Thread(new UDPReceiveThread(dsReceive)).start();75     }76 }