大文件分片上传的后台方法（Java）

1 数据表结构
2 Java后台
- 2.1 工具类
- 2.2 实现查询文件状态
- 2.3 实现首次上传文件分片
- 2.4 实现继续上传文件分片
- 2.5 实现秒传
本文全部更新已完成

本文仅为后端Java，如需前端Vue，请移步我的另一篇文章：支持IE11的文件分片逐一上传的方法（vue）

1 数据表结构

file表

字段名	数据类型	主键	非空	自增	注释
md	varchar	+	+	-	文件唯一标识码
allNum	int	-	-	-	文件全部分片数量
successNum	int	-	-	-	已经上传成功的分片数量
type	int	-	-	-	文件状态
path	varcher	-	-	-	文件在服务器磁盘路径

file_info表

字段名	数据类型	主键	非空	自增	注释
id	int	+	+	+	varchar
md	varcher	-	-	-	文件唯一标识码
fileName	varchar	-	-	-	文件真是名字
detail	varchar	-	-	-	详细介绍
date	varchar	-	-	-	文件上传时
fileTypeId	int	-	-	-	文件类型
parentId	int	-	-	-	文件类型父级ID

2 Java后台

Bean层

@Data
@Accessors(chain = true)
public class FileInfo{
	private Integer id;
	private String md;
	private Integer allNum;
	private Integer successNum;
	private String fileName;
	private String detail;
	private String path;
	private String size;
	private String date;
	private Integer fileTypeId;
	private Integer parentId;
}

2.1 工具类

工具类Tools，下边两个方法在这个工具类中

@Component("Tools")
public class Tools{

}

将前端传来的文件分片存储到服务器的磁盘中，磁盘的IO操作，没什么需要注释的吧

public boolean saveFileChunk(String name,String chunkPath,MultipartFile file,Integer num){
	OutputStream out = null;
	InputStream in = null;
	try{
		in = file.getInputStream();
	}catch(Exception e){
		e.printStackTrace;
	}
	try{
		byte[] bs = new byte[1024];
		int len;
		File fileChunk = new File(chunkPath)
		if(!fileChunk.exists()){
			fileChunk.mkdirs();
		}
		out = new FileOutputStream(chunkPath + "\" + name + "_" + num + ".temporary");
		while((len=in.read(bs)) != -1){
			out.write(bs,0,len);
		}
	}catch(Exception e){
		e.printStackTrace();
		return false;
	}finally{
		try{
			out.close();
			in.close();
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	return true;
}

将指定文件夹、文件名的分片文件合并为完整文件，同时删除分片文件

public Boolean mergeFileChunk(String fileName,String path,Integer num){
	OutputStream = null;
	InputStream = null;
	File fileChunk = null;
	try{
		new File(path + "\" + fileName).delete();
		out = new BufferedOutputStream(new FileOutputStream(path + "\" + fileName,true));
		for(int i = 0 ; i < num ; i ++){
			fileChunk = new file(path + "\" + fileName + "_" + i + ".temporary");
			if(!fileChunk.exists()){
				continue;
			}
			in = new BufferedInputStream(new FileInputStream(fileChunk));
			byts[] chunk = new byte[1024];
			int theEnd = -1;
			while((theEnd = in.read(chunk)) != -1){
				out.write(chunk,0,theEnd);
			}
			in.close();
			fileChunk.delete();
		}
	}catch(Exception e){
		e.printStackTrace();
		return false;
	}final{
		try{
			out.close();
		}catch(Excepting e){
			e.printStackTrace();
		}
	}
	return true;
}

ServiceImpl层的一个公用方法

private FileInfo getFileInfo(HttpServletRequest info){
	fileInfo fileInfo = new FileInfo();
	fileInfo.setMd(info.getParameter("md"))
			.setAllNum(Integer.valueOf(info.getParameter("allNum")))
			.setSuccessNum(Integer.valueOf(info.getParameter("successNum")))
			.setType(Integer.valueOf(info.getParameter("type")))
			.setFileName(info.getParameter("fileIName"))
			.setDetail(info.getParameter("detail"))
			.setPath(info.getParameter("path"));
}

2.2 实现查询文件状态

很简单的查询，可以忽略不看
Controller层

public Result findFileInfo(@RequestBody FileInfo fileInfo){
	return new Result(fileService.findFileInfo(fileInfo))
}

ServiceImpl层

public List findFileInfo(FileInfo fileInfo){
	return new Result(fileService.findFileInfo(fileInfo))
}

Mapper层

@Select("select a.md md,a.allNum allNum,a.successNum successNum,a.type type,a.path path,b.id id,b.fileName fileName,b.detail detail from file a left join file_info b on a.md=b.md where a.md=#{md}")
List findFileInfo(FileInfo fileInfo);

2.3 实现首次上传文件分片

Controller层

@PostMapping("/uploadFileFirst")
public Result uploadFileFirst(HttpServletRequest httpServletRequest,
									@@RequestParam("file") MultopartFile multopartFile){
	return new Result(fileService.uploadFileFirst(httpServletRequest,multopartFile))
}

ServiceImpl层

public Result uploadFileFirst(HttpServletRequest info,MultopartFile file){
	FileInfo fileInfo = getFileInfo(info);	//2.1工具类中有这个方法
	//这里是获取文件类型的数据，为了可以分类型查找文件，不是文件上传的必要参数
	fileInfo.setParentId(Integer.valueOf(info.getParameter("parentId")))
			.setFileTypeId(Integer.valueOf(info.getParameter("fileTypeId")));
	String[] paths = new simpleDateFormat("yy.MM.dd-HH:mm:ss".format(new Date())).split("-")[0].split("\.");
	//这里需要自定义文件存储根目录位置
	fileInfo.setPath("........." + "\" + path[0] + "\" + path[1] + "\" +path[2] + "\" + fileInfo.getMd())
			.setDate(newsimpleDateFormat("yy.MM.dd-HH:mm:ss".format(new Date())))
			.setType(0);
	fileMapper.insertFileInfo(fileInfo);
	fileMapper.insertNewFileInfo(fileInfo);
	tools.saveFileChunk(fileInfo.getMd(),fileInfo.getPath(),file,fileInfo.getSuccessNum());
	fileMapper.updateFileSuccessNum(fileInfo.getMd(),fileInfo.getSuccessNum()+1);
	fileInfo.setSuccessNum(fileInfo.getSuccessNum+1).setType(0);
	if(fileInfo.getAllNum() == fileInfo.getSuccessNum()&&fileInfo.getAllNum == 1){
		fileInfo.setType(1);
		fileMapper.updateFileType(fileInfo.getMd(),fileInfo.getType());
		tools.mergeFileChunk(fileInfo.getMd(),fileInfo.getPath(),fileInfo.getAllNum());
	}
	return fileInfo;
}

Mapper层

@Insert("insert into file_info values(null,#{md}.#{fileName},#{detail},#{date},#{fileTypeId},#{parentId})")
void insertFileInfo(FileInfo fileInfo);

@Insert("insert into file values(#{md}.#{allNum},#{successNum},#{type},#{path})")
void insertNewFileInfo(FileInfo fileInfo);

@Update("update file set successNum=#{successNum} where md=#{md}")
void updateFileSuccessNum(@Param("md")String md,@Param("successNum")Integer successNum);

@Update("update file set type=#{type} where md=#{md}")
void updateFileType(@Param("md")String md,@Param("type")Integer type);

2.4 实现继续上传文件分片

Controller层

@PostMapping("/uploadFileContinue")
public Result uploadFileContinue(HttpServletRequest httpServletRequest,
									@@RequestParam("file") MultopartFile multopartFile){
	return new Result(fileService.uploadFileContinue(httpServletRequest,multopartFile))
}

ServiceImpl层

public Result uploadFileContinue(HttpServletRequest info,MultopartFile file){
	FileInfo fileInfo = getFileInfo(info);	//2.1工具类中有这个方法
	tools.saveFileChunk(fileInfo.getMd(),fileInfo.getPath(),file,fileInfo.getSuccessNum());
	fileMapper.updateFileSuccessNum(fileInfo.getMd(),fileInfo.getSuccessNum()+1);
	fileInfo.setSuccessNum(fileInfo.getSuccessNum+1);
	if(fileInfo.getAllNum() == fileInfo.getSuccessNum()&&fileInfo.getAllNum == 1){
		fileInfo.setType(1);
		fileMapper.updateFileType(fileInfo.getMd(),fileInfo.getType());
		tools.mergeFileChunk(fileInfo.getMd(),fileInfo.getPath(),fileInfo.getAllNum());
	}
	return fileInfo;
}

Mapper层

@Update("update file set successNum=#{successNum} where md=#{md}")
void updateFileSuccessNum(@Param("md")String md,@Param("successNum")Integer successNum);

@Update("update file set type=#{type} where md=#{md}")
void updateFileType(@Param("md")String md,@Param("type")Integer type);

2.5 实现秒传

Controller层

@PostMapping("/uploadFileFast")
public Result uploadFileFast(@RequestBody FileInfo fileInfo){
	return new Result(fileService.uploadFileFast(fileInfo))
}

ServiceImpl层

public Result uploadFileFast(FileInfo fileInfo){
	fileInfo.steType(1).setSuccessNum(fileInfo.getAllNum()).setDate(new simpleDateFormat("yy.MM.dd-HH:mm:ss".format(new Date())));
	fileMapper.insertFileInfo(fileInfo);
	return fileInfo;
}

Mapper层

@Insert("insert into file_info values(null,#{md}.#{fileName},#{detail},#{date},#{fileTypeId},#{parentId})")
void insertFileInfo(FileInfo fileInfo);

本文全部更新已完成

大文件分片上传的后台方法（Java）

Java相关栏目本月热门文章