1. package com.jwis.cos;
   
2. 
   
3. import java.awt.Button;
   
4. import java.awt.FlowLayout;
   
5. import java.awt.Frame;
   
6. import java.awt.TextArea;
   
7. import java.awt.TextField;
   
8. import java.awt.event.ActionEvent;
   
9. import java.awt.event.ActionListener;
   
10. import java.awt.event.KeyAdapter;
    
11. import java.awt.event.KeyEvent;
    
12. import java.awt.event.WindowAdapter;
    
13. import java.awt.event.WindowEvent;
    
14. import java.io.IOException;
    
15. import java.net.DatagramPacket;
    
16. import java.net.DatagramSocket;
    
17. import java.net.InetAddress;
    
18. import java.net.SocketException;
    
19. import java.net.UnknownHostException;
    
20. 
    
21. public class UDPChatFrame {
    
22.         public static void main(String[] args) {
    
23.                 try {
    
24.                         DatagramSocket sendSocket = new DatagramSocket();
    
25.                         DatagramSocket recvSocket = new DatagramSocket(10000);
    
26.                         SendMsg send = new SendMsg(sendSocket);
    
27.                         ChatWindow chat = new ChatWindow();
    
28.                         chat.Rec(send);
    
29.                         RecvMsg recv = new RecvMsg(recvSocket,chat);
    
30.                         Thread rec = new Thread(recv);
    
31.                         rec.start();
    
32.                 } catch (SocketException e) {
    
33.                         // TODO Auto-generated catch block
    
34.                         e.printStackTrace();
    
35.                 }
    
36.         }
    
37. }
    
38. 
    
39. class SendMsg implements Runnable
    
40. {
    
41.         private DatagramSocket socket;
    
42.         private String Message;
    
43.         public void Message(String Message) {
    
44.                 // TODO Auto-generated method stub
    
45.                 this.Message = Message;
    
46.         }
    
47.         public SendMsg(DatagramSocket socket) {
    
48.                 // TODO Auto-generated constructor stub
    
49.                 this.socket = socket;
    
50.         }
    
51.         @Override
    
52.         public void run() {
    
53.                 // TODO Auto-generated method stub
    
54.                 byte [] sends = new byte[1024];
    
55.                 sends = Message.getBytes();
    
56.                 try {
    
57.                         DatagramPacket packet =
    
58.                                         new DatagramPacket(sends, sends.length, InetAddress.getByName("192.168.1.104"), 10000);
    
59.                         socket.send(packet);
    
60.                 } catch (UnknownHostException e) {
    
61.                         // TODO Auto-generated catch block
    
62.                         e.printStackTrace();
    
63.                 } catch (IOException e) {
    
64.                         // TODO Auto-generated catch block
    
65.                         e.printStackTrace();
    
66.                 }
    
67.         }
    
68.        
    
69. }
    
70. class RecvMsg implements Runnable
    
71. {
    
72.         private DatagramSocket socket;
    
73.         private ChatWindow chat;
    
74.         public RecvMsg(DatagramSocket socket,ChatWindow chat) {
    
75.                 // TODO Auto-generated constructor stub
    
76.                 this.socket = socket;
    
77.                 this.chat = chat;
    
78.         }
    
79.         @Override
    
80.         public void run() {
    
81.                 // TODO Auto-generated method stub
    
82.                 try {
    
83.                         while(true)
    
84.                         {
    
85.                                 byte [] recv = new byte[1024];
    
86.                                 DatagramPacket packet = new DatagramPacket(recv, recv.length);
    
87.                                 socket.receive(packet);
    
88.                                 String data =new String(packet.getData(),0,packet.getLength());
    
89.                                 String name =packet.getAddress().getHostAddress();
    
90.                                 chat.output.append(name+":\r\n"+data+"\r\n");
    
91.                         }
    
92.                 } catch (IOException e) {
    
93.                         // TODO Auto-generated catch block
    
94.                         e.printStackTrace();
    
95.                 }
    
96.         }
    
97.        
    
98. }
    
99. class ChatWindow
    
100. {
     
101.         private Frame frame;
     
102.         public TextArea output;
     
103.         private TextField input;
     
104.         private Button button;
     
105.         private SendMsg send= null;
     
106.         public void Rec(SendMsg send) {
     
107.                 // TODO Auto-generated method stub
     
108.                 this.send = send;
     
109.         }
     
110.         public ChatWindow() {
     
111.                 // TODO Auto-generated constructor stub
     
112.                 frame = new Frame("chatroom");
     
113.                 frame.setBounds(100, 100, 450, 500);
     
114.                 frame.setLayout(new FlowLayout());
     
115.                 output = new TextArea(null, 20, 50,1);
     
116.                 input = new TextField(30);
     
117.                 button = new Button("send");
     
118.                 frame.add(output);
     
119.                 frame.add(input);
     
120.                 frame.add(button);
     
121.                 myEvents();
     
122.                 frame.setVisible(true);
     
123.         }
     
124.         private void myEvents() {
     
125.                 // TODO Auto-generated method stub
     
126.                 frame.addWindowListener(new WindowAdapter() {
     
127.                         public void windowClosing(WindowEvent e)
     
128.                         {
     
129.                                 System.exit(0);
     
130.                         }
     
131.                 });
     
132.                 button.addActionListener(new ActionListener() {
     
133.                        
     
134.                         @Override
     
135.                         public void actionPerformed(ActionEvent e) {
     
136.                                 // TODO Auto-generated method stub
     
137.                                 String s = input.getText();
     
138.                                 send.Message(s);
     
139.                                 Thread sendMessage = new Thread(send);
     
140.                                 sendMessage.start();
     
141.                                 input.setText(null);
     
142.                         }
     
143.                 });
     
144.                 input.addKeyListener(new KeyAdapter() {
     
145.                         public void keyPressed(KeyEvent e)
     
146.                         {
     
147.                                 if(e.getKeyCode()==KeyEvent.VK_ENTER)
     
148.                                 {
     
149.                                         String s = input.getText();
     
150.                                         send.Message(s);
     
151.                                         Thread sendMessage = new Thread(send);
     
152.                                         sendMessage.start();
     
153.                                         input.setText(null);
     
154.                                 }
     
155.                         }
     
156.                 });
     
157.         }
     
158. }

复制代码

由于只有一个人无法进行测试。。。希望有人能够一起交流下

OK，已经测试过，没问题~不过建议在发送的时候加一个过滤，空字符串不能发送，不然一直按Enter就一直出192.168.1.110加空字符串

强大的楼主，向楼主学习