1. 
   
2. 
   
3. import java.net.*;
   
4. import java.io.*;
   
5. import java.awt.*;
   
6. import java.awt.event.*;
   
7. import java.util.*;
   
8. import java.text.*;
   
9. 
   
10. 
    
11. class Send implements Runnable
    
12. {
    
13.          private DatagramSocket ds;
    
14.          private String text;
    
15.          Send(DatagramSocket ds,String text)
    
16.          {
    
17.          this.ds = ds;
    
18.          this.text = text;
    
19.          }
    
20. 
    
21.          public void run()
    
22.          {
    
23. 
    
24.                   byte[] buf = text.getBytes();
    
25. 
    
26.                   //封包
    
27.                   try
    
28.                   {
    
29.                            DatagramPacket dp =
    
30.                            new DatagramPacket(buf, buf.length,InetAddress.getByName("192.168.1.255"), 12005);
    
31.                            ds.send(dp);
    
32.                   }
    
33.                   catch (Exception e)
    
34.                   {
    
35.                            throw new RuntimeException("接收端失败");
    
36.                   }
    
37. 
    
38.          }
    
39. 
    
40. }
    
41. 
    
42. class Rece implements Runnable
    
43. {
    
44.          private DatagramSocket ds;
    
45.          private TextArea ta;
    
46.          Rece(DatagramSocket ds,TextArea ta)
    
47.          {
    
48.                   this.ds = ds;
    
49.                   this.ta = ta;
    
50.          }
    
51. 
    
52.          public void run() {
    
53.                   try {
    
54. 
    
55.                            while (true)
    
56.                            {
    
57. 
    
58.                                     byte[] buf = new byte[1024];
    
59.                                     DatagramPacket dp = new DatagramPacket(buf, buf.length);
    
60. 
    
61.                                     ds.receive(dp);//接收到数据就继续运行，没有就停在这了。
    
62. 
    
63.                                     String ip = dp.getAddress().getHostAddress();
    
64.                                     String data = new String(dp.getData(), 0, dp.getLength());
    
65.                                     System.out.println(ip + " : " + data);
    
66.                                     ta.append("("+ip+") "+Tools.getTime()+":\r\n"+data+"\r\n\r\n");
    
67.                            }
    
68. 
    
69.                   }catch (Exception e)
    
70.                   {
    
71.                            throw new RuntimeException("接收端失败");
    
72.                   }
    
73.          }
    
74. }
    
75. 
    
76. 
    
77. class ChatDemo
    
78. {
    
79. 
    
80.          private Frame f;
    
81. 
    
82.          private TextArea sendText,receText;
    
83. 
    
84.          private Button bt;
    
85. 
    
86.          ChatDemo()
    
87.          {
    
88.                   init();
    
89.          }
    
90. 
    
91.          public void init()
    
92.          {
    
93.                   f = new Frame("简易聊天");
    
94.                   f.setBounds(300,240,430,500);
    
95. 
    
96.                   f.setLayout(new FlowLayout()) ;
    
97. 
    
98.                   receText = new TextArea(18,50); //接收文本域
    
99.                   sendText = new TextArea(7,50); //输入文本域
    
100.                   receText.setEditable(false); //禁止输入
     
101. 
     
102.                   bt = new Button("发送");
     
103. 
     
104. 
     
105.                   f.add(receText);
     
106.                   f.add(sendText);
     
107.                   f.add(bt);
     
108. 
     
109.                   f.setVisible(true);
     
110.                   event();
     
111. 
     
112.          }
     
113. 
     
114. 
     
115.          public void event()
     
116.          {
     
117.                   //关闭窗口
     
118.                   f.addWindowListener(new WindowAdapter()
     
119.                   {
     
120.                            public void windowClosing(WindowEvent e)
     
121.                            {
     
122.                                     System.exit(0);
     
123.                            }
     
124.                   });
     
125. 
     
126.                   //发送
     
127.                   bt.addActionListener(new ActionListener()
     
128.                   {
     
129.                            public void actionPerformed(ActionEvent e)
     
130.                            {
     
131.                                     try
     
132.                                     {
     
133.                                              if(!"".equals(sendText.getText()))
     
134.                                              {
     
135.                                                       DatagramSocket sendSocket = new DatagramSocket();
     
136.                                                       new Thread(new Send(sendSocket,sendText.getText())).start();
     
137. 
     
138.                                                       sendText.setText("");     //发送完后，把输入文本域中的内容清空。
     
139.                                              }
     
140. 
     
141.                                     }
     
142.                                     catch (Exception ex)
     
143.                                     {
     
144.                                              throw new RuntimeException();
     
145.                                     }
     
146.                            }
     
147. 
     
148.                   });
     
149.          }
     
150. 
     
151.          public static void main(String[] args) throws Exception
     
152.          {
     
153.                   ChatDemo cd = new ChatDemo();
     
154.                   DatagramSocket receSocket = new DatagramSocket(12005);
     
155.                   new Thread(new Rece(receSocket,cd.receText)).start();
     
156.          }
     
157. }
     
158. 
     
159. 
     
160. 
     
161. 
     
162. class Tools
     
163. {
     
164.          //获取当前时间
     
165.          public static String getTime()
     
166.          {
     
167.                   Date date =new Date();
     
168.                   SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
     
169. 
     
170.                   return sdf.format(date);
     
171.          }
     
172. }
     
173. 
     
174. 
     
175. 
     

复制代码

请各位兄弟，看看我这代码写的有没有问题，如果能有两台机测试一下最好了。。。

是不能输出数据?

杜俊彪 发表于 2012-6-5 00:07
是不能输出数据?

可以输出数据，按照思路来写的，应该是没有问题。
就是不知道两台电脑连局域网进行聊天的时候，会不会有问题，毕竟没测试。

还有不知道我写的这个代码还有没有可以优化的地方。

这个我之前做过；   那你就发给自己也行啊！！！  把发送端改一下，    发给自己；

1. //封包
   
2.                   try
   
3.                   {
   
4.                            DatagramPacket dp =
   
5.                            new DatagramPacket(buf, buf.length,InetAddress.getByName(InetAddress.getLocalHost().getHostAddress()), 12005);
   
6.                            ds.send(dp);
   
7.                   }
   
8.                   catch (Exception e)
   
9.                   {
   
10.                            throw new RuntimeException("接收端失败");
    
11.                   }

复制代码

杜俊彪 发表于 2012-6-5 00:19
这个我之前做过；   那你就发给自己也行啊！！！  把发送端改一下，    发给自己； ...

老毕不是说，192.168.1.255是一个特殊的IP地址，局域网内，这个是一个广播地址，可以让所有局域网内的都能接收到数据吗？

杨天皓 发表于 2012-6-5 00:23
老毕不是说，192.168.1.255是一个特殊的IP地址，局域网内，这个是一个广播地址，可以让所有局域网内的都 ...

嗯，，可以，   我试过了；   

127.0.0.1 本机地址

我有点纳闷你的滚动条怎么加的？    没看到代码；  难道java.awt.TextArea  中自带的？？  我用java.swing.JTextArea;

杜俊彪 发表于 2012-6-5 00:35
我有点纳闷你的滚动条怎么加的？    没看到代码；  难道java.awt.TextArea  中自带的？？  我用java.swing. ...

对啊。TextArea自带的。
swing里面的控件我还没试过捏。明天来试试。