黑马程序员技术交流社区

标题: 我对不起社会对不起党,UDP的聊天问题 [打印本页]

作者: 孙百鑫    时间: 2013-5-3 10:42
标题: 我对不起社会对不起党,UDP的聊天问题
  1. /*
  2. 编写一个聊天程序。
  3. 有收数据的部分,和发数据的部分。
  4. 这两部分需要同时执行。
  5. 那就需要用到多线程技术。
  6. 一个线程控制收,一个线程控制发。

  7. 因为收和发动作是不一致的,所以要定义两个run方法。
  8. 而且这两个方法要封装到不同的类中。

  9. */
  10. import java.net.*;
  11. import java.io.*;
  12. class Send implements Runnable//发送端
  13. {
  14.         private DatagramSocket ds;
  15.         public Send(DatagramSocket ds)
  16.         {
  17.                 this.ds=ds;
  18.         }
  19.         public void run()//多线程覆盖run方法
  20.         {
  21.                 try
  22.                 {
  23.                         //键盘录入
  24.                         BufferedReader bufr=
  25.                                 new BufferedReader(new InputStreamReader(System.in));

  26.                         String len=null;

  27.                         while((len=bufr.readLine())!=null)
  28.                         {
  29.                                 //转换成字节数组发送数据
  30.                                 byte[] buf=len.getBytes();

  31.                                 DatagramPacket dp=
  32.                                         new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10001);

  33.                                 ds.send(dp);

  34.                                 if("886".equals(len))
  35.                                         break;
  36.                         }
  37.                 }
  38.                 catch (Exception e)
  39.                 {
  40.                         throw new RuntimeException("发送端失败");
  41.                 }
  42.         }
  43. }
  44. class Rece implements Runnable//接收端
  45. {
  46.         private DatagramSocket ds;
  47.         public Rece(DatagramSocket ds)
  48.         {
  49.                 this.ds=ds;
  50.         }
  51.         public void run()
  52.         {
  53.                 try
  54.                 {
  55.                         while(true)
  56.                         {
  57.                                 //建立字节数组接收数据
  58.                                 byte[] buf=new byte[1024];

  59.                                 DatagramPacket dp=
  60.                                         new DatagramPacket(buf,buf.length);

  61.                                
  62.                                 ds.receive(dp);

  63.                                 //获取IP
  64.                                 String ip=dp.getAddress().getHostAddress();

  65.                                 //将包转化成字符串
  66.                                 String data=new String(dp.getData(),0,dp.getLength());

  67.                                 if("886".equals(data))
  68.                                 {
  69.                                         System.out.println(ip+"...离开聊天室");
  70.                                         break;
  71.                                 }
  72.                                 //打印
  73.                                 System.out.println(ip+".,"+data);
  74.                         }
  75.                 }
  76.                 catch (Exception e)
  77.                 {
  78.                         throw new RuntimeException("接收端失败");
  79.                 }
  80.         }
  81. }

  82. class  ChatDemo
  83. {
  84.         public static void main(String[] args) throws Exception
  85.         {
  86.                 //创建接收端和发送端
  87.                 DatagramSocket sendSocket = new DatagramSocket();
  88.                 DatagramSocket receSocket = new DatagramSocket(10001);

  89.                 //开启多线程
  90.                 new Thread(new Send(receSocket)).start();
  91.                 new Thread(new Rece(sendSocket)).start();
  92.         }
  93. }
复制代码
我知道肯定是个小问题....可是.找了半天还找到.发送数据没反应
打印结果

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


作者: 曹睿翔    时间: 2013-5-3 10:45
抢鑫鑫的沙发
作者: 李德全    时间: 2013-5-3 11:27
楼主好搞笑
作者: harborbest    时间: 2013-5-3 11:29
线程没学好啊!
作者: 孙百鑫    时间: 2013-5-3 13:31
李德全 发表于 2013-5-3 11:27
楼主好搞笑

肿么了???? - -
作者: 孙百鑫    时间: 2013-5-3 13:31
harborbest 发表于 2013-5-3 11:29
线程没学好啊!

怎么;了啊 啊啊 啊  - -
作者: 朱德帅    时间: 2013-5-3 16:07
大哥,您这是什么玩意?
                new Thread(new Send(receSocket)).start();

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

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

作者: Ysfox    时间: 2013-7-4 10:49
参数ds没传
作者: 吴光新    时间: 2013-7-6 21:17
本帖最后由 Jiewin 于 2013-7-6 21:23 编辑

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

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

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







欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2