php 使用resumablejs实现文件的分块上传与断点续传功能-php开发知识文章-编程文章分享

本文介绍了php 使用resumablejs实现文件的分块上传与断点续传功能。分享给大家供大家参考，欢迎大家的学习。

resumablejs

Resumable.js 是一个 JavaScript 库，通过 HTML5 文件 API 提供，稳定和可恢复的批量上传功能。

在上传大文件的时候通过每个文件分割成小块，每块在上传失败的时候，上传会不断重试直到程序完成。

这允许上传到本地或服务器的网络连接丢失后能够自动恢复上传。

php 使用resumablejs实现文件的分块上传与断点续传功能

html页面

<!DOCTYPE html>
<html lang="en">
<div>
    <a href="#" rel="external nofollow" id="browseButton">选择文件</a>
    <div>
        <div>
            <input id="btnCancel" type="button" onClick='r.pause()' 
                   value="取消上传" style="margin-left: 2px; 
                   height: 22px; font-size: 8pt;"/>
            <br/>
        </div>
        <script src="resumable.js"></script>
        <script>
            var r = new Resumable({
                target: 'upload.php',
                chunkSize: 2 * 1024 * 1024,
                simultaneousUploads: 4,
                testChunks: true,
                throttleProgressCallbacks: 1,
            });
            r.assignBrowse(document.getElementById('browseButton'));
            r.on('fileSuccess', function (file) {
                // console.debug(file);
            });
            r.on('fileProgress', function (file) {
                // console.debug(file);
            });
            r.on('fileAdded', function (file, event) {
                r.upload();
                //console.debug(file, event);
            });
            r.on('fileRetry', function (file) {
                //console.debug(file);
            });
            r.on('fileError', function (file, message) {
                //console.debug(file, message);
            });
            r.on('uploadStart', function () {
                //console.debug();
            });
            r.on('complete', function () {
                //console.debug();
            });
            r.on('progress', function () {
                //console.debug();
            });
            r.on('error', function (message, file) {
                //console.debug(message, file);
            });
            r.on('pause', function (file, message) {
                //console.debug();
            });
            r.on('cancel', function () {
                //console.debug();
            });
        </script>
</html>

后台upload.php页面

/**
 *
 * Logging operation - to a file (upload_log.txt) and to the stdout
 * @param string $str - the logging string
 */
function _log($str)
{
    // log to the output
    $log_str = date('d.m.Y') . ": {$str}\r\n";
    echo $log_str;
    // log to file
    if (($fp = fopen('upload_log.txt', 'a+')) !== false) {
        fputs($fp, $log_str);
        fclose($fp);
    }
}

/**
 *
 * Delete a directory RECURSIVELY
 * @param string $dir - directory path
 * @link http://php.net/manual/en/function.rmdir.php
 */
function rrmdir($dir)
{
    if (is_dir($dir)) {
        $objects = scandir($dir);
        foreach ($objects as $object) {
            if ($object != "." && $object != "..") {
                if (filetype($dir . "/" . $object) == "dir") {
                    rrmdir($dir . "/" . $object);
                } else {
                    unlink($dir . "/" . $object);
                }
            }
        }
        reset($objects);
        rmdir($dir);
    }
}

/**
 *
 * Check if all the parts exist, and
 * gather all the parts of the file together
 * @param string $dir - the temporary directory holding all the parts of the file
 * @param string $fileName - the original file name
 * @param string $chunkSize - each chunk size (in bytes)
 * @param string $totalSize - original file size (in bytes)
 */
function createFileFromChunks($temp_dir, $fileName, $chunkSize, $totalSize)
{
    // count all the parts of this file
    $total_files = 0;
    foreach (scandir($temp_dir) as $file) {
        if (stripos($file, $fileName) !== false) {
            $total_files++;
        }
    }
    // check that all the parts are present
    // the size of the last part is between chunkSize and 2*$chunkSize
    if ($total_files * $chunkSize >= ($totalSize - $chunkSize + 1)) {
        // create the final destination file
        if (($fp = fopen('temp/' . $fileName, 'w')) !== false) {
            for ($i = 1; $i <= $total_files; $i++) {
                fwrite($fp, file_get_contents($temp_dir . '/' . $fileName . '.part' . $i));
                _log('writing chunk ' . $i);
            }
            fclose($fp);
        } else {
            _log('cannot create the destination file');
            return false;
        }
        // rename the temporary directory (to avoid access from other
        // concurrent chunks uploads) and than delete it
        if (rename($temp_dir, $temp_dir . '_UNUSED')) {
            rrmdir($temp_dir . '_UNUSED');
        } else {
            rrmdir($temp_dir);
        }
    }
}

//接收上传的文件
//check if request is GET and the requested chunk exists or not. this makes testChunks work
if ($_SERVER['REQUEST_METHOD'] === 'GET') {
    $temp_dir = 'temp/' . $_GET['resumableIdentifier'];
    $chunk_file = $temp_dir . '/' . $_GET['resumableFilename'] . '.part' . $_GET['resumableChunkNumber'];
    if (file_exists($chunk_file)) {
        header("HTTP/1.0 200 Ok");
    } else {
        header("HTTP/1.0 404 Not Found");
    }
}
//接收上传的文件
// loop through files and move the chunks to a temporarily created directory
if (!empty($_FILES)) foreach ($_FILES as $file) {
    // check the error status
    if ($file['error'] != 0) {
        _log('error ' . $file['error'] . ' in file ' . $_POST['resumableFilename']);
        continue;
    }
    // init the destination file (format <filename.ext>.part<#chunk>
    // the file is stored in a temporary directory
    $temp_dir = 'temp/' . $_POST['resumableIdentifier'];
    $dest_file = $temp_dir . '/' . $_POST['resumableFilename'] . '.part' . $_POST['resumableChunkNumber'];
    // create the temporary directory
    if (!is_dir($temp_dir)) {
        mkdir($temp_dir, 0777, true);
    }
    // move the temporary file
    if (!move_uploaded_file($file['tmp_name'], $dest_file)) {
        _log('Error saving (move_uploaded_file) chunk ' . $_POST['resumableChunkNumber'] . ' for file ' . $_POST['resumableFilename']);
    } else {
        // check if all the parts present, and create the final destination file
        createFileFromChunks($temp_dir, $_POST['resumableFilename'],
            $_POST['resumableChunkSize'], $_POST['resumableTotalSize']);
    }
}

以上就是本文php 使用resumablejs实现文件的分块上传与断点续传功能的全部内容，希望本文所述对大家PHP程序设计有所帮助。

php 使用resumablejs实现文件的分块上传与断点续传功能

相关推荐

请登录