在看毕老师的UDP传输时，遇到点问题，，，就是在接收端怎么用循环来处理 ，，，，，求教了 ，，谢谢大

家，（就是说我在发送端要发送100M的数据，我在接受端肯定是预先不知道大小的，我怎么在接收端利用循环成功接收）

1. import java.io.FileInputStream;
   
2. import java.io.InputStream;
   
3. import java.net.DatagramPacket;
   
4. import java.net.DatagramSocket;
   
5. import java.net.InetAddress;
   
6. import java.net.SocketException;
   
7. 
   
8. 
   
9. public class UDPSend {
   
10. 
    
11.         /**
    
12.          * @param args
    
13.          * @throws Exception
    
14.          */
    
15.         public static void main(String[] args) throws Exception {
    
16.                 // TODO Auto-generated method stub
    
17.                 DatagramSocket ds=new DatagramSocket();
    
18.                 //String str="UDP 演示";
    
19.                 StringBuilder sb=new StringBuilder();
    
20.                 InputStream is=new FileInputStream("a.txt");
    
21.                 int a=-1;
    
22.                 while((a=is.read())!=-1)
    
23.                 {
    
24.                         sb.append((char)a);
    
25.                 }
    
26.                 byte[] buf=sb.toString().getBytes();
    
27.                 DatagramPacket dp=new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10000);
    
28.                 ds.send(dp);
    
29.                 ds.close();
    
30.                
    
31. 
    
32.         }
    
33. 
    
34. }
    
35. [code]import java.io.FileOutputStream;
    
36. import java.io.OutputStream;
    
37. import java.net.DatagramPacket;
    
38. import java.net.DatagramSocket;
    
39. import java.net.SocketException;
    
40. 
    
41. 
    
42. public class UDPReceiver {
    
43. 
    
44.         /**
    
45.          * @param args
    
46.          * @throws Exception
    
47.          */
    
48.         public static void main(String[] args) throws Exception {
    
49.                 // TODO Auto-generated method stub
    
50.                 DatagramSocket ds=new DatagramSocket(10000);
    
51.                 byte[] buf=new byte[1024];//如果我要给接受端传个100M的数据，我总不能new100M的数组吧，怎么用循环解决
    
52.                 DatagramPacket dp=new DatagramPacket(buf,buf.length);
    
53.                 ds.receive(dp);
    
54.                 //String ip=dp.getAddress().getHostAddress();
    
55.                 //int  prot=dp.getPort();
    
56.                 String text=new String(dp.getData(),0,dp.getLength());
    
57.                 //System.out.println(ip+prot+text);
    
58.                 OutputStream os=new FileOutputStream("b.txt");
    
59.                 os.write(text.getBytes());
    
60.                
    
61.                 ds.close();
    
62. 
    
63.         }
    
64. 
    
65. }
    

复制代码

[/code]

caijunsong 发表于 2014-3-26 15:35

谢谢 太没太理解你写的东西

没运行，楼主自己运行一下

1.   import java.io.*;
   
2.       public class Demo1 {
   
3. 
   
4.               import java.io.FileInputStream;
   
5.               import java.io.InputStream;
   
6.               import java.net.DatagramPacket;
   
7.               import java.net.DatagramSocket;
   
8.               import java.net.InetAddress;
   
9.               import java.net.SocketException;
   
10. 
    
11. 
    
12.               public class UDPSend {
    
13. 
    
14.                       /**
    
15.                        * @param args
    
16.                        * @throws Exception
    
17.                        */
    
18.                       public static void main(String[] args) throws Exception {
    
19.                               // TODO Auto-generated method stub
    
20.                               DatagramSocket ds=new DatagramSocket();
    
21.                               //String str="UDP 演示";
    
22.                               StringBuilder sb=new StringBuilder();
    
23.                               InputStream is=new FileInputStream("a.txt");
    
24.                               int a=-1;
    
25.                               while((a=is.read())!=-1)
    
26.                               {
    
27.                                       sb.append((char)a);
    
28.                               }
    
29.                               byte[] buf=sb.toString().getBytes();
    
30.                               DatagramPacket dp=new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10000);
    
31.                               ds.send(dp);
    
32.                               ds.close();
    
33.                              
    
34. 
    
35.                       }
    
36. 
    
37.               }
    
38.               [code]import java.io.FileOutputStream;
    
39.               import java.io.OutputStream;
    
40.               import java.net.DatagramPacket;
    
41.               import java.net.DatagramSocket;
    
42.               import java.net.SocketException;
    
43. 
    
44. 
    
45.               public class UDPReceiver {
    
46. 
    
47.                       /**
    
48.                        * @param args
    
49.                        * @throws Exception
    
50.                        */
    
51.                       public static void main(String[] args) throws Exception {
    
52.                               // TODO Auto-generated method stub
    
53.                               DatagramSocket ds=new DatagramSocket(10000);
    
54.                               byte[] buf=new byte[1024*64];//如果我要给接受端传个100M的数据，我总不能new100M的数组吧，怎么用循环解决
    
55.                               DatagramPacket dp=new DatagramPacket(buf,buf.length);
    
56.                               while(true)  //将缓冲区该为可以封包的最大限度64k，循环，一直接受来自客户端的数据
    
57.                               {          
    
58.                               ds.receive(dp);
    
59.                               //String ip=dp.getAddress().getHostAddress();
    
60.                               //int  prot=dp.getPort();
    
61.                               String text=new String(dp.getData(),0,dp.getLength());
    
62.                               //System.out.println(ip+prot+text);
    
63.                               OutputStream os=new FileOutputStream("b.txt");
    
64.                               os.write(text.getBytes());
    
65.                               }
    
66.                               ds.close();
    
67. 
    
68.                       }
    
69. 
    
70.               }
    
71. 
    
72. 
    
73. 
    
74. 
    
75. 
    

复制代码

龙健 发表于 2014-3-26 21:32
没运行，楼主自己运行一下

多谢了   。。。。。。。。。。但还是不行，，，我觉得一次如果读不过来，数据已经丢失了

打架帮帮忙呗  有没有解决办法