Java怎么利用Socket和IO流实现文件的上传与下载
IObit Uninstaller 是一款专为 Win 平台设计的软件卸载工具,卸载干净彻底。清理链路的完整性会更好一些,做应用卸载、残留处理和空间整理时,通常能少走很多手动排查步骤。
核心技术1、TCP2、Socket3、FileInputStream与FileOutputStream4、DataInputStream与DataOutputStream5、多线程Configpackagecom.io14;/***本文作者:谷哥的小弟*博客地址:http://blog.csdn.net/lfdfhl*/publicclassConfig{publicstaticfinalStringip="localhost";publicstaticfinalintport=10088;}Client
核心技术
1、TCP
2、Socket
3、FileInputStream与FileOutputStream
4、DataInputStream与DataOutputStream
5、多线程
Config
package com.io14;
/**
* 本文作者:谷哥的小弟
* 博客地址:http://blog.csdn.net/lfdfhl
*/
public class Config {
public static final String ip = "localhost";
public static final int port = 10088;
}
Client
package com.io14;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
/**
* 本文作者:谷哥的小弟
* 博客地址:http://blog.csdn.net/lfdfhl
*/
public class Client {
public static void main(String arg[]) {
testDownload();
}
public static void testUpload() {
String filePath = "D:" + File.separator + "beauty.jpg";
Client client = new Client();
client.uploadFile(filePath);
}
public static void testDownload() {
Client client = new Client();
client.downloadFile();
}
public void uploadFile(String filePath) {
try {
// 创建待上传文件对象
File file = new File(filePath);
String fileName = file.getName();
long fileLength = file.length();
System.out.println("客户端待上传文件:" + fileName + ",其大小为:" + fileLength);
// 创建FileInputStream
FileInputStream fileInputStream = new FileInputStream(filePath);
// 创建Socket对象
Socket socket = new Socket(Config.ip, Config.port);
// 从Socket获取OutputStream
OutputStream outputStream = socket.getOutputStream();
// 创建DataOutputStream
DataOutputStream dataOutputStream = new DataOutputStream(outputStream);
// 利用DataOutputStream写出文件名和文件大小
dataOutputStream.writeUTF(fileName);
dataOutputStream.writeLong(fileLength);
dataOutputStream.flush();
// IO流读写操作
byte[] buf = new byte[1024 * 1];
int len = 0;
while ((len = fileInputStream.read(buf)) != -1) {
dataOutputStream.write(buf, 0, len);
}
// 释放资源
dataOutputStream.flush();
fileInputStream.close();
socket.close();
} catch (Exception e) {
System.out.println(e.toString());
}
}
public void downloadFile() {
try {
// 创建Socket对象
Socket socket = new Socket(Config.ip, Config.port);
// 从Socket获取InputStream
InputStream inputStream = socket.getInputStream();
// 创建DataInputStream对象
DataInputStream dataInputStream = new DataInputStream(inputStream);
// 获取下载文件的文件名和文件大小
String fileName = dataInputStream.readUTF();
long fileLength = dataInputStream.readLong();
System.out.println("客户端下载文件:" + fileName + ",其大小为:" + fileLength);
// 组拼文件保存路径
String fileDir = "D:";
String filePath = fileDir + File.separator + fileName;
// 创建FileOutputStream对象
FileOutputStream fileOutputStream = new FileOutputStream(filePath);
// IO流读写操作
byte[] buf = new byte[1024 * 1];
int len = 0;
while ((len = dataInputStream.read(buf)) != -1) {
fileOutputStream.write(buf, 0, len);
}
// 释放资源
fileOutputStream.flush();
fileOutputStream.close();
dataInputStream.close();
socket.close();
} catch (Exception e) {
System.out.println(e.toString());
}
}
}
Server
package com.io14;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 本文作者:谷哥的小弟
* 博客地址:http://blog.csdn.net/lfdfhl
*/
public class Server {
public static void main(String arg[]) {
testDownload();
}
public static void testUpload() {
Server server = new Server();
server.handleUploadFile();
}
public static void testDownload() {
Server server = new Server();
server.handleDownloadFile();
}
public void handleUploadFile() {
try {
// 创建ServerSocket对象
ServerSocket serverSocket = new ServerSocket(Config.port);
while (true) {
// 接收客户端连接请求
Socket socket = serverSocket.accept();
// 开启子线程处理文件上传
UploadRunnableImpl uploadRunnableImpl = new UploadRunnableImpl(socket);
Thread thread = new Thread(uploadRunnableImpl);
thread.start();
}
} catch (Exception e) {
System.out.println(e.toString());
}
}
public void handleDownloadFile() {
try {
// 创建ServerSocket对象
ServerSocket serverSocket = new ServerSocket(Config.port);
while (true) {
// 接收客户端连接请求
Socket socket = serverSocket.accept();
// 开启子线程处理文件下载
DownloadRunnableImpl downloadRunnableImpl = new DownloadRunnableImpl(socket);
Thread thread = new Thread(downloadRunnableImpl);
thread.start();
}
} catch (Exception e) {
System.out.println(e.toString());
}
}
}
UploadRunnableImpl
package com.io14;
import java.io.DataInputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.net.Socket;
/**
* 本文作者:谷哥的小弟
* 博客地址:http://blog.csdn.net/lfdfhl
*/
public class UploadRunnableImpl implements Runnable {
private Socket socket;
public UploadRunnableImpl(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try {
// 从Socket获取InputStream
InputStream inputStream = socket.getInputStream();
// 创建DataInputStream对象
DataInputStream dataInputStream = new DataInputStream(inputStream);
// 获取上传文件的文件名和文件大小
String fileName = dataInputStream.readUTF();
long fileLength = dataInputStream.readLong();
System.out.println("服务端接收上传文件:"+fileName+",其大小为:"+fileLength);
// 组拼文件保存路径
String fileDir = "E:";
String filePath= fileDir + File.separator+fileName;
// 创建FileOutputStream对象
FileOutputStream fileOutputStream = new FileOutputStream(filePath);
// IO流读写操作
byte[] buf = new byte[1024*1];
int len = 0;
while ((len = dataInputStream.read(buf)) != -1) {
fileOutputStream.write(buf, 0, len);
}
// 释放资源
fileOutputStream.flush();
fileOutputStream.close();
dataInputStream.close();
socket.close();
} catch (Exception e) {
System.out.println(e.toString());
}
}
}
DownloadRunnableImpl
package com.io14;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.OutputStream;
import java.net.Socket;
/**
* 本文作者:谷哥的小弟
* 博客地址:http://blog.csdn.net/lfdfhl
*/
public class DownloadRunnableImpl implements Runnable{
private Socket socket;
public DownloadRunnableImpl(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try {
// 创建待下载文件对象
String filePath = "E:"+File.separator+"beauty.jpg";
File file = new File(filePath);
String fileName = file.getName();
long fileLength = file.length();
System.out.println("服务端待下载文件:" + fileName + ",其大小为:" + fileLength);
// 创建FileInputStream
FileInputStream fileInputStream = new FileInputStream(filePath);
// 从Socket获取OutputStream
OutputStream outputStream = socket.getOutputStream();
// 创建DataOutputStream
DataOutputStream dataOutputStream = new DataOutputStream(outputStream);
// 利用DataOutputStream写出文件名和文件大小
dataOutputStream.writeUTF(fileName);
dataOutputStream.writeLong(fileLength);
dataOutputStream.flush();
// IO流读写操作
byte[] buf = new byte[1024 * 1];
int len = 0;
while ((len = fileInputStream.read(buf)) != -1) {
dataOutputStream.write(buf, 0, len);
}
// 释放资源
dataOutputStream.flush();
fileInputStream.close();
socket.close();
} catch (Exception e) {
System.out.println(e.toString());
}
}
}
Photoshop 2026 是 Adobe 推出的专业图像处理与视觉设计软件,支持 Windows、macOS 和 iPad 等平台,广泛应用于摄影修图、电商设计、平面海报、数字绘画及视觉合成等创作场景。
Blender 是一款免费开源、跨平台的专业 3D 创作软件,集建模、动画、渲染、视频编辑与视觉合成等功能于一体,广泛应用于影视动画、游戏设计和建筑可视化等领域。软件支持 Cycles 物理渲染器与 Eevee 实时渲染引擎,并提供多边形建模、骨骼绑定、物理模拟等专业工具。Blender 兼容 Windows、macOS 和 Linux 系统,安装包轻巧、运行流畅,依托活跃的全球开发者社区持续更新,是从初学者到专业创作者都值得选择的正版 3D 创作工具。
Photoshop 2026 是 Adobe 推出的专业图像处理与视觉设计软件,支持 Windows、macOS 和 iPad 等平台,广泛应用于摄影修图、电商设计、平面海报、数字绘画及视觉合成等创作场景。
Blender 是一款免费开源、跨平台的专业 3D 创作软件,集建模、动画、渲染、视频编辑与视觉合成等功能于一体,广泛应用于影视动画、游戏设计和建筑可视化等领域。软件支持 Cycles 物理渲染器与 Eevee 实时渲染引擎,并提供多边形建模、骨骼绑定、物理模拟等专业工具。Blender 兼容 Windows、macOS 和 Linux 系统,安装包轻巧、运行流畅,依托活跃的全球开发者社区持续更新,是从初学者到专业创作者都值得选择的正版 3D 创作工具。















