今天老师说：使用线程和Io流可以实现局域网聊天。谁能帮我做一个，要有详细的注释，说明每个语句的意思？？谢谢大家了。。

1. import java.io.BufferedReader;
   
2. import java.io.IOException;
   
3. import java.io.InputStreamReader;
   
4. import java.net.*;
   
5. 
   
6. public class duoxianchengliaotian
   
7. {
   
8.         public static void main(String[]args) throws Exception
   
9.         {
   
10.                 DatagramSocket sendSocket = new DatagramSocket();
    
11.                 DatagramSocket resceSocket = new DatagramSocket(10000);
    
12.                 send s = new send(sendSocket);
    
13.                 resce r = new resce(resceSocket);
    
14.                 Thread t1 = new Thread(s);
    
15.                 Thread t2 = new Thread(r);
    
16.                 t1.start();
    
17.                 t2.start();
    
18.         }
    
19. }
    
20. 
    
21. class send implements Runnable {
    
22.         private DatagramSocket ds;
    
23.         public  send(DatagramSocket ds)
    
24.         {
    
25.                 this.ds=ds;
    
26.         }
    
27.         public void run()
    
28.         {
    
29.                 String line =null;
    
30.                 BufferedReader bfr = new BufferedReader(new InputStreamReader(System.in));
    
31.                 try {
    
32.                         while((line=bfr.readLine())!=null)
    
33.                         {
    
34.                                 byte[] buf  = line.getBytes();
    
35.                                 DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.0.102"),10000);
    
36.                                 ds.send(dp);
    
37.                                
    
38.                         }
    
39.                 } catch (IOException e) {
    
40.                         // TODO Auto-generated catch block
    
41.                         e.printStackTrace();
    
42.                 }
    
43.         }
    
44. 
    
45. }
    
46. 
    
47. class resce implements Runnable
    
48.         {
    
49.                 private DatagramSocket ds;
    
50.                 public  resce(DatagramSocket ds)
    
51.                 {
    
52.                         this.ds=ds;
    
53.                 }
    
54.                 public void run()
    
55.                 {
    
56.                         String line =null;
    
57.                        
    
58.                         while(true)
    
59.                         {
    
60.                                 byte[]buf = new byte[1024];
    
61.                                 DatagramPacket dp = new DatagramPacket(buf, buf.length);
    
62.                                 try {
    
63.                                         ds.receive(dp);
    
64.                                         String ip = dp.getAddress().getHostAddress();
    
65.                                         String data = new String(dp.getData(),0,dp.getLength());
    
66.                                         System.out.println(ip+":::"+data);
    
67.                                        
    
68.                                 } catch (IOException e) {
    
69.                                         // TODO Auto-generated catch block
    
70.                                         e.printStackTrace();
    
71.                                 }
    
72.                                 //ds.close();
    
73.                         }
    
74.                 }
    
75.         }

复制代码