黑马程序员技术交流社区

标题: UDP 循环 [打印本页]
作者: 霍振鹏    时间: 2014-3-26 13:51
标题: UDP 循环
在看毕老师的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;


  9. public class UDPSend {

  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.                

  32.         }

  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;


  42. public class UDPReceiver {

  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();

  63.         }

  65. }
复制代码
[/code]
作者: 霍振鹏    时间: 2014-3-26 16:05
caijunsong 发表于 2014-3-26 15:35

谢谢 太没太理解你写的东西
作者: 龙健    时间: 2014-3-26 21:32
没运行，楼主自己运行一下
  1.   import java.io.*;
  2.       public class Demo1 {

  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;


  12.               public class UDPSend {

  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.                              

  35.                       }

  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;


  45.               public class UDPReceiver {

  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();

  68.                       }

  70.               }





复制代码
作者: 霍振鹏    时间: 2014-3-26 22:45
龙健 发表于 2014-3-26 21:32
没运行，楼主自己运行一下

多谢了   。。。。。。。。。。但还是不行，，，我觉得一次如果读不过来，数据已经丢失了
作者: 霍振鹏    时间: 2014-3-28 15:49
打架帮帮忙呗  有没有解决办法



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