1. /*
   
2. 编写一个聊天程序。
   
3. 有收数据的部分，和发数据的部分。
   
4. 这两部分需要同时执行。
   
5. 那就需要用到多线程技术。
   
6. 一个线程控制收，一个线程控制发。
   
7. 
   
8. 因为收和发动作是不一致的，所以要定义两个run方法。
   
9. 而且这两个方法要封装到不同的类中。
   
10. 
    
11. */
    
12. import java.net.*;
    
13. import java.io.*;
    
14. class Send implements Runnable//发送端
    
15. {
    
16.         private DatagramSocket ds;
    
17.         public Send(DatagramSocket ds)
    
18.         {
    
19.                 this.ds=ds;
    
20.         }
    
21.         public void run()//多线程覆盖run方法
    
22.         {
    
23.                 try
    
24.                 {
    
25.                         //键盘录入
    
26.                         BufferedReader bufr=
    
27.                                 new BufferedReader(new InputStreamReader(System.in));
    
28. 
    
29.                         String len=null;
    
30. 
    
31.                         while((len=bufr.readLine())!=null)
    
32.                         {
    
33.                                 //转换成字节数组发送数据
    
34.                                 byte[] buf=len.getBytes();
    
35. 
    
36.                                 DatagramPacket dp=
    
37.                                         new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10001);
    
38. 
    
39.                                 ds.send(dp);
    
40. 
    
41.                                 if("886".equals(len))
    
42.                                         break;
    
43.                         }
    
44.                 }
    
45.                 catch (Exception e)
    
46.                 {
    
47.                         throw new RuntimeException("发送端失败");
    
48.                 }
    
49.         }
    
50. }
    
51. class Rece implements Runnable//接收端
    
52. {
    
53.         private DatagramSocket ds;
    
54.         public Rece(DatagramSocket ds)
    
55.         {
    
56.                 this.ds=ds;
    
57.         }
    
58.         public void run()
    
59.         {
    
60.                 try
    
61.                 {
    
62.                         while(true)
    
63.                         {
    
64.                                 //建立字节数组接收数据
    
65.                                 byte[] buf=new byte[1024];
    
66. 
    
67.                                 DatagramPacket dp=
    
68.                                         new DatagramPacket(buf,buf.length);
    
69. 
    
70.                                
    
71.                                 ds.receive(dp);
    
72. 
    
73.                                 //获取IP
    
74.                                 String ip=dp.getAddress().getHostAddress();
    
75. 
    
76.                                 //将包转化成字符串
    
77.                                 String data=new String(dp.getData(),0,dp.getLength());
    
78. 
    
79.                                 if("886".equals(data))
    
80.                                 {
    
81.                                         System.out.println(ip+"...离开聊天室");
    
82.                                         break;
    
83.                                 }
    
84.                                 //打印
    
85.                                 System.out.println(ip+".,"+data);
    
86.                         }
    
87.                 }
    
88.                 catch (Exception e)
    
89.                 {
    
90.                         throw new RuntimeException("接收端失败");
    
91.                 }
    
92.         }
    
93. }
    
94. 
    
95. class  ChatDemo
    
96. {
    
97.         public static void main(String[] args) throws Exception
    
98.         {
    
99.                 //创建接收端和发送端
    
100.                 DatagramSocket sendSocket = new DatagramSocket();
     
101.                 DatagramSocket receSocket = new DatagramSocket(10001);
     
102. 
     
103.                 //开启多线程
     
104.                 new Thread(new Send(receSocket)).start();
     
105.                 new Thread(new Rece(sendSocket)).start();
     
106.         }
     
107. }
     

复制代码

我知道肯定是个小问题....可是.找了半天还找到.发送数据没反应
打印结果

D:\java0410\day23>java ChatDemo
看吧没结果吧....
啊啊啊 啊啊

抢鑫鑫的沙发

楼主好搞笑

线程没学好啊！

李德全 发表于 2013-5-3 11:27
楼主好搞笑

肿么了???? - -

harborbest 发表于 2013-5-3 11:29
线程没学好啊！

怎么;了啊 啊啊 啊  - -

大哥，您这是什么玩意？
                new Thread(new Send(receSocket)).start();

                new Thread(new Rece(sendSocket)).start();

这传的是什么参数啊！！！哪个是发送端哪个是接收端搞乱了吧！你参数写反了！

参数ds没传

楼主让我想起了一个故事，有两个老农到镇上买了一口大水缸，由于水缸大，回家路途远，
两人费了一天的时间小心翼翼的抬到了家门口，特别高兴，正想总算安全太到家了，
正当他们要把水缸抬进家里时，不小心一个人被门卡拌了一下，摔倒了，于是水缸也摔到地上破了！

这个故事告诉我们任何时候都不能掉以轻心。

8楼说的对，参数传反了！应该是下面这样
new Thread(new Send(sendSocket)).start();
new Thread(new Rece(receSocket)).start();