java 大文件上传 断点续传 完整版实例 （Socket、IO流）

java两台服务器之间，大文件上传（续传），采用了Socket通信机制以及JavaIO流两个技术点，具体思路如下：

实现思路：

• 1、服：利用ServerSocket搭建服务器，开启相应端口，进行长连接操作
• 2、服：使用ServerSocket.accept()方法进行阻塞，接收客户端请求
• 3、服：每接收到一个Socket就建立一个新的线程来处理它
• 4、客：利用Socket进行远程连接，询问已上传进度
• 5、客：使用FileInputStream.skip(long length)从指定位置读取文件，向服务器发送文件流
• 6、服：接收客户端输入流，使用RandomAccessFile.seek(long length)随机读取，将游标移动到指定位置进行读写
• 7、客/服：一个循环输出，一个循环读取写入
• 8、示例：以下是具体代码，仅供参考

文件介绍：

• FileUpLoadServer.java（服务器接收文件类）
• FileUpLoadClient.java（客户端发送文件类）
• FinalVariables.java（自定义参数类）
• SocketServerListener.java（JavaWeb启动Socket操作类）
• web.xml（配置文件，跟随项目启动）

断点上传（服务端）

package com.cn.csdn.seesun2012.socket;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.math.RoundingMode;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.DecimalFormat;public class FileUpLoadServer extends ServerSocket {
    // 文件大小private static DecimalFormat df = null;// 退出标识private boolean quit = false;static {
    // 设置数字格式，保留一位有效小数df = new DecimalFormat("#0.0");df.setRoundingMode(RoundingMode.HALF_UP);df.setMinimumFractionDigits(1);df.setMaximumFractionDigits(1);}public FileUpLoadServer(int report) throws IOException {
    super(report);}/*** 使用线程处理每个客户端传输的文件* * @throws Exception*/public void load() throws Exception {
    System.out.println("【文件上传】服务器：" + this.getInetAddress() + " 正在运行中...");while (!quit) {
    // server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的Socket socket = this.accept();/*** 我们的服务端处理客户端的连接请求是同步进行的， 每次接收到来自客户端的连接请求后，* 都要先跟当前的客户端通信完之后才能再处理下一个连接请求。 这在并发比较多的情况下会严重影响程序的性能，* 为此，我们可以把它改为如下这种异步处理与客户端通信的方式*/// 收到请求，验证合法性String ip = socket.getInetAddress().toString();ip = ip.substring(1, ip.length());System.out.println("服务器接收到请求，正在开启验证对方合法性IP：" + ip + "！");// 每接收到一个Socket就建立一个新的线程来处理它new Thread(new Task(socket, ip)).start();}}/*** 处理客户端传输过来的文件线程类*/class Task implements Runnable {
    private Socket sk;	// 当前连接private String ips; // 当前连接IP址public Task(Socket socket, String ip) {
    this.sk = socket;this.ips = ip;}public void run() {
    Socket socket = sk;					// 重新定义，请不要移出run()方法外部，否则连接两会被重置String ip = ips;					// 重新定义，同上IP会变long serverLength = -1l;			// 定义：存放在服务器里的文件长度，默认没有为-1char pathChar = File.separatorChar;	// 获取：系统路径分隔符String panFu = "D:";				// 路径：存储文件盘符DataInputStream dis = null;			// 获取：客户端输出流DataOutputStream dos = null;		// 发送：向客户端输入流FileOutputStream fos = null;		// 读取：服务器本地文件流RandomAccessFile rantmpfile = null;	// 操作类：随机读取try {
    // 获取dis = new DataInputStream(socket.getInputStream());// 发送dos = new DataOutputStream(socket.getOutputStream());// 定义客户端传过来的文件名String fileName = "";while (fileName == "") {
    // 读取客户端传来的数据fileName = dis.readUTF();System.out.println("服务器获取客户端文件名称：" + fileName);File file = new File(panFu+ pathChar +"receive"+ pathChar +"" + ip + pathChar + fileName);if (file.exists()) {
    serverLength = file.length();dos.writeLong(serverLength);System.out.println("向客户端返回文件长度：" + serverLength + " B");} else {
    serverLength = 0l;dos.writeLong(serverLength);System.out.println("文件不存在");System.out.println("向客户端返回文件长度：" + serverLength + " B");}}System.out.println("服务器建立新线程处理客户端请求，对方IP：" + ip + "，传输正在进行中...");// 从客户端获取输入流dis = new DataInputStream(socket.getInputStream());// 文件名和长度long fileLength = dis.readLong();File directory = new File(panFu + pathChar + "receive"+ pathChar +"" + ip + pathChar);if (!directory.exists()) directory.mkdirs();int length = 0;byte[] bytes = new byte[1024];File file = new File(directory.getAbsolutePath() + pathChar + fileName);if (!file.exists()) {
    // 不存在fos = new FileOutputStream(file);// 开始接收文件while ((length = dis.read(bytes, 0, bytes.length)) != -1) {
    fos.write(bytes, 0, length);fos.flush();}} else {
    // 存储在服务器中的文件长度long fileSize = file.length(), pointSize = 0;// 判断是否已下载完成if (fileLength > fileSize) {
    // 断点下载pointSize = fileSize;} else {
    // 重新下载file.delete();file.createNewFile();}rantmpfile = new RandomAccessFile(file, "rw");/** java.io.InputStream.skip() 用法：跳过 n 个字节（丢弃） 如果 n* 为负，则不跳过任何字节。*/// dis.skip(pointSize); （已从客户端读取进度）/*** 资源，文件定位（游标、指针） 将ras的指针设置到8，则读写ras是从第9个字节读写到*/rantmpfile.seek(pointSize);while ((length = dis.read(bytes, 0, bytes.length)) != -1) rantmpfile.write(bytes, 0, length);}System.out.println("======== 文件接收成功 [File Name：" + fileName + "] [ClientIP:" + ip + "] [Size：" + getFormatFileSize(file.length()) + "] ========");} catch (Exception e) {
    e.printStackTrace();} finally {
    try {
    if (fos != null) fos.close();if (dis != null) dis.close();if (rantmpfile != null) rantmpfile.close();socket.close();} catch (Exception e) {
    e.printStackTrace();System.out.println("Socket关闭失败！");}/*** 文件传输完毕：执行后续操作（略）*///TODO 录入数据库，记录文件信息：文件ID、文件名称、文件路径、文件MD5值//FileInfo fi= new FileInfo()//fi.setId(UUID.randomUUID().toString().replace("-", ""));//fi.setFileName("断点续传：xxxxxxx号文件.zip");//fi.setFilePath("D:\receive\296.245.235.254\断点续传：xxxxxxx号文件.zip");//fi.setMD5Val("578F48BF49EA461A9FDDFA3E68A72EF8");//}}}/*** 格式化文件大小* * @param length* @return*/public String getFormatFileSize(long length) {
    double size = ((double) length) / (1 << 30);if (size >= 1) return df.format(size) + "GB";size = ((double) length) / (1 << 20);if (size >= 1) return df.format(size) + "MB";size = ((double) length) / (1 << 10);if (size >= 1) return df.format(size) + "KB";return length + "B";}/*** 退出*/public void quit() {
    this.quit = true;try {
    this.close();} catch (IOException e) {
    System.out.println("服务器关闭发生异常，原因未知");}}}

断点上传（客户端）

package com.cn.csdn.seesun2012.socket;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Timer;
import java.util.TimerTask;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;/*** Client端<br><br>* 功能说明：文件上传（断点）传输* * @author CSDN:seesun2012* @CreateDate 2017年08月18日 * @Override 2017年11月07日* @version 1.1*/
public class FileUpLoadClient extends Socket{
    private Logger logger = LoggerFactory.getLogger("oaLogger");private Socket client;				// Socket-客户端private static long status = 0;		// 进度条private boolean quit = false;		//退出/*** 构造器* * @param ip 服务端IP地址* @param report 服务端开放的端口 * @throws UnknownHostException* @throws IOException*/public FileUpLoadClient(String ip, Integer report) throws UnknownHostException, IOException {
    super(ip, report);this.client = this;if (client.getLocalPort()>0) {
    System.out.println("Cliect[port:" + client.getLocalPort() + "] 成功连接服务端");}else{
    System.out.println("服务器连接失败");}}public int sendFile(String filePath) {
    DataOutputStream dos = null;	// 上传服务器：输出流DataInputStream dis = null;		// 获取服务器：输入流Long serverLength = -1l;		// 存储在服务器的文件长度，默认-1FileInputStream fis = null;		// 读取文件：输入流// 获取：上传文件File file = new File(filePath);// ==================== 节点：文件是否存在 ==================== if (file.exists()) {
    // 发送：文件名称、文件长度try {
    dos = new DataOutputStream(client.getOutputStream());} catch (IOException e2) {
    logger.error("Socket客户端：1.读取输出流发生错误");e2.printStackTrace();}try {
    dos.writeUTF(file.getName());dos.flush();dos.writeLong(file.length());dos.flush();} catch (IOException e2) {
    logger.error("Socket客户端：2.向服务器发送文件名、长度发生错误");e2.printStackTrace();}// 获取：已上传文件长度try {
    dis = new DataInputStream(client.getInputStream());} catch (IOException e2) {
    logger.error("Socket客户端：3.向服务器发送文件名、长度发生错误");e2.printStackTrace();}while(serverLength==-1){
    try {
    serverLength = dis.readLong();} catch (IOException e) {
    logger.error("Socket客户端：4.读取服务端长度发送错误");e.printStackTrace();}}// 读取：需要上传的文件try {
    fis = new FileInputStream(file);} catch (FileNotFoundException e2) {
    logger.error("Socket客户端：5.读取本地需要上传的文件失败，请确认文件是否存在");e2.printStackTrace();}// 发送：向服务器传输输入流try {
    dos = new DataOutputStream(client.getOutputStream());} catch (IOException e2) {
    logger.error("Socket客户端：6.向服务器传输输入流发生错误");e2.printStackTrace();}System.out.println("======== 开始传输文件 ========");byte[] bytes = new byte[1024];int length = 1024;long progress = serverLength;// 设置游标：文件读取的位置if (serverLength==-1l) serverLength = 0l;try {
    fis.skip(serverLength);} catch (IOException e1) {
    logger.error("Socket客户端：7.设置游标位置发生错误，请确认文件流是否被篡改");e1.printStackTrace();}try {
    while (((length = fis.read(bytes, 0, bytes.length)) != -1) && quit != true) {
    dos.write(bytes, 0, length);dos.flush();progress += length;status =  (100 * progress / file.length());}} catch (IOException e) {
    logger.error("Socket客户端：8.设置游标位置发生错误，请确认文件流是否被篡改");e.printStackTrace();}finally {
    if (fis != null)try {
    fis.close();} catch (IOException e1) {
    logger.error("Socket客户端：9.关闭读取的输入流异常");e1.printStackTrace();}if (dos != null)try {
    dos.close();} catch (IOException e1) {
    logger.error("Socket客户端：10.关闭发送的输出流异常");e1.printStackTrace();}try {
    client.close();} catch (IOException e) {
    logger.error("Socket客户端：11.关闭客户端异常");e.printStackTrace();}}System.out.println("======== 文件传输成功 ========");}else{
    logger.error("Socket客户端：0.文件不存在");return -1;}return 1;}	/*** 进度条*/public void statusInfo(){
    Timer time = new Timer();time.schedule(new TimerTask() {
    long num = 0;@Overridepublic void run() {
    if (status>num) {
    System.out.println("当前进度为："+status+"%");num = status;}if (status==101) System.gc();}}, 0, 100);}/*** 退出*/public void quit() {
    this.quit  = true;try {
    this.close();} catch (IOException e) {
    System.out.println("服务器关闭发生异常，原因未知");}}}

断点上传（参数设置）

package com.cn.csdn.seesun2012.socket;public interface FinalVariables {
    // 服务端IPpublic final static String SERVER_IP = "192.168.1.10010"; // 服务端端口public final static int SERVER_PORT = 10086; // 开启配置public final static String IS_START_SERVER = "instart"; }

断点上传（JavaWeb启动服务端）

package com.cn.csdn.seesun2012.socket;import java.util.Timer;
import java.util.TimerTask;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;/*** Server端<br><br>* 功能说明：服务端监听开启Servlet* * @author CSDN:seesun2012* @CreateDate 2017年08月18日 * @Override 2017年11月07日* @Override 2017年11月14日* @version 1.3*/
public class SocketServerListener extends HttpServlet{
    private static final long serialVersionUID = -999999999999999999L;// 初始化启动Socket服务@Overridepublic void init() throws ServletException {
    super.init();for(int i = 0; i < 3; i++){
    if ("instart".equals(FinalVariables.IS_START_SERVER )) {
    open();break;}}}public void open(){
    Timer timer = new Timer();timer.schedule(new TimerTask() {
    @SuppressWarnings("resource")@Overridepublic void run() {
    try {
    FileUpLoadServer fileUpLoadServer = new FileUpLoadServer(FinalVariables.SERVER_PORT);fileUpLoadServer.load();} catch (Exception e) {
    e.printStackTrace();}}}, 3000);}
}

web.xml配置（跟随项目启动）

<?xml version="1.0" encoding="UTF-8"?><web-app><welcome-file-list><welcome-file>index.html</welcome-file><welcome-file>index.jsp</welcome-file></welcome-file-list><servlet><servlet-name>SocketServerListener</servlet-name><servlet-class>com.cn.csdn.seesun2012.socket.SocketServerListener</servlet-class><load-on-startup>10</load-on-startup></servlet><display-name>seesun2012</display-name></web-app>

注：以上内容仅提供参考和交流，请勿用于商业用途，如有侵权联系本人删除！

持续更新中…

如有对思路不清晰或有更好的解决思路，欢迎与本人交流，QQ群：273557553
你遇到的问题是小编创作灵感的来源！