java文件分片上傳，斷點續傳

時間 2019-11-19

標籤 java 文件分片上傳斷點欄目 Java 简体版

原文原文鏈接

百度的webUploader的前端開源插件實現的大文件分片上傳功能javascript

前端部分php

前端頁面代碼以下，只須要修改本身的文件上傳地址接口地址：css

<!DOCTYPE html>

<head>

<title>

Web Uploader

</title>

</head>

<body>

<p>您能夠嘗試文件拖拽，使用QQ截屏工具，而後激活窗口後粘貼，或者點擊添加圖片按鈕</p>

<div class="webuploader-pick">點擊選擇圖片</div>

</div>

<p>或將照片拖到這裏，單次最多可選300張</p>

</div>

</div>

</div><div class="info">共0張（0B），已上傳0張</div>

</div>

var BASE_URL = '/webuploader';

</script>

</body>

</html>

前端js代碼 demo.js，須要修改插件初始化的參數，和文件上傳成功後的合併通知的地址。html

jQuery(function() {

var $ = jQuery, // just in case. Make sure it's not an other libaray.

$wrap = $('#uploader'),

// 圖片容器

$queue = $('<ul class="filelist"></ul>')

.appendTo( $wrap.find('.queueList') ),

// 狀態欄，包括進度和控制按鈕

$statusBar = $wrap.find('.statusBar'),

// 文件整體選擇信息。

$info = $statusBar.find('.info'),

// 上傳按鈕

$upload = $wrap.find('.uploadBtn'),

// 沒選擇文件以前的內容。

$placeHolder = $wrap.find('.placeholder'),

// 整體進度條

$progress = $statusBar.find('.progress').hide(),

// 添加的文件數量

fileCount = 0,

// 添加的文件總大小

fileSize = 0,

// 優化retina, 在retina下這個值是2

ratio = window.devicePixelRatio || 1,

// 縮略圖大小

thumbnailWidth = 110 * ratio,

thumbnailHeight = 110 * ratio,

// 可能有pedding, ready, uploading, confirm, done.

state = 'pedding',

// 全部文件的進度信息，key爲file id

percentages = {},

supportTransition = (function(){

var s = document.createElement('p').style,

r = 'transition' in s ||

'WebkitTransition' in s ||

'MozTransition' in s ||

'msTransition' in s ||

'OTransition' in s;

s = null;

return r;

})(),

uploader;

if ( !WebUploader.Uploader.support() ) {

alert( 'Web Uploader 不支持您的瀏覽器！若是你使用的是IE瀏覽器，請嘗試升級 flash 播放器');

throw new Error( 'WebUploader does not support the browser you are using.' );

}

// 實例化

uploader = WebUploader.create({

pick: {

id: '#filePicker',

label: '點擊選擇圖片'

dnd: '#uploader .queueList',

paste: document.body,

/* accept: {

title: 'Images',

extensions: 'gif,jpg,jpeg,bmp,png',

mimeTypes: 'image/*'

},*/

// swf文件路徑

swf: BASE_URL + '/js/Uploader.swf',

disableGlobalDnd: true,

//分片

chunked: true,

//每片大小 2M

chunkSize: 20097152,

//單片失敗後重試次數

chunkRetry: 10,

//上傳併發線程數

thread: 1,

// server: 'http://webuploader.duapp.com/server/fileupload.php',

server: 'http://localhost:8080/uploadFile',

fileNumLimit: 300,

fileSizeLimit: 2000* 1024 * 1024, // 2000 M

fileSingleSizeLimit: 1000 * 1024 * 1024 // 1000 M

});

// 添加「添加文件」的按鈕，

uploader.addButton({

id: '#filePicker2',

label: '繼續添加'

});

// 當有文件添加進來時執行，負責view的建立

function addFile( file ) {

var $li = $( '<li id="' + file.id + '">' +

'<p class="title">' + file.name + '</p>' +

'<p class="imgWrap"></p>'+

'<p class="progress"><span></span></p>' +

'</li>' ),

$btns = $('<div class="file-panel">' +

'<span class="cancel">刪除</span>' +

'<span class="rotateRight">向右旋轉</span>' +

'<span class="rotateLeft">向左旋轉</span></div>').appendTo( $li ),

$prgress = $li.find('p.progress span'),

$wrap = $li.find( 'p.imgWrap' ),

$info = $('<p class="error"></p>'),

showError = function( code ) {

switch( code ) {

case 'exceed_size':

text = '文件大小超出';

break;

case 'interrupt':

text = '上傳暫停';

break;

default:

text = '上傳失敗，請重試';

break;

}

$info.text( text ).appendTo( $li );

};

if ( file.getStatus() === 'invalid' ) {

showError( file.statusText );

} else {

// @todo lazyload

$wrap.text( '預覽中' );

uploader.makeThumb( file, function( error, src ) {

if ( error ) {

$wrap.text( '不能預覽' );

return;

}

var img = $('<img src="'+src+'">');

$wrap.empty().append( img );

}, thumbnailWidth, thumbnailHeight );

percentages[ file.id ] = [ file.size, 0 ];

file.rotation = 0;

}

file.on('statuschange', function( cur, prev ) {

if ( prev === 'progress' ) {

$prgress.hide().width(0);

} else if ( prev === 'queued' ) {

$li.off( 'mouseenter mouseleave' );

$btns.remove();

}

// 成功

if ( cur === 'error' || cur === 'invalid' ) {

console.log( file.statusText );

showError( file.statusText );

percentages[ file.id ][ 1 ] = 1;

} else if ( cur === 'interrupt' ) {

showError( 'interrupt' );

} else if ( cur === 'queued' ) {

percentages[ file.id ][ 1 ] = 0;

} else if ( cur === 'progress' ) {

$info.remove();

$prgress.css('display', 'block');

} else if ( cur === 'complete' ) {

$li.append( '<span class="success"></span>' );

alert("此文件已成功");

console.log("========="+file.size);

if(file.size>20097152){

$.post("http://localhost:8080/mergingChunks",{"id":file.id,"name":file.name,"size":file.size,"lastModifiedDate":file.lastModifiedDate},

function(data,status){

alert("Data: " + data + "\nStatus: " + status);

});

}

$li.removeClass( 'state-' + prev ).addClass( 'state-' + cur );

});

$li.on( 'mouseenter', function() {

$btns.stop().animate({height: 30});

});

$li.on( 'mouseleave', function() {

$btns.stop().animate({height: 0});

});

$btns.on( 'click', 'span', function() {

var index = $(this).index(),

deg;

switch ( index ) {

case 0:

uploader.removeFile( file );

return;

case 1:

file.rotation += 90;

break;

case 2:

file.rotation -= 90;

break;

}

if ( supportTransition ) {

deg = 'rotate(' + file.rotation + 'deg)';

$wrap.css({

'-webkit-transform': deg,

'-mos-transform': deg,

'-o-transform': deg,

'transform': deg

});

} else {

$wrap.css( 'filter', 'progid:DXImageTransform.Microsoft.BasicImage(rotation='+ (~~((file.rotation/90)%4 + 4)%4) +')');

}

});

$li.appendTo( $queue );

}

// 負責view的銷燬

function removeFile( file ) {

var $li = $('#'+file.id);

delete percentages[ file.id ];

updateTotalProgress();

$li.off().find('.file-panel').off().end().remove();

}

function updateTotalProgress() {

var loaded = 0,

total = 0,

spans = $progress.children(),

percent;

$.each( percentages, function( k, v ) {

total += v[ 0 ];

loaded += v[ 0 ] * v[ 1 ];

} );

percent = total ? loaded / total : 0;

spans.eq( 0 ).text( Math.round( percent * 100 ) + '%' );

spans.eq( 1 ).css( 'width', Math.round( percent * 100 ) + '%' );

updateStatus();

}

function updateStatus() {

var text = '', stats;

if ( state === 'ready' ) {

text = '選中' + fileCount + '張圖片，共' +

WebUploader.formatSize( fileSize ) + '。';

} else if ( state === 'confirm' ) {

stats = uploader.getStats();

if ( stats.uploadFailNum ) {

text = '已成功上傳' + stats.successNum+ '張照片至XX相冊，'+

stats.uploadFailNum + '張照片上傳失敗，<a class="retry" href="#">從新上傳</a>失敗圖片或<a class="ignore" href="#">忽略</a>'

}

} else {

stats = uploader.getStats();

text = '共' + fileCount + '張（' +

WebUploader.formatSize( fileSize ) +

'），已上傳' + stats.successNum + '張';

if ( stats.uploadFailNum ) {

text += '，失敗' + stats.uploadFailNum + '張';

}

$info.html( text );

}

function setState( val ) {

var file, stats;

if ( val === state ) {

return;

}

$upload.removeClass( 'state-' + state );

$upload.addClass( 'state-' + val );

state = val;

switch ( state ) {

case 'pedding':

$placeHolder.removeClass( 'element-invisible' );

$queue.parent().removeClass('filled');

$queue.hide();

$statusBar.addClass( 'element-invisible' );

uploader.refresh();

break;

case 'ready':

$placeHolder.addClass( 'element-invisible' );

$( '#filePicker2' ).removeClass( 'element-invisible');

$queue.parent().addClass('filled');

$queue.show();

$statusBar.removeClass('element-invisible');

uploader.refresh();

break;

case 'uploading':

$( '#filePicker2' ).addClass( 'element-invisible' );

$progress.show();

$upload.text( '暫停上傳' );

break;

case 'paused':

$progress.show();

$upload.text( '繼續上傳' );

break;

case 'confirm':

$progress.hide();

$upload.text( '開始上傳' ).addClass( 'disabled' );

stats = uploader.getStats();

if ( stats.successNum && !stats.uploadFailNum ) {

setState( 'finish' );

return;

}

break;

case 'finish':

stats = uploader.getStats();

if ( stats.successNum ) {

alert( '文件上傳已完成！' );//文件上傳後服務器合併文件

} else {

// 沒有成功的圖片，重設

state = 'done';

location.reload();

}

break;

}

updateStatus();

}

uploader.onUploadProgress = function( file, percentage ) {

var $li = $('#'+file.id),

$percent = $li.find('.progress span');

$percent.css( 'width', percentage * 100 + '%' );

percentages[ file.id ][ 1 ] = percentage;

updateTotalProgress();

};

uploader.onFileQueued = function( file ) {

fileCount++;

fileSize += file.size;

if ( fileCount === 1 ) {

$placeHolder.addClass( 'element-invisible' );

$statusBar.show();

}

addFile( file );

setState( 'ready' );

updateTotalProgress();

};

uploader.onFileDequeued = function( file ) {

fileCount--;

fileSize -= file.size;

if ( !fileCount ) {

setState( 'pedding' );

}

removeFile( file );

updateTotalProgress();

};

uploader.on( 'all', function( type ) {

var stats;

switch( type ) {

case 'uploadFinished':

setState( 'confirm' );

break;

case 'startUpload':

setState( 'uploading' );

break;

case 'stopUpload':

setState( 'paused' );

break;

}

});

uploader.onError = function( code ) {

alert( 'Eroor: ' + code );

};

$upload.on('click', function() {

if ( $(this).hasClass( 'disabled' ) ) {

return false;

}

if ( state === 'ready' ) {

uploader.upload();

} else if ( state === 'paused' ) {

uploader.upload();

} else if ( state === 'uploading' ) {

uploader.stop();

}

});

$info.on( 'click', '.retry', function() {

uploader.retry();

} );

$info.on( 'click', '.ignore', function() {

alert( 'todo' );

} );

$upload.addClass( 'state-' + state );

updateTotalProgress();

});

後臺Controller層代碼：前端

package com.webFileUploader.Controller;

import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.servlet.http.HttpSession;

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

import org.springframework.stereotype.Controller;

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

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

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

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

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

import org.springframework.web.multipart.MultipartFile;

import com.webFileUploader.exception.ErrorPremetersException;

import com.webFileUploader.service.FileManagerService;

import com.webFileUploader.utils.MutilFileUploadUtils;

import com.webFileUploader.vo.MutilFileInfo;

/**

* @version 1.0

* @author liangxh

* @since 2018-12-04

* @return 文件上傳

@Controller

public class uploadController {

@Autowired

private FileManagerService fileManagerService;

/**

* 文件上傳

* @param fileInfo:文件參數實體類

* @param file 附件字節碼文件

* @return 返回處理結果，請求頭200:成功,500:失敗

* @throws Exception

@RequestMapping(value = "/uploadFile", method = RequestMethod.POST)

@ResponseBody

public Map<String, String> MutiluploadFile(MutilFileInfo fileinfo,@RequestParam(required=false,value="file")MultipartFile file,HttpServletResponse response) throws Exception {

try {

if(file != null && !file.isEmpty()){

if(MutilFileUploadUtils.checkMutiFilePremeter(fileinfo)){ //切片上傳

fileManagerService.saveMutiBurstFiletoDir(fileinfo,file);

}else if(MutilFileUploadUtils.checkSingleFilePremeter(fileinfo)){//單文件總體上傳

fileManagerService.saveSingleFiletoDir(fileinfo,file);

}else {

throw new ErrorPremetersException("文件上傳參數不合法");

}

}else {

throw new ErrorPremetersException("文件上傳附件字節流內容爲空");

}

} catch (Exception e) {

e.printStackTrace();

response.setStatus(500);

}

return null;

}

/**

* 文件分片合併

* @return 返回處理結果，請求頭200:成功,500:失敗

* @throws Exception

@RequestMapping(value = "/mergingChunks", method = RequestMethod.POST)

@ResponseBody

public Map<String, String> MutilMergingChunksForFile(MutilFileInfo fileinfo,HttpServletResponse response) throws Exception {

try {

fileManagerService.MutilMergingChunks(fileinfo);

} catch (Exception e) {

e.printStackTrace();

response.setStatus(500);

}

return null;

}

/**

* 文件分片合併

* @return 返回處理結果，請求頭200:成功,500:失敗

* @throws Exception

@RequestMapping(value = "/")

public String uploaderView(HttpServletRequest request) throws Exception {

HttpSession session = request.getSession();

System.out.println(session);

return "redirect:/index.html";

}

後臺Service實現層；先在服務端硬盤上建立一個要上傳的文件相同的大文件，利用RandomAccessFile實現文件的隨機讀寫。從而實如今分片上傳時直接覆蓋空白文件中的一小段數據，從而避免分片保存爲臨時文件再合併的IO消耗，java

package com.webFileUploader.service.impl;

import java.io.File;

import java.util.ArrayList;

import java.util.Collections;

import java.util.List;

import java.util.concurrent.ConcurrentHashMap;

import java.util.concurrent.locks.ReentrantLock;

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

import org.springframework.stereotype.Service;

import org.springframework.web.multipart.MultipartFile;

import com.webFileUploader.service.FileManagerService;

import com.webFileUploader.utils.MutilFileUploadUtils;

import com.webFileUploader.utils.SHA256Util;

import com.webFileUploader.utils.SessionUtils;

import com.webFileUploader.vo.MutilFileInfo;

@Service

public class FileManagerServiceImpl implements FileManagerService {

@Value("${filePath.tempWorkBasePath}")

private String tempWorkPath;//分片臨時文件存放目錄

@Value("${filePath.saveFileBasePath}")

private String saveFilePath;//文件存放目錄

private ReentrantLock filetempLock = new ReentrantLock();

@Override

public void saveMutiBurstFiletoDir(MutilFileInfo fileinfo, MultipartFile file) throws Exception {

this.checkBaseDir(tempWorkPath);

File tempFile = this.GenerateDirPathForCurrFile(fileinfo,"chunks");

MutilFileUploadUtils.spaceFileWriter(file,tempFile,fileinfo);

}

@Override

public void saveSingleFiletoDir(MutilFileInfo fileinfo, MultipartFile file) throws Exception {

this.checkBaseDir(saveFilePath);

File targetFile = this.GenerateDirPathForCurrFile(fileinfo,"single");

MutilFileUploadUtils.saveFile2DirPath(file,targetFile);

}

@Override

synchronized public File GenerateDirPathForCurrFile(MutilFileInfo fileinfo,String flag) throws Exception {

String fileName = fileinfo.getName();

String lastModifiedDate = fileinfo.getLastModifiedDate();

long fileSize = fileinfo.getSize();

String type = fileinfo.getType();

String id = fileinfo.getId();

String extName = fileName.substring(fileName.lastIndexOf("."));

long timeStemp=System.currentTimeMillis();

if("single".equals(flag)) {

String fileNameSource = fileName+lastModifiedDate+fileSize+type+id+timeStemp;

String fileDirName = SHA256Util.getSHA256StrJava(fileNameSource)+extName;

File targetFile = new File(saveFilePath,fileDirName);

while(targetFile.exists()){

fileNameSource=fileNameSource+"1";

fileDirName = SHA256Util.getSHA256StrJava(fileNameSource)+extName;

targetFile = new File(fileDirName);

}

return targetFile;

}else if("chunks".equals(flag)) {

String fileNameSource = fileSize+"_"+fileName+id+lastModifiedDate;

String fileDirName = tempWorkPath+"/"+SHA256Util.getSHA256StrJava(fileNameSource)+extName+".temp";

File tempFile = new File(fileDirName);//禁用FileInfo.exists()類, 防止緩存致使併發問題

if(!(tempFile.exists()&&tempFile.isFile())){

filetempLock.lock();//上鎖

if(!(tempFile.exists()&&tempFile.isFile())) {

MutilFileUploadUtils.readySpaceFile(fileinfo,tempFile);

}

filetempLock.unlock();//釋放鎖

}

tempFile = new File(fileDirName);

return tempFile;

}else{

throw new Exception("目標文件生成失敗");

}

public void checkBaseDir(String baseDir) throws Exception {

File file = new File(baseDir);

if(!file.exists()&&!file.isDirectory()) {

file.mkdirs();

}

@Override//文件合併

public void MutilMergingChunks(MutilFileInfo fileinfo) throws Exception {

// TODO Auto-generated method stub

String fileName = fileinfo.getName();

String lastModifiedDate = fileinfo.getLastModifiedDate();

long fileSize = fileinfo.getSize();

String id = fileinfo.getId();

String extName = fileName.substring(fileName.lastIndexOf("."));

String fileNameSource = fileSize+"_"+fileName+id+lastModifiedDate;

String fileDirName = tempWorkPath+"/"+SHA256Util.getSHA256StrJava(fileNameSource)+extName+".temp";

File tempFile = new File(fileDirName);

if(tempFile.exists()&&tempFile.isFile()) {

checkBaseDir(saveFilePath);

String targetDirName = saveFilePath+"/"+SHA256Util.getSHA256StrJava(fileNameSource);

File targetFile=new File(targetDirName+extName);

while(targetFile.exists()&&targetFile.isFile()) {

targetDirName = targetDirName+"1";

targetFile=new File(targetDirName+extName);

}

System.out.println(targetFile.getAbsolutePath());

if(tempFile.renameTo(targetFile)) {

System.out.println("文件重命名成功!");

//數據庫操做

}else {

System.out.println("文件重命名失敗!");

throw new Exception("臨時文件重命名失敗");

}

實體類，爲了便與操做，這裏將全部的參數分裝成了一個實體類；jquery

package com.webFileUploader.vo;

import java.io.File;

import java.util.Arrays;

/**

* @version 1.0

* @author liangxh

* @since 2018-12-04

* @return 大文件上傳實體類

public class MutilFileInfo {

private String id; //文件id

private String name; //文件名稱

private String type;//文件類型

private String lastModifiedDate;//文件最後一次修改時間

private Long size;//文件總大小

//private Byte[] file;//副本字節流文件

private Integer chunk;//當前分片序號

private Integer chunks;//分片總數

private File fileChunk;//文件臨時分片

private Boolean saved=false;//分片是否保存成功默認值:false

public Boolean getSaved() {

return saved;

}

public void setSaved(Boolean saved) {

this.saved = saved;

}

public String getId() {

return id;

}

public File getFileChunk() {

return fileChunk;

}

public void setFileChunk(File fileChunk) {

this.fileChunk = fileChunk;

}

public void setId(String id) {

this.id = id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public String getType() {

return type;

}

public void setType(String type) {

this.type = type;

}

public String getLastModifiedDate() {

return lastModifiedDate;

}

public void setLastModifiedDate(String lastModifiedDate) {

this.lastModifiedDate = lastModifiedDate;

}

public Long getSize() {

return size;

}

public void setSize(Long size) {

this.size = size;

}

public Integer getChunk() {

return chunk;

}

public void setChunk(Integer chunk) {

this.chunk = chunk;

}

public Integer getChunks() {

return chunks;

}

public void setChunks(Integer chunks) {

this.chunks = chunks;

}

@Override

public String toString() {

return "MutilFileInfo [id=" + id + ", name=" + name + ", type=" + type + ", lastModifiedDate="

+ lastModifiedDate + ", size=" + size + ", chunk=" + chunk + ", chunks=" + chunks + ", fileChunk="

+ fileChunk + ", saved=" + saved + "]";

}

文件上傳工具類封裝;web

package com.webFileUploader.utils;

import java.io.BufferedInputStream;

import java.io.BufferedOutputStream;

import java.io.File;

import java.io.FileFilter;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.RandomAccessFile;

import java.util.ArrayList;

import java.util.Collections;

import java.util.Comparator;

import java.util.List;

import java.util.Map.Entry;

import java.util.Set;

import java.util.concurrent.ConcurrentHashMap;

import org.springframework.web.multipart.MultipartFile;

import com.webFileUploader.vo.MutilFileInfo;

/**

* @version 1.0

* @author liangxh

* @since 2018-12-04

* @return 文件上傳工具類

public class MutilFileUploadUtils {

/**

* 校驗文件切片上傳參數(字節流文件不能爲空)

* @param fileinfo:上傳參數實體類

* @return 判斷是否文件切片上傳，true：切片上傳，false:單文件總體上傳

* @throws Exception

public static Boolean checkMutiFilePremeter(MutilFileInfo fileinfo) {

if(fileinfo!=null) {

if(fileinfo.getChunks()!=null&&fileinfo.getChunk()!=null&&fileinfo.getChunks()>1&&fileinfo.getChunk()>=0&&fileinfo.getChunks()>fileinfo.getChunk()) {

return true;

}else {

return false;

}

}else {

return false;

}

/**

* 校驗文件單文件上傳參數(字節流文件不能爲空)

* @param fileinfo:上傳參數實體類

* @return 判斷參數上傳是否合法，true：符合單文件上傳參數格式，false:不符合單文件格式

* @throws Exception

public static Boolean checkSingleFilePremeter(MutilFileInfo fileinfo) {

if(fileinfo!=null) {

if(fileinfo.getChunks()==null&&fileinfo.getChunk()==null) {

return true;

}else {

return false;

}

}else {

return false;

}

/**

* 保存文件到指定目錄

* @param fileinfo:上傳參數實體類

* @throws Exception

public static void saveFile2DirPath(MultipartFile file,File targetFile) throws Exception {

if(targetFile.createNewFile()){

file.transferTo(targetFile);

}

/**

* 建立空目標文件

* @throws IOException

* @throws Exception

public static void readySpaceFile(MutilFileInfo fileinfo,File tempFile) throws IOException{

RandomAccessFile targetSpaceFile = new RandomAccessFile(tempFile, "rws");

targetSpaceFile.setLength(fileinfo.getSize());

System.out.println("建立文件："+fileinfo.getSize());

targetSpaceFile.close();

}

/**

* 向空文件寫入二進制數據

* @param targetFile:目標文件

* @param appenderFile:數據源文件

* @throws Exception

@SuppressWarnings("resource")

public static void spaceFileWriter(MultipartFile file, File tempFile,MutilFileInfo fileInfo) throws Exception {

long totalSpace = tempFile.getTotalSpace();

RandomAccessFile raf = new RandomAccessFile(tempFile, "rw");

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

Long startPointer = getFileWriterStartPointer(file, fileInfo);

raf.seek(startPointer);//初始化文件指針起始位置

byte[] bt = new byte[1024];

int n=0;

try {

while ((n=sourceBuffer.read(bt))!=-1){

raf.write(bt);

}

} catch (IOException e) {

e.printStackTrace();

}finally {

if(sourceBuffer!=null) {

sourceBuffer.close();

}

if(raf!=null) {

raf.close();

}

/**

* 計算指針開始位置

* @param fileInfo:分片實體類

* @param MultipartFile:文件流

* @throws IOException

* @throws Exception

synchronized public static Long getFileWriterStartPointer(MultipartFile file, MutilFileInfo fileInfo) throws Exception {

// TODO Auto-generated method stub

long chunkSize = file.getSize();

Integer currChunk = fileInfo.getChunk();

Integer allChunks = fileInfo.getChunks();

Long allSize = fileInfo.getSize();

if(currChunk<(allChunks-1)){

long starter = chunkSize*currChunk;

return starter;

}else if(currChunk==(allChunks-1)){

long starter = allSize-chunkSize;

return starter;

}else {

throw new Exception("分片參數異常");

}

DEMO下載地址：https://dwz.cn/fgXtRtnuspring

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。