1. 
   
2. /*
   
3. 需求:
   
4. 通过udp建立简单的通讯软件;
   
5. */
   
6. 
   
7. import java.io.*;
   
8. import java.net.*;
   
9. class UdpSend implements Runnable
   
10. {
    
11. private DatagramSocket ds;
    
12. UdpSend(DatagramSocket ds)
    
13. {
    
14. this.ds=ds;
    
15. }
    
16. public void run()
    
17. {
    
18. BufferedReader bufr=null;
    
19. try
    
20. {
    
21. bufr=new BufferedReader(new InputStreamReader(System.in));
    
22. String line=null;
    
23. while ((line=bufr.readLine())!=null)
    
24. {
    
25. byte[] buf=line.getBytes();
    
26. try
    
27. {
    
28. DatagramPacket dp=new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.0.4"),10000);
    
29. ds.send(dp);
    
30. }
    
31. catch (UnknownHostException ue)
    
32. {
    
33. throw new RuntimeException("您指定的主机地址未知");
    
34. }
    
35. 
    
36. }
    
37. }
    
38. catch (IOException io)
    
39. {
    
40. throw new RuntimeException("读取键盘数据失败");
    
41. }
    
42. finally
    
43. {
    
44. try
    
45. {
    
46. if (bufr!=null)
    
47. {
    
48. bufr.close();
    
49. }
    
50. }
    
51. catch (IOException io)
    
52. {
    
53. throw new RuntimeException("读取流关闭失败");
    
54. }
    
55. ds.close();
    
56. }
    
57. }
    
58. }
    
59. 
    
60. 
    
61. class UdpReceive implements Runnable
    
62. {
    
63. private DatagramSocket ds;
    
64. UdpReceive(DatagramSocket ds)
    
65. {
    
66. this.ds=ds;
    
67. }
    
68. public void run()
    
69. {
    
70. while (true)
    
71. {
    
72. byte[] buf=new byte[1024];
    
73. DatagramPacket dp=new DatagramPacket(buf,buf.length);
    
74. try
    
75. {
    
76. ds.receive(dp);
    
77. }
    
78. catch (IOException i)
    
79. {
    
80. throw new RuntimeException("接受数据包失败");
    
81. }
    
82. String ip=dp.getAddress().getHostAddress();
    
83. 
    
84. System.out.println(ip);
    
85. 
    
86. String line=new String(dp.getData(),0,dp.getLength());
    
87. 
    
88. System.out.println(line);
    
89. 
    
90. if (line.equals("over"))
    
91. {
    
92. break;
    
93. }
    
94. 
    
95. ds.close();
    
96. }
    
97. 
    
98. }
    
99. }
    
100. 
     
101. 
     
102. class UdpSocket
     
103. {
     
104. public static void main(String[] args)
     
105. {
     
106. DatagramSocket dsSend=null;
     
107. 
     
108. DatagramSocket dsReceive=null;
     
109. try
     
110. {
     
111. dsSend=new DatagramSocket(8888);
     
112. 
     
113. dsReceive=new DatagramSocket(10000);
     
114. }
     
115. catch (SocketException se)
     
116. {
     
117. throw new RuntimeException("Socket服务创建失败");
     
118. }
     
119. UdpSend us=new UdpSend(dsSend);
     
120. 
     
121. UdpReceive ur=new UdpReceive(dsReceive);
     
122. 
     
123. new Thread(us).start();
     
124. 
     
125. new Thread(ur).start();
     
126. 
     
127. }
     
128. }

复制代码

具体异常的状况在DOS命令行的截图处

1. public void run()
   
2. 
   
3. {
   
4. 
   
5.         
   
6.                 byte[] buf=new byte[1024];
   
7.                 DatagramPacket dp=new DatagramPacket(buf,buf.length);
   
8.                 try
   
9.                 {
   
10.                 while (true){
    
11.                 ds.receive(dp);
    
12.                 String ip=dp.getAddress().getHostAddress();
    
13.                 System.out.println(ip);
    
14.                 String line=new String(dp.getData(),0,dp.getLength());
    
15.                 System.out.println(line);
    
16.                 if (line.equals("over")){break;}
    
17.                 }}
    
18.                 catch (IOException i){
    
19.                         throw new RuntimeException("接受数据包失败");
    
20.                 }
    
21.                 ds.close();
    
22.         
    
23. }

复制代码

你接收语句有错，应该把while循环放在try语句里，尽量让死循环语句范围小点，只有在调用receive方法是才会阻塞;
还有你发送类中循环语句也不正确，你这是在键盘输入，直接读取一行就好，不要判断读取是否为null；

林德燚 发表于 2012-4-26 11:31
你接收语句有错，应该把while循环放在try语句里，尽量让死循环语句范围小点，只有在调用receive方法是才会 ...

我找你说的,修改了一下,运行成功

但是具体为什么循环放在try外面就不可以啊???

能不能说详细点啊