用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");
    
21. 
    
22.                                 String ip=dp.getAddress().getHostAddress();
    
23. 
    
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. }
    
39. 
    
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);
    
46. 
    
47.                 //new Thread(new Send(sendSocket)).start();
    
48.                 new Thread(new Rece(receSocket)).start();
    
49.         }
    
50. }
    

复制代码

这是我刚写的，你看看对你有什么帮助没！

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);
    
67. 
    
68.                 new Thread (new Send(sendSocket)).start();
    
69.                 new Thread (new Rece(receSocket)).start();
    
70.         }
    
71. }

复制代码

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];
    
16. 
    
17.                                 DatagramPacket dp = new DatagramPacket(buf,buf.length);
    
18.                                
    
19.                                 ds.receive(dp);
    
20.                                
    
21.                                 String ip = dp.getAddress().getHostAddress();
    
22. 
    
23.                                 String data = new String(dp.getData(),0,dp.getLength());
    
24. 
    
25.                                 System.out.println("(" + ip + "):" + data);
    
26.                         }
    
27.                 }
    
28.                 catch (Exception e)
    
29.                 {
    
30.                         throw new RuntimeException("接收失败");
    
31.                 }
    
32. 
    
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. }
    

复制代码

重新看看毕姥爷第23天的第八节课的视频吧