黑马程序员技术交流社区

标题: 通过UDP传送并复制文件 [打印本页]
作者: 乘鱼飞    时间: 2013-5-5 22:06
标题: 通过UDP传送并复制文件
发送端线程：
  1. import java.io.*;
  2. import java.net.*;
  3. public class Send extends Thread{
  4.         private DatagramSocket socket;
  5.         public Send(DatagramSocket socket)
  6.         {
  7.                 this.socket=socket;
  8.         }
  9.         @Override
  10.         public void run()
  11.         {
  12.                 try {
  13.                         BufferedReader br=new BufferedReader(new FileReader("E:/TestIP.java"));
  14.                         String line=null;
  15.                 while((line=br.readLine())!=null)
  16.                 {
  17.                         byte[] buf=line.getBytes();
  18.                         DatagramPacket packet=new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10009);
  19.                     socket.send(packet);
  20.                 }
  21.                 } catch (FileNotFoundException e) {
  22.                         // TODO Auto-generated catch block
  23.                         e.printStackTrace();
  24.                 } catch (IOException e) {
  25.                         // TODO Auto-generated catch block
  26.                         e.printStackTrace();
  27.                 }
  28.         }
  29. }
复制代码
接收端线程：
  1. import java.io.*;
  2. import java.net.*;
  3. public class Receive extends Thread {
  4.         private DatagramSocket socket;
  5.         public Receive(DatagramSocket socket)
  6.         {
  7.                 this.socket=socket;
  8.         }
  9.         @Override
  10.         public void run()
  11.         {

  13.                         byte[] buf=new byte[1024];
  14.                         DatagramPacket packet=new DatagramPacket(buf,buf.length);
  15.                         try {
  16.                                 socket.receive(packet);
  17.                                 BufferedWriter bw=new BufferedWriter(new FileWriter("E:/aaa.txt"));
  18.                                
  19.                                 String data=null;
  20.                                 data=new String(packet.getData());

  22.                                 for(int i=0;i<packet.getLength();i++)
  23.                                 {
  24.                                         bw.write(data);
  25.                                         bw.newLine();
  26.                                         bw.flush();
  27.                                 }
  28.                         } catch (IOException e) {
  29.                                 e.printStackTrace();
  30.                         }
  31.         }
  32. }
复制代码
测试类：
  1. import java.net.DatagramSocket;
  2. import java.net.SocketException;

  4. public class TsetUDP {
  5.         public static void main(String[] args) throws Exception {
  6.                 DatagramSocket sendSocket=new DatagramSocket();
  7.                 DatagramSocket receiveSocket=new DatagramSocket(10009);
  8.         new Thread(new Send(sendSocket)).start();
  9.         new Thread(new Receive(receiveSocket)).start();
  10.         }
  11. }
复制代码
目的：（1）从发送端，把文件TestIP.java 发送到接收端
          （2）在接收端，接收文件并复制到 aaa.txt 中
现在只有接收端 搞不定
aaa.txt 中只有几行相同的数据，17行  import java.net.*;      

哪位大侠帮帮忙。。。。。
作者: 乘鱼飞    时间: 2013-5-6 11:43
好吧，自己再冒个泡
接收端线程做了如下修改：因为，DatagramPacket传来的是字节所以我改为字节流，
文件是复制成功了，但每行数据都重复出现了三次，求助。。哪位大神知道怎么修改。。。。
接收端线程代码如下：
  1. import java.io.*;
  2. import java.net.*;

  4. public class Receive extends Thread {
  5.         private DatagramSocket socket;
  6.         public Receive(DatagramSocket socket)
  7.         {
  8.                 this.socket=socket;
  9.         }
  10.         @Override
  11.         public void run()
  12.         {

  14.                         byte[] buf=new byte[1024];
  15.                        
  16.                         try {
  17.                                 FileOutputStream fos = new FileOutputStream("E:/bbb.txt");  
  18.                                 BufferedOutputStream bos = new BufferedOutputStream(fos);  
  19.                                 DataOutputStream dos = new DataOutputStream(bos);  

  21.                                 int i;
  22.                                 DatagramPacket packet=new DatagramPacket(buf,buf.length);
  23.                                 while(true)
  24.                                 {
  25.                                         boolean j=false;
  26.                                         while(packet.getData().length!=0)
  27.                                         {
  28.                                                 dos.write(packet.getData());
  29.                                                 socket.receive(packet);
  30.                                                 j=true;
  31.                                         }
  32.                                 }
  33.                         } catch (IOException e) {
  34.                                 e.printStackTrace();
  35.                         }
  36.         }
  37. }
复制代码




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