Java 基于tcp协议实现文件上传

下面我来详细讲解一下Java基于tcp协议实现文件上传的完整攻略。

一、前置知识

在实现文件上传之前，需要具备以下知识：

• Java Socket编程基础知识
• Java IO编程基础知识
• 文件上传的基本概念和流程

二、上传文件的流程

• 客户端连接服务器，向服务器发送需要上传的文件名、文件大小等信息
• 服务器接收到客户端发来的信息后，创建文件并打开输出流
• 客户端开始向服务器传输文件内容
• 服务器接收到客户端传来的文件内容，写入输出流中
• 当文件传输完毕后，关闭输入输出流和连接

三、实现步骤

1. 客户端实现步骤

1. 创建Socket连接服务器

java
Socket socket = new Socket(服务器IP地址, 服务器端口号);

1. 获取需要上传的文件

java
File file = new File("文件路径");

1. 创建输出流

java
OutputStream outputStream = socket.getOutputStream();

1. 发送文件信息（包括文件名、文件大小等）

java
// 获取文件名和文件大小
String fileName = file.getName();
long fileSize = file.length();
// 发送文件信息
DataOutputStream dataOutputStream = new DataOutputStream(outputStream);
dataOutputStream.writeUTF(fileName);
dataOutputStream.writeLong(fileSize);

1. 创建输入流

java
FileInputStream fileInputStream = new FileInputStream(file);

1. 缓冲区读取文件内容并发送到服务器

java
byte[] buffer = new byte[1024];
int len;
while ((len = fileInputStream.read(buffer)) > 0) {
outputStream.write(buffer, 0, len);
}

1. 关闭输入输出流和连接

java
fileInputStream.close();
outputStream.close();
socket.close();

2. 服务器端实现步骤

1. 创建ServerSocket并监听端口

java
ServerSocket serverSocket = new ServerSocket(服务器端口号);

1. 等待客户端连接

java
Socket socket = serverSocket.accept();

1. 创建输入流

java
InputStream inputStream = socket.getInputStream();

1. 接收文件信息

java
DataInputStream dataInputStream = new DataInputStream(inputStream);
String fileName = dataInputStream.readUTF();
long fileSize = dataInputStream.readLong();

1. 创建输出流

java
FileOutputStream fileOutputStream = new FileOutputStream("服务器保存文件路径" + fileName);

1. 接收文件内容并写入输出流

java
byte[] buffer = new byte[1024];
int len;
while ((len = inputStream.read(buffer)) > 0) {
fileOutputStream.write(buffer, 0, len);
}

1. 关闭输入输出流和连接

java
fileOutputStream.close();
inputStream.close();
socket.close();

四、示例代码

客户端示例代码

public class FileUploadClient {
    public static void main(String[] args) throws IOException {
        // 创建Socket连接服务器
        Socket socket = new Socket("10.10.10.10", 8888);

        // 获取需要上传的文件
        File file = new File("文件路径");

        // 创建输出流
        OutputStream outputStream = socket.getOutputStream();

        // 发送文件信息
        String fileName = file.getName();
        long fileSize = file.length();
        DataOutputStream dataOutputStream = new DataOutputStream(outputStream);
        dataOutputStream.writeUTF(fileName);
        dataOutputStream.writeLong(fileSize);

        // 创建输入流
        FileInputStream fileInputStream = new FileInputStream(file);

        // 缓冲区读取文件内容并发送到服务器
        byte[] buffer = new byte[1024];
        int len;
        while ((len = fileInputStream.read(buffer)) > 0) {
            outputStream.write(buffer, 0, len);
        }

        // 关闭输入输出流和连接
        fileInputStream.close();
        outputStream.close();
        socket.close();
    }
}

服务器端示例代码

public class FileUploadServer {
    public static void main(String[] args) throws IOException {
        // 创建ServerSocket并监听端口
        ServerSocket serverSocket = new ServerSocket(8888);

        // 等待客户端连接
        Socket socket = serverSocket.accept();

        // 创建输入流
        InputStream inputStream = socket.getInputStream();

        // 接收文件信息
        DataInputStream dataInputStream = new DataInputStream(inputStream);
        String fileName = dataInputStream.readUTF();
        long fileSize = dataInputStream.readLong();

        // 创建输出流
        FileOutputStream fileOutputStream = new FileOutputStream("服务器保存文件路径" + fileName);

        // 接收文件内容并写入输出流
        byte[] buffer = new byte[1024];
        int len;
        while ((len = inputStream.read(buffer)) > 0) {
            fileOutputStream.write(buffer, 0, len);
        }

        // 关闭输入输出流和连接
        fileOutputStream.close();
        inputStream.close();
        socket.close();
        serverSocket.close();
    }
}

以上就是Java基于tcp协议实现文件上传的完整攻略。