1. import java.io.*;
   
2. import java.net.*;
   
3. class Send implements Runnable
   
4. {
   
5.         private DatagramSocket ds;
   
6.         public Send(DatagramSocket ds)//发送的时候要用哪一个socket不确定，所以在发送端在构造时就传一个指定的socket进来
   
7.         {
   
8.                 this.ds = ds;
   
9.         }
   
10. 
    
11.         public void run()
    
12.         {
    
13.                 try//请问这里为什么不抛出异常而是选择了处理异常？
    
14.                 {
    
15.                         BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
    
16. 
    
17.                         String line = null;
    
18. 
    
19.                         while((line=bufr.readLine())!=null)
    
20.                         {
    
21.                                 byte[] buf = line.getBytes();
    
22. 
    
23.                                 DatagramPacket dp =
    
24.                                         new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.255"),10002);
    
25. 
    
26.                                 ds.send(dp);
    
27. 
    
28.                                 if("886".equals(line))
    
29.                                         break;
    
30.                         }
    
31.                 }
    
32.                 catch (Exception e)
    
33.                 {
    
34.                         throw new RuntimeException("发送端失败");
    
35.                 }
    
36.         }
    
37. }
    
38. 
    
39. class Rece implements Runnable
    
40. {
    
41. 
    
42.         private DatagramSocket ds;
    
43.         public Rece(DatagramSocket ds)
    
44.         {
    
45.                 this.ds = ds;
    
46.         }
    
47.         public void run()
    
48.         {
    
49.                 try//<span style="line-height: 30.7999992370605px;">请问这里为什么不抛出异常而是选择了处理异常？</span>
    
50.                 {
    
51.                         while(true)
    
52.                         {
    
53.                                 byte[] buf = new byte[1024];
    
54.                                 DatagramPacket dp = new DatagramPacket(buf,buf.length);
    
55.                                 ds.receive(dp);
    
56.                                 String ip = dp.getAddress().getHostAddress();
    
57.                                 String data = new String(dp.getData(),0,dp.getLength());
    
58.                                 if("886".equals(data))
    
59.                                 {
    
60.                                         System.out.println(ip+"....离开聊天室");
    
61.                                         break;
    
62.                                 }
    
63.                                 System.out.println(ip+":"+data);
    
64.                         }
    
65.                 }
    
66.                 catch (Exception e)
    
67.                 {
    
68.                         throw new RuntimeException("接收端失败");
    
69.                 }
    
70.         }
    
71. }
    
72. 
    
73. class  ChatDemo
    
74. {
    
75.         public static void main(String[] args) throws Exception
    
76.         {
    
77.                 DatagramSocket sendSocket = new DatagramSocket();
    
78.                 DatagramSocket receSocket = new DatagramSocket(10002);
    
79. 
    
80.                 new Thread(new Send(sendSocket)).start();
    
81.                 new Thread(new Rece(receSocket)).start();
    
82.         }
    
83. }

复制代码

这代码全部是你自己写的啊，感觉好强大啊