发送端线程：

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.         {
    
12. 
    
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());
    
21. 
    
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;
   
3. 
   
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.*;      

哪位大侠帮帮忙。。。。。

好吧，自己再冒个泡
接收端线程做了如下修改：因为，DatagramPacket传来的是字节所以我改为字节流，
文件是复制成功了，但每行数据都重复出现了三次，求助。。哪位大神知道怎么修改。。。。
接收端线程代码如下：

1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
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.         {
    
13. 
    
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);  
    
20. 
    
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. }
    

复制代码