1. package cn.itcast.UDP;
   
2. 
   
3. import java.io.BufferedReader;
   
4. import java.io.IOException;
   
5. import java.io.InputStreamReader;
   
6. import java.net.DatagramPacket;
   
7. import java.net.DatagramSocket;
   
8. import java.net.InetAddress;
   
9. 
   
10. class S implements Runnable{
    
11. 
    
12.         @Override
    
13.         public void run() {
    
14.                 try {
    
15.                         
    
16.                         DatagramSocket ds = new DatagramSocket(88);
    
17.                         BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    
18.                         
    
19.                         String str=null;
    
20.                         while((str=br.readLine())!=null){
    
21.                                 byte[] buf = str.getBytes();
    
22.                                 DatagramPacket dp = new DatagramPacket(
    
23.                                                                                 buf,buf.length,InetAddress.getByName("192.168.1.101"),10005);
    
24.                                 ds.send(dp);
    
25.                         }
    
26.                         
    
27.                         ds.close();        
    
28.                 } catch (Exception e) {
    
29.                         // TODO Auto-generated catch block
    
30.                         e.printStackTrace();
    
31.                 }
    
32.                         
    
33.                
    
34.         }
    
35. 
    
36. }
    
37. 
    
38. 
    
39. class R implements Runnable{
    
40. 
    
41.         @Override
    
42.         public void run() {
    
43.                 try{
    
44.                         
    
45.                         DatagramSocket ds = new DatagramSocket(10005);
    
46.                         while(true){
    
47.                                 byte[] by = new byte[10];
    
48.                                 DatagramPacket dp = new DatagramPacket(by, by.length);
    
49.                                 ds.receive(dp);
    
50.                                 
    
51.                                 System.out.println(new String(dp.getData(),0,by.length));
    
52.                         }
    
53.                         ds.close();//这里怎么关闭不了，报错。
    
54.                 }catch(Exception e){}
    
55. 
    
56.         }
    
57. }
    
58. 
    
59. public class UDP2{
    
60. 
    
61.         public static void main(String[] args) {
    
62. 
    
63.                 new Thread(new S()).start();
    
64.                 new Thread(new R()).start();
    
65.                
    
66.         }
    
67. }

复制代码

问题在注释处

有while循环，那里根本关闭不了，所以后面的close（）语句是到达不了的，改动了一下

1. package cn.itcast.UDP;
   
2. 
   
3. 
   
4. import java.io.BufferedReader;
   
5. import java.io.IOException;
   
6. import java.io.InputStreamReader;
   
7. import java.net.DatagramPacket;
   
8. import java.net.DatagramSocket;
   
9. import java.net.InetAddress;
   
10. 
    
11. class S implements Runnable{
    
12.         private DatagramSocket ds;
    
13.         public S(DatagramSocket ds){//弄一个构造方法，传入DataGramSocket
    
14.                 this.ds = ds;
    
15.         }
    
16.        
    
17. 
    
18.         @Override
    
19.         public void run() {
    
20.                 try {
    
21.                         
    
22.                         BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    
23.                         
    
24.                         String str=null;
    
25.                         while((str=br.readLine())!=null){
    
26.                                 byte[] buf = str.getBytes();
    
27.                                 DatagramPacket dp = new DatagramPacket(
    
28.                                                                                 buf,buf.length,InetAddress.getByName("localhost"),10005);
    
29.                                 ds.send(dp);
    
30.                         }
    
31.                         
    
32.                         ds.close();        
    
33.                 } catch (Exception e) {
    
34.                         // TODO Auto-generated catch block
    
35.                         e.printStackTrace();
    
36.                 }
    
37.                         
    
38.                
    
39.         }
    
40. 
    
41. }
    
42. 
    
43. 
    
44. class R implements Runnable{
    
45.         private DatagramSocket ds;
    
46. 
    
47.         public R( DatagramSocket ds){//弄一个构造方法，传入DataGramSocket
    
48.                 this.ds = ds;
    
49.         }
    
50. 
    
51.         @Override
    
52.         public void run() {
    
53.                 try{
    
54.                         
    
55.                         while(true){
    
56.                                 byte[] by = new byte[10];
    
57.                                 DatagramPacket dp = new DatagramPacket(by, by.length);
    
58.                                 ds.receive(dp);
    
59.                                 
    
60.                                 System.out.println(new String(dp.getData(),0,by.length));
    
61.                         }
    
62. //                        ds.close();//这里怎么关闭不了，报错。有while循环，这里就读不到：Unreachable code，
    
63.                                                 //去掉while之后，我觉等应该是关闭了，因为只有发送端在发数据，而没有接收端接收数据了
    
64.                 }catch(Exception e){}
    
65. 
    
66.         }
    
67. }
    
68. 
    
69. public class UDP2{
    
70. 
    
71.         public static void main(String[] args)throws Exception {
    
72. 
    
73.                 new Thread(new S(new DatagramSocket())).start();
    
74.                 new Thread(new R(new DatagramSocket(10005))).start();//接收端要知道端口
    
75.                
    
76.         }
    
77. }
    

复制代码

李锡碧 发表于 2013-9-24 00:32
while（true）｛｝......后面的执行不到了，，，

不是这个问题，去掉循环也报错。

while（true）｛｝......后面的执行不到了，，，