1. import java.io.*;
   
2. import java.net.*;
   
3. import java.awt.*;
   
4. import java.awt.event.*;
   
5. class UdpSend implements Runnable
   
6. {
   
7.         private DatagramSocket ds;
   
8.         UdpSend(DatagramSocket ds)
   
9.         {
   
10.                 this.ds = ds;
    
11.         }
    
12.         public void run()
    
13.         {       
    
14.                 try
    
15.                 {
    
16.                                 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    
17.                                 String line = null;
    
18.                                 while((line=br.readLine())!=null)
    
19.                                 {
    
20.                                         byte[] buf = line.getBytes();
    
21.                                         DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.255"),10086);
    
22.                                         ds.send(dp);
    
23.                                 }
    
24.                        
    
25.                 }
    
26.                 catch (Exception e)
    
27.                 {
    
28.                         System.out.println("传送数据失败！");
    
29.                 }
    
30.         }
    
31. }
    
32. class UdpReceive implements Runnable
    
33. {
    
34.         private DatagramSocket ds;
    
35.         UdpReceive(DatagramSocket ds)
    
36.         {
    
37.                 this.ds = ds;
    
38.         }
    
39.         public void run()
    
40.         {
    
41.                 try
    
42.                 {
    
43.                         while(true)
    
44.                         {
    
45.                                 byte[] buf = new byte[1024];
    
46.                                 DatagramPacket dp = new DatagramPacket(buf,buf.length);       
    
47.                                 ds.receive(dp);
    
48.                                
    
49.                                 InetAddress ia = dp.getAddress();
    
50.                                 String name = ia.getHostName();
    
51.                                 String ip = ia.getHostAddress();
    
52.                                 String data = new String(dp.getData(),0,dp.getLength());
    
53.                                 System.out.println(name+":"+ip+"--"+data);
    
54.                         }
    
55.                 }
    
56.                 catch (Exception e)
    
57.                 {
    
58.                         System.out.println("接收数据异常！");
    
59.                 }
    
60.         }
    
61. }
    
62. class YY
    
63. {
    
64.         public static void main(String[] args) throws Exception                        //建立传输/接收对象要抛异常
    
65.         {
    
66.                 new Thread(new UdpSend(new DatagramSocket())).start();
    
67.                 new Thread(new UdpReceive(new DatagramSocket(10086))).start();       
    
68.         }
    
69. }
    

复制代码

以上是UDP的聊天代码，我想为这个代码添加一个GUI的界面，但不知道如何下手，请高手指点下呗！

我也一直想做一个，做了一上午，终于做出来了，代码如下：

1. package udpChat;
   
2. 
   
3. import java.awt.*;
   
4. import java.awt.event.*;
   
5. import java.io.File;
   
6. import java.net.DatagramPacket;
   
7. import java.net.DatagramSocket;
   
8. import java.net.InetAddress;
   
9. 
   
10. public class UdpChatFrame {
    
11.         private Frame f;
    
12.         private TextField tf;
    
13.         private Button but;
    
14.         private Button butSend;
    
15.         private TextArea taReceive;// 数据接收窗口
    
16.         private TextArea taSend;// 数据发送窗口
    
17. 
    
18.         private Dialog d;// 用于校验IP地址
    
19.         private Label receiveLab;
    
20.         private Label sendLab;
    
21.         private Button okBut;// 对话框上的确定按钮
    
22.         
    
23.         public String ip;
    
24.         UdpChatFrame() {
    
25.                
    
26. 
    
27.         }
    
28.         //创建窗体，开启线程
    
29.         public void init() {
    
30. 
    
31.                 f = new Frame("Udp聊天框");
    
32.                 f.setBounds(300, 100, 600, 500);
    
33.                 f.setLayout(new FlowLayout());
    
34. 
    
35.                 tf = new TextField(70);
    
36.                 but = new Button("连接");
    
37.                 taReceive = new TextArea(10, 60);
    
38.                 taSend = new TextArea(10, 60);
    
39.                 receiveLab = new Label("接收信息:");
    
40.                 sendLab = new Label("发送信息:");
    
41.                 butSend = new Button("发送");
    
42. 
    
43.                 f.add(tf);
    
44.                 f.add(but);
    
45.                 f.add(receiveLab);
    
46.                 f.add(taReceive);
    
47.                 f.add(sendLab);
    
48.                 f.add(taSend);
    
49.                 f.add(butSend);
    
50.                
    
51.                 //开启一个接收线程用于不断地接收输入的信息
    
52.                 new Thread(new ReceiveThread()).start();
    
53.                 myEvent();
    
54.                
    
55.                 f.setVisible(true);
    
56.         }
    
57. 
    
58.         private void myEvent() {
    
59.                 //监听 连接 按钮
    
60.                 but.addActionListener(new ActionListener() {
    
61.                         public void actionPerformed(ActionEvent e) {
    
62.                                 ip = tf.getText();
    
63.                                 taReceive.append("开始和" + ip + "主机对话吧......" + "\r\n");
    
64.                                 taReceive.append("---------------------------------------"
    
65.                                                 + "\r\n");
    
66.                                 
    
67.                         
    
68.                         }
    
69.                 });
    
70.                 //监听 发送 按钮
    
71.                 butSend.addActionListener(new ActionListener() {
    
72.                         public void actionPerformed(ActionEvent e) {
    
73.                                 String message = taSend.getText();
    
74.                                 taReceive.append("我：" + message + "\r\n");
    
75.                                 send(message);
    
76.                                 taSend.setText("");
    
77.                         }
    
78.                 });
    
79.                 f.addWindowListener(new WindowAdapter() {
    
80. 
    
81.                         public void windowClosing(WindowEvent e) {
    
82.                                 System.exit(0);
    
83. 
    
84.                         }
    
85.                 });
    
86. 
    
87.         }
    
88.         //发送 方法
    
89.         public void send(String message)
    
90.         {
    
91.                 try
    
92.                 {
    
93.                         DatagramSocket ds = new DatagramSocket();                        
    
94.                                 byte[] buf = message.getBytes();
    
95.                                 //将缓冲区中的数据打包，用于发送。
    
96.                                 DatagramPacket dp =
    
97.                                                 new DatagramPacket(buf, buf.length,InetAddress.getByName(ip), 10086);
    
98.                                 ds.send(dp);
    
99.                         
    
100.                         
     
101.                 }
     
102.                 catch (Exception e)
     
103.                 {
     
104.                         e.printStackTrace();
     
105.                 }
     
106.                
     
107.         }
     
108.         
     
109.         //内部类  用于接收
     
110.         public class ReceiveThread implements Runnable {
     
111.                 private DatagramSocket receiveDs;
     
112.                 public void setReceiveDs()
     
113.                 {
     
114.                         try
     
115.                         {
     
116.                                 this.receiveDs = new DatagramSocket(10086);
     
117.                         }
     
118.                         catch (Exception e)
     
119.                         {
     
120.                                 e.printStackTrace();
     
121.                         }                        
     
122.                 }
     
123.                 //一创建就 标好端口号
     
124.                 ReceiveThread()
     
125.                 {
     
126. 
     
127.                         setReceiveDs();
     
128.                 }
     
129. 
     
130.                
     
131.                 public void run() {
     
132.                         try
     
133.                         {
     
134.                                 while(true)
     
135.                                 {
     
136.                                         byte[] buf = new byte[1024];
     
137.                                         //将接收缓冲区封装起来，用于存放接收到的数据。
     
138.                                         DatagramPacket dp = new DatagramPacket(buf, buf.length);
     
139.                                         receiveDs.receive(dp);                                
     
140.                                         String data = new String(dp.getData(),0,dp.getLength());
     
141.                                        
     
142.                                                 taReceive.append("他："+data+"\r\n");        
     
143.                                        
     
144.                                 }                        
     
145.                                 
     
146.                         }
     
147.                         catch (Exception e)
     
148.                         {                        
     
149.                                 e.printStackTrace();                        
     
150.                         }
     
151.                 }
     
152.                
     
153.         }
     
154.                
     
155.         }

复制代码

主函数：

1. package udpChat;
   
2. import java.net.*;
   
3. 
   
4. public class UdpChat {
   
5.        
   
6. 
   
7.         public static void main(String[] args)
   
8.         {
   
9.                
   
10.                 try
    
11.                 {
    
12.                         UdpChatFrame udpChatFrame = new UdpChatFrame();
    
13.                         udpChatFrame.init();       
    
14.                        
    
15.                 }
    
16.                 catch (Exception e)
    
17.                 {
    
18.                         e.printStackTrace();
    
19.                 }       
    
20. 
    
21.         }
    
22. 
    
23. }
    

复制代码

缺陷：接收端也能输入。
遇到的最大的困难就是需要在init（)方法中开启两个线程，主线程和接收线程,也就是说需要在一个类的方法中运行两个线程。
解决方法：接收线程定义了内部类ReceiveThread。
希望能对你有帮助。