java后端分片上传接口(java后端分片上传接口在哪)

  本篇文章为你整理了java后端分片上传接口(java后端分片上传接口在哪)的详细内容,包含有java后端分片上传接口有哪些 java后端分片上传接口在哪 java 分片上传 java分片上传文件 java后端分片上传接口,希望能帮助你了解 java后端分片上传接口。

   File dir = new File(strPath);

   File[] files = dir.listFiles(); // 该文件目录下文件全部放入数组

   if (files != null) {

   for (int i = 0; i files.length; i++) {

   String fileName = files[i].getName();

   if (files[i].isDirectory()) { // 判断是文件还是文件夹

   getFileList(files[i].getAbsolutePath()); // 获取文件绝对路径

   } else { // 判断文件名

   String strFileName = files[i].getAbsolutePath();

   // System.out.println("---" + strFileName);

   filelist.add(files[i]);

   return filelist;

   * 合并文件

   * @param from

   * @param to

   * @throws IOException

   public static void mergeFile(String from, String to) throws IOException {

   File t = new File(to);

   FileInputStream in = null;

   FileChannel inChannel = null;

   System.out.println("t "+t);

   FileOutputStream out = new FileOutputStream(t,true);

   FileChannel outChannel = out.getChannel();

   File f = new File(from);

   System.out.println("f "+f.isDirectory());

   // 获取目录下的每一个文件名,再将每个文件一次写入目标文件

   if (f.isDirectory()) {

   List File list = getAllFileAndSort(from);

   System.out.println("sortlist "+list);

   // 记录新文件最后一个数据的位置

   long start = 0;

   for (File file : list) {

   in = new FileInputStream(file);

   inChannel = in.getChannel();

   // 从inChannel中读取file.length()长度的数据,写入outChannel的start处

   outChannel.transferFrom(inChannel, start, file.length());

   start += file.length();

   in.close();

   inChannel.close();

   out.close();

   outChannel.close();

   * 所有文件排序

   * @param dirPath 文件根目录路径

   * @return

   public static List File getAllFileAndSort(String dirPath) {

   File dirFile = new File(dirPath);

   File[] listFiles = dirFile.listFiles();

   List File list = Arrays.asList(listFiles);

   Collections.sort(list, (o1, o2) - {

   String _str=o1.getName().split("\\.")[0];

   String _num=_str.split("_")[1];

   String _str2=o2.getName().split("\\.")[0];

   String _num2=_str2.split("_")[1];

   return Integer.parseInt(_num) - Integer.parseInt(_num2);

   return list;

   * 删除文件夹

   * 删除文件夹需要把包含的文件及文件夹先删除,才能成功

   * https://blog.csdn.net/m0_57640408/article/details/120774050

   * @param directory 文件夹名

   * @return 删除成功返回true,失败返回false

   public static boolean deleteDirectory(String directory) {

   // directory不以文件分隔符(/或\)结尾时,自动添加文件分隔符,不同系统下File.separator方法会自动添加相应的分隔符

   if (!directory.endsWith(File.separator)) {

   directory = directory + File.separator;

   File directoryFile = new File(directory);

   // 判断directory对应的文件是否存在,或者是否是一个文件夹

   if (!directoryFile.exists() !directoryFile.isDirectory()) {

   System.out.println("文件夹删除失败,文件夹不存在" + directory);

   return false;

   boolean flag = true;

   // 删除文件夹下的所有文件和文件夹

   File[] files = directoryFile.listFiles();

   for (int i = 0; i files.length; i++) { // 循环删除所有的子文件及子文件夹

   // 删除子文件

   if (files[i].isFile()) {

   flag = deleteFile(files[i].getAbsolutePath());

   if (!flag) {

   break;

   } else { // 删除子文件夹

   flag = deleteDirectory(files[i].getAbsolutePath());

   if (!flag) {

   break;

   if (!flag) {

   System.out.println("删除失败");

   return false;

   // 最后删除当前文件夹

   if (directoryFile.delete()) {

   System.out.println("删除成功:" + directory);

   return true;

   } else {

   System.out.println("删除失败:" + directory);

   return false;

   * 删除文件

   * @param fileName 文件名

   * @return 删除成功返回true,失败返回false

   public static boolean deleteFile(String fileName) {

   File file = new File(fileName);

   if (file.isFile() file.exists()) {

   file.delete();

   System.out.println("删除文件成功:" + fileName);

   return true;

   } else {

   System.out.println("删除文件失败:" + fileName);

   return false;

  }

 

 

  

  分片上传文件接口

  

package com.youmejava.chun.commoninterface;

 

  import com.youmejava.chun.util.FileUtil;

  import com.youmejava.chun.util.ResultVo;

  import com.youmejava.chun.util.StringUtil;

  import io.swagger.annotations.Api;

  import io.swagger.annotations.ApiImplicitParam;

  import io.swagger.annotations.ApiImplicitParams;

  import io.swagger.annotations.ApiOperation;

  import org.apache.shiro.authc.ExpiredCredentialsException;

  import org.springframework.beans.factory.annotation.Value;

  import org.springframework.stereotype.Service;

  import org.springframework.transaction.annotation.Transactional;

  import org.springframework.web.bind.annotation.*;

  import org.springframework.web.multipart.MultipartFile;

  import org.springframework.web.multipart.MultipartHttpServletRequest;

  import javax.servlet.http.HttpServletRequest;

  import java.io.*;

  import java.util.Arrays;

  import java.util.HashMap;

  import java.util.List;

  import java.util.Map;

  @RestController

  @RequestMapping("/api/apiSystem/upload")

  @Api(value = "文件上传", tags = "文件上传")

  public class UploadController {

   @Value("${filePath1}")

   private String filePath;

   @PostMapping("/register")

   @ApiOperation(value = "文件注册", notes = "文件注册")

   @ApiImplicitParams({@ApiImplicitParam(value = "哈希值", name = "hash", required = true, paramType = "body")})

   public ResultVo register(@RequestBody Map String, Object map) {

   System.out.println("hash: " + map.get("hash"));

   if (!StringUtil.isNotBlankAndNull(map.get("hash").toString())) {

   // return ResultVo.failure("哈希值不可为空");

   throw new ExpiredCredentialsException("哈希值不可为空!");

   String _filePath=filePath;

   if (!_filePath.endsWith("/")) {

   _filePath+="/";

  // String _pathStr = "C:\\Users\\JH-rent\\Desktop\\java启动文件\\test" + "\\" + map.get("hash");

   String _pathStr=_filePath+map.get("hash");

   //创建不同的文件夹目录

   File file = new File(_pathStr);

   //判断文件夹是否存在

   if (!file.exists()) {

   //如果文件夹不存在,则创建新的的文件夹

   file.mkdirs();

   File f = new File(_pathStr);

   // 检查目录是否已上传过文件,如果上传过,返回上传个数

   if (f.isDirectory()) {

   File dirFile = new File(_pathStr);

   File[] listFiles = dirFile.listFiles();

   List File list = Arrays.asList(listFiles);

   if (list == null list.size() 0) {

   Map String, Object map1=new HashMap ();

   map1.put("number",list.size());

   return ResultVo.success(map1);

  
@ApiOperation(value = "上传文件", notes = "上传文件")

   @ApiImplicitParams({@ApiImplicitParam(value = "哈希值", name = "hash", required = true, paramType = "body"), @ApiImplicitParam(value = "文件流", name = "file", required = true, paramType = "body"), @ApiImplicitParam(value = "文件名称", name = "fileName", required = true, paramType = "body"),})

   public ResultVo uploadFile(HttpServletRequest request) {

   MultipartHttpServletRequest params = ((MultipartHttpServletRequest) request);

   List MultipartFile files = ((MultipartHttpServletRequest) request).getFiles("file");

   String _fileName = params.getParameter("fileName");

   String _hash = params.getParameter("hash");

   if (!StringUtil.isNotBlankAndNull(_hash)) {

   throw new ExpiredCredentialsException("哈希值不可为空!");

   if (!StringUtil.isNotBlankAndNull(_fileName)) {

   throw new ExpiredCredentialsException("文件名称不可为空!");

  // System.out.println("_fileName: " + _fileName);

  // System.out.println("_hash: " + _hash);

  // System.out.println("files: " + files);

  // System.out.println(params.getParameter("file"));

  // String _pathStr = "C:\\Users\\JH-rent\\Desktop\\java启动文件\\test" + "\\" + _hash + "\\";

   String _filePath=filePath;

   if (!_filePath.endsWith("/")) {

   _filePath+="/";

   String _pathStr =_filePath+_hash+"/";

   FileOutputStream fileOut = null;

   //写入到文件(注意文件保存路径的后面一定要加上文件的名称)

   try {

   fileOut = new FileOutputStream(_pathStr + _fileName);

   BufferedOutputStream bos = new BufferedOutputStream(fileOut);

   BufferedInputStream bis = null;

   for (MultipartFile file : files) {

   // file.transferTo(new File(_pathStr + file.getOriginalFilename()));

   // System.out.println(file.getInputStream());

   bis = new BufferedInputStream(file.getInputStream());

   byte[] buf = new byte[4096];

   int length = bis.read(buf);

   //保存文件

   while (length != -1) {

   bos.write(buf, 0, length);

   length = bis.read(buf);

   bos.close();

   bis.close();

   return ResultVo.success();

   } catch (Exception e) {

   e.printStackTrace();

   return ResultVo.failure(e.getMessage());

   @GetMapping("/getMergeFile")

   @ApiOperation(value = "获取合并文件", notes = "获取合并文件")

   @ApiImplicitParams({@ApiImplicitParam(value = "哈希值", name = "hash", required = true, dataType = "String"), @ApiImplicitParam(value = "文件名称", name = "fileName", required = true, dataType = "String")})

   public ResultVo getMergeFile(@RequestParam(value = "hash") String hash, @RequestParam(value = "fileName") String fileName) {

  // String _pathStr = "C:\\Users\\JH-rent\\Desktop\\java启动文件\\test" + "\\" + hash + "\\";

  // String _pathStr1 = "C:\\Users\\JH-rent\\Desktop\\java启动文件\\test";

   String _filePath=filePath;

   if (!_filePath.endsWith("/")) {

   _filePath+="/";

   String _pathStr = _filePath + hash + "/";

   String _pathStr1 = _filePath;

   try {

  // if (!_pathStr1.endsWith("\\")) {

  // _pathStr1 += "\\";

   _pathStr1 += fileName;

   FileUtil.mergeFile(_pathStr, _pathStr1);

   //合并成功删除加密文件

   FileUtil.deleteDirectory(_pathStr);

   } catch (IOException e) {

   e.printStackTrace();

   Map String, Object map=new HashMap ();

   map.put("fileUrl",_pathStr1);

   return ResultVo.success(map);

  }

 

  前端分片链接:https:///wxchun/p/15892243.html

  以上就是java后端分片上传接口(java后端分片上传接口在哪)的详细内容,想要了解更多 java后端分片上传接口的内容,请持续关注盛行IT软件开发工作室。

郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

留言与评论(共有 条评论)
   
验证码: