基于UDP传输协议局域网文件接收软件设计 Java版

　　网路传输主要的两大协议为TCP/IP协议和UDP协议，本文主要介绍基于UDP传输的一个小软件分享，针对于Java网络初学者是一个很好的练笔，大家可以参考进行相关的联系，但愿能够帮助到大家。

　　话不多说，直接上代码结构图：

　　

　　FindThread类是为了创建接收服务线程，GetLocalHostAddress类是为了获取本地IP地址，作为远程传输的目标地址，GetLocalTime是为了获取本地时间，为主界面提示信息建立时间戳，GetRandomNumber是为了方便创建端口号的，端口号正常范围是0到65535，（具体信息请百度，谢谢，有的人老是问为什么，我不禁要说一句How old are you！为什么不能自己去查一查呢！）GetSavePath类是为了实现存储功能，路径由用户自定义，MyRunable是上文所提线程的实例化，UDPReceiveSever类是详细实现协议功能，也是这个软件的核心部分。下面具体详细的列一下实现代码：

　　FindThread类

package fc;

public class FindThread {
    public static Thread findThread(long threadId) {
        ThreadGroup group = Thread.currentThread().getThreadGroup();
        while(group != null) {
            Thread[] threads = new Thread[(int)(group.activeCount() * 1.2)];
            int count = group.enumerate(threads, true);
            for(int i = 0; i < count; i++) {
                if(threadId == threads[i].getId()) {
                    return threads[i];
                }
            }
            group = group.getParent();
        }
        return null;
    }
}

　　GetLocalHostAddress类

package fc;

import java.net.InetAddress;
import java.net.UnknownHostException;

public class GetLocalHostAddress {

    public String getLocalHostAddress() throws UnknownHostException{
        InetAddress ia = InetAddress.getLocalHost();
        String ip= ia.getHostAddress();
        return ip;
    }

}

　　GetLocalTime类

package fc;

import java.text.SimpleDateFormat;
import java.util.Date;

public class GetLocalTime {

    public String getLocalTime(){
        Date date = new Date(); 
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
        String time = dateFormat.format(date);
        return time;
    }
}

　　GetRandomNumber类

package fc;

import java.util.Random;

public class GetRandomNumber {

    public int getRandomNumber(){
        int max=65535;
        int min=1025;
        Random random_N = new Random();
        int num = random_N.nextInt(max)%(max-min+1) + min;
        return num;
    }
}

　　GetSavePath类

package fc;

import java.io.File;

import javax.swing.JFileChooser;
import javax.swing.JLabel;

public class GetSavePath {

    private String filepath = "";
    public String getSavePath(){
        JFileChooser jfc=new JFileChooser();
        jfc.setFileSelectionMode(JFileChooser.DIRECTORIES_ONLY);
        jfc.showDialog(new JLabel(), "选择路径");
        File file=jfc.getSelectedFile();
        if(file.isDirectory()){
        }else if(file.isFile()){
        }
        this.filepath=file.getAbsolutePath();
        return filepath;
    }
}

　　MyRunable类

package fc;

import java.io.IOException;

public class MyRunnable implements Runnable {
    public void run() {
        UDPReceiveService urs = new UDPReceiveService();
        try {
            urs.receiveFile();
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

　　UDPReceiveService类

package fc;

import java.io.BufferedOutputStream;
import java.io.DataOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

import fm.MainWindows;

public class UDPReceiveService {
    
    public static String IP         = "";
    public static String filePath     = "";
    public static int      Port         = 0;
    GetLocalTime           glt         = new  GetLocalTime();
    public static long   thr_id;
    
    @SuppressWarnings("static-access")
    void receiveFile() throws IOException, InterruptedException { 
        MainWindows.jta.setText("");
        if(filePath.equals("")){
            MainWindows.jta.append("【"+glt.getLocalTime()+"】    "+"服务启动失败......错误：文件存储路径无效或为空！
");
            MainWindows.jta.setCaretPosition(MainWindows.jta.getText().length());  
            Thread.currentThread().interrupt();
        }
        thr_id = Thread.currentThread().getId();
        @SuppressWarnings("resource")        
        DatagramSocket dataSocket  =  new DatagramSocket(Port);
        MainWindows.jta.append("【"+glt.getLocalTime()+"】    "+"服务准备启动......
");
        MainWindows.jta.setCaretPosition(MainWindows.jta.getText().length());  
        byte[] receiveByte;
        DatagramPacket dataPacket;
        @SuppressWarnings("resource")
        DataOutputStream fileOut = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(filePath)));
        MainWindows.jta.append("【"+glt.getLocalTime()+"】    "+"创建接收路径已完成！
");
        MainWindows.jta.setCaretPosition(MainWindows.jta.getText().length());  
        int i = 0;
        MainWindows.jta.append("【"+glt.getLocalTime()+"】    "+"服务已经启动！
");
        MainWindows.jta.setCaretPosition(MainWindows.jta.getText().length());  
        MainWindows.jt3_1.setText("服务正在运行......");
        MainWindows.jta.setCaretPosition(MainWindows.jta.getText().length());  
        int num1 = 0,num2 = 0;
        double num3 = 0;
        while(i == 0){
            receiveByte = new byte[64512];
            dataPacket = new DatagramPacket(receiveByte, receiveByte.length);
            dataSocket.receive(dataPacket);
            i = dataPacket.getLength();
            if(i > 0){
                MainWindows.jta.append("【"+glt.getLocalTime()+"】    "+"捕获到数据包，大小为"+i/1024+"KB,数据存储已完成！
");
                MainWindows.jta.setCaretPosition(MainWindows.jta.getText().length());  
                fileOut.write(receiveByte,0,i);
                fileOut.flush();
                num3 = num3 + i/1024;
                i = 0;
                num2 = num2 + 1;
            }
            if(num2 > 0 && num2 == num1){
                MainWindows.jta.append("【"+glt.getLocalTime()+"】    "+"文件存储已完成，大小："+num3/1024+"M
");
                MainWindows.jta.setCaretPosition(MainWindows.jta.getText().length());  
                Thread.currentThread().sleep(10);
                MainWindows.jta.append("【"+glt.getLocalTime()+"】    "+"服务重载成功，正在运行......
");
                MainWindows.jta.setCaretPosition(MainWindows.jta.getText().length());  
                num2 = 0;
            }
            num1=num2;
        }
    }
}

　　窗体文件就不再详细展出了，运行结果如下图：