黑马程序员技术交流社区

标题: 请问UDP写聊天程序，为什么接收不到数据呢 [打印本页]
作者: Cola    时间: 2014-1-13 21:30
标题: 请问UDP写聊天程序，为什么接收不到数据呢
本帖最后由 Cola 于 2014-1-14 20:18 编辑

用UDP写的聊天程序，接收类Rece接收不到port。传的是10010，Rece类中的port是-1，请问为什么呢？
  1. class Rece implements Runnable
  2. {
  3.         private DatagramSocket ds;
  4.         public Rece(DatagramSocket ds)
  5.         {
  6.                 this.ds=ds;
  7.         }
  8.         public void run()
  9.         {
  10.                 try
  11.                 {
  12.                         while(true)
  13.                         {
  14.                                 System.out.println("Rece");
  15.                                 System.out.println("port "+ds.getPort());
  16.                                 byte[] buf=new byte[1024];
  17.                                 DatagramPacket dp=new DatagramPacket(buf,buf.length);
  18.                                 
  19.                                 ds.receive(dp);
  20.                                 System.out.println("Receive dp");

  22.                                 String ip=dp.getAddress().getHostAddress();

  24.                                 String data=new String(dp.getData(),0,dp.getLength());
  25.                                 if("886".equals(data))
  26.                                 {
  27.                                         System.out.println(ip+"......离开聊天室");
  28.                                         break;
  29.                                 }
  30.                                 System.out.println(ip+"::"+data);
  31.                         }
  32.                 }
  33.                 catch (Exception e)
  34.                 {
  35.                         throw new RuntimeException("接收端失败");
  36.                 }
  37.         }
  38. }

  40. class ChatDemo2
  41. {
  42.         public static void main(String[] args) throws Exception
  43.         {
  44.                 //DatagramSocket sendSocket=new DatagramSocket();
  45.                 DatagramSocket receSocket=new DatagramSocket(10010);

  47.                 //new Thread(new Send(sendSocket)).start();
  48.                 new Thread(new Rece(receSocket)).start();
  49.         }
  50. }
复制代码



捕获.JPG (15.88 KB, 下载次数: 46)

运行结果

运行结果
作者: 几番意难相付    时间: 2014-1-13 22:27
重新看看毕姥爷第23天的第八节课的视频吧
作者: 程玉习    时间: 2014-1-14 01:27
  1. class Rece implements Runnable
  2. {
  3.         private DatagramSocket ds ;
  4.         public Rece(DatagramSocket ds )
  5.         {
  6.                 this.ds = ds;
  7.         }
  8.        
  9.         public void run()
  10.         {
  11.                 try
  12.                 {
  13.                         while(true)
  14.                         {
  15.                                 byte[] buf = new byte[1024];

  17.                                 DatagramPacket dp = new DatagramPacket(buf,buf.length);
  18.                                
  19.                                 ds.receive(dp);
  20.                                
  21.                                 String ip = dp.getAddress().getHostAddress();

  23.                                 String data = new String(dp.getData(),0,dp.getLength());

  25.                                 System.out.println("(" + ip + "):" + data);
  26.                         }
  27.                 }
  28.                 catch (Exception e)
  29.                 {
  30.                         throw new RuntimeException("接收失败");
  31.                 }

  33.         }
  34. }
  35. class ChatDemo
  36. {
  37.         public static void main(String[] args) throws Exception
  38.         {
  39.                 //创建Send 和 Rece 的DatagramSocket对象，并指定监听的端口。
  40.                 DatagramSocket senfDs = new DatagramSocket(6666);
  41.                 DatagramSocket receDs = new DatagramSocket(8888);
  42.                
  43.                 //开启线程，进行通讯。
  44.                 new Thread(new Send(senfDs)).start();
  45.                 new Thread(new Rece(receDs)).start();
  46.         }
  47. }
复制代码
作者: 汪伟楠    时间: 2014-1-14 10:52
这是我刚写的，你看看对你有什么帮助没！
  1. import java.io.*;
  2. import java.net.*;
  3. class Send implements Runnable
  4. {
  5.         private DatagramSocket ds;
  6.         public Send(DatagramSocket ds)
  7.         {
  8.                 this.ds = ds;
  9.         }
  10.         public void run()
  11.         {
  12.                 try
  13.                 {
  14.                         BufferedReader bu = new BufferedReader(new InputStreamReader(System.in));
  15.                         String line = null;
  16.                         while((line =bu.readLine())!=null)
  17.                         {
  18.                                 if ("886".equals(line))
  19.                                         break;
  20.                                 byte[] bf = line.getBytes();
  21.                                 DatagramPacket dp
  22. 　　　　 = new DatagramPacket(bf,bf.length,InetAddress.getByName("127.0.0.1"),10002);
  23.                                 ds.send(dp);
  24.                         }
  25.                         ds.close();
  26.                 }
  27.                 catch (Exception e)
  28.                 {
  29.                         throw new RuntimeException("发送失败");
  30.                 }
  31.         }
  32. }
  33. class Rece implements Runnable
  34. {
  35.         private DatagramSocket ds;
  36.         public Rece(DatagramSocket ds)
  37.         {
  38.                 this.ds = ds;
  39.         }
  40.         public void run()
  41.         {
  42.                 try
  43.                 {
  44.                         while(true)
  45.                         {
  46.                                 byte[] buf = new byte[1024];
  47.                                 DatagramPacket dp = new DatagramPacket(buf,buf.length);
  48.                                 ds.receive(dp);
  49.                                 String ip = dp.getAddress().getHostAddress();
  50.                                 String data=new String(dp.getData(),0,dp.getLength());
  51.                                 int port = dp.getPort();
  52.                                 System.out.println(ip+"---"+data+"-----"+port);
  53.                         }
  54.                 }
  55.                 catch (Exception e)
  56.                 {
  57.                         throw new RuntimeException("接收失败");
  58.                 }
  59.         }
  60. }
  61. class ChatDemo
  62. {
  63.         public static void main(String[] args) throws Exception
  64.         {
  65.                 DatagramSocket sendSocket = new DatagramSocket();
  66.                 DatagramSocket receSocket = new DatagramSocket(10002);

  68.                 new Thread (new Send(sendSocket)).start();
  69.                 new Thread (new Rece(receSocket)).start();
  70.         }
  71. }
复制代码




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