1. public class TestUDP {
   
2. 
   
3.         /**
   
4.          * @param args
   
5.          * @throws IOException
   
6.          */
   
7.         public static void main(String[] args) throws IOException {
   
8.                 DatagramSocket send = new DatagramSocket();
   
9.                 Send s = new Send(send);
   
10.                 DatagramSocket rece = new DatagramSocket(10001);
    
11.                 Receive r = new Receive(rece);
    
12.                 new Thread(s).start();
    
13.                 new Thread(r).start();
    
14.         }
    
15. 
    
16. }
    
17. public class Send implements Runnable {
    
18.         private DatagramSocket ds;
    
19. 
    
20.         Send(DatagramSocket ds) {
    
21.                 this.ds = ds;
    
22.         }
    
23. 
    
24.         @Override
    
25.         public void run() {
    
26.                 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    
27.                 String line = null;
    
28.                 try {
    
29.                         while ((line = br.readLine()) != null) {
    
30.                                 byte[] bys = line.getBytes();
    
31.                                 InetAddress in = InetAddress.getLocalHost();
    
32.                                 DatagramPacket dp = new DatagramPacket(bys, bys.length, in,
    
33.                                                 10001);
    
34.                                 ds.send(dp);
    
35.                                 if(line.equalsIgnoreCase("over"))
    
36.                                         break;
    
37.                         }
    
38.                 } catch (IOException e) {
    
39.                         e.printStackTrace();
    
40.                 }
    
41.         }
    
42. }
    
43. public class Receive implements Runnable {
    
44.         private DatagramSocket ds;
    
45. 
    
46.         Receive(DatagramSocket ds) {
    
47.                 this.ds = ds;
    
48.         }
    
49. 
    
50.         @Override
    
51.         public void run() {
    
52.                 byte[] bys = new byte[1024];
    
53.                 DatagramPacket dp = new DatagramPacket(bys, bys.length);
    
54.                 try {
    
55.                         while (true) {
    
56.                                 ds.receive(dp);
    
57.                                 String data=new String(dp.getData(),0,dp.getLength());
    
58.                                 System.out.println(dp.getAddress().getHostAddress()+":"+data);
    
59.                         }
    
60.                 } catch (IOException e) {
    
61.                         e.printStackTrace();
    
62.                 }
    
63.         }
    
64. 
    
65. }

复制代码

一句注释都没有，懒得看了都

额 ,提问结束??