局域网使用Java进行文件传输

时间:2024-02-24 20:48:15
package com.herley;
/**
 *
 * 客户端
 */


import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Scanner;
import java.util.TimeZone;

public class Send {
    public static void main(String[] args) {
        File filesrc;       //需要传送的文件
        Socket socket;  //套接字
        FileInputStream open;   //读取文件
        FileOutputStream out;   //传送文件
        Scanner sc;//键盘录入
        Date start;
        Date end;

        try {
            System.out.println("[欢迎使用局域网发送系统,仅支持单文件发送]");
            System.out.print("请输入你要发送的文件路径!");
            System.out.println("(注意格式:文件路径+后缀名!)");
            //需要传输的文件
            sc = new Scanner(System.in);
            String src = sc.nextLine();

            filesrc = new File(src);//键盘录入需要传输的文件路径
            open = new FileInputStream(filesrc);//创建文件输入流
            //连接服务器
            System.out.println("请输入服务器的ip地址");
            sc = new Scanner(System.in);
            String url = sc.nextLine();

//            System.out.println("请输入服务器的端口号");
//            sc = new Scanner(System.in);
//            int port = sc.nextInt();

            socket = new Socket(url, 2017);//创建socket

            out = (FileOutputStream)socket.getOutputStream();//创建文件输出流

            //开始传送
            byte[] b = new byte[1024];
            int n = open.read(b);//首次传送

//            int start = (int)System.currentTimeMillis();
            start = new Date();//首次时间
            while (n != -1) {
                out.write(b, 0, n);

                n = open.read(b);
            }
//            int end = (int)System.currentTimeMillis();
            end = new Date();
            long l = Send.printSplitTime(start, end);
            SimpleDateFormat formatter =  new SimpleDateFormat("HH:mm:ss");
            formatter.setTimeZone(TimeZone.getTimeZone("GMT+00:00"));
            String hms = formatter.format(l);

            System.out.println( "发送成功,耗时:" + hms);
            System.out.println("谢谢使用");
            //关闭流
            out.close();
            socket.close();
            open.close();
        } catch (Exception e) {
            System.out.println("文件路径或者ip有误");
        }
    }
    public static long printSplitTime(Date start, Date end) {
        long interval = (end.getTime() - start.getTime());
        //System.out.println("接口耗时:" + interval + "毫秒");
        return interval;
    }
}
 

 

package com.herley;
/**
 *
 * 服务端
 */

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.net.Socket;
import java.net.ServerSocket;
import java.util.Scanner;

public class Receive {
    public static void main(String[] args) {
        File target;    //接收到的文件保存的位置
        FileOutputStream save;  //将接收到的文件写入电脑
        FileInputStream in;     //读取穿送过来的数据文件
        ServerSocket server;    //服务器
        Socket socket;          //套接字

        //处理客户端的请求
        try {
            //接受前文件的准备
            System.out.print("请输入你将要保存文件的地址");
            System.out.println("(注意格式:文件路径+后缀名!)");
            Scanner scanner = new Scanner(System.in);
            String s = scanner.nextLine();
            target = new File(s);
            save = new FileOutputStream(target);

            server = new ServerSocket(2017);    //服务端口

            //等待客户端的呼叫
            System.out.println("正在等待客户端的呼叫........");
            socket = server.accept();   //阻塞
            in = (FileInputStream)socket.getInputStream();

            //接收数据
            byte[] b = new byte[64];
            int n = in.read(b);
            int start = (int)System.currentTimeMillis();
            while (n != -1) {
                save.write(b, 0, n);    //写入指定地方
                n = in.read(b);
            }
            int end = (int)System.currentTimeMillis();
            System.out.println("接收成功,耗时:" + (end-start)+"毫秒");
            socket.close();
            server.close();
            in.close();
            save.close();
        } catch (Exception e) {
            System.out.println(e);
        }
    }
}

相关文章