功能:支持斷點續(xù)傳的下載,能計算傳輸率,能控制傳輸率
在貢山等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強發(fā)展的系統(tǒng)性、市場前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務理念，為客戶提供成都網(wǎng)站設計、做網(wǎng)站 網(wǎng)站設計制作按需定制設計,公司網(wǎng)站建設,企業(yè)網(wǎng)站建設,成都品牌網(wǎng)站建設,營銷型網(wǎng)站建設,成都外貿(mào)網(wǎng)站建設公司,貢山網(wǎng)站建設費用合理。
簡易使用方法:
$object = new httpdownload();
$object-set_byfile($file)%N#H#%;//服務器文件名,包括路徑
$object-filename = $filename;//下載另存為的文件名
$object-download();
3.源文件:
?
class httpdownload {
var $data = null;
var $data_len = 0;
var $data_mod = 0;
var $data_type = 0;
var $data_section = 0; //section download
var $sentSize=0;
var $handler = array('auth' = null);
var $use_resume = true;
var $use_autoexit = false;
var $use_auth = false;
var $filename = null;
var $mime = null;
var $bufsize = 2048;
var $seek_start = 0;
var $seek_end = -1;
var $totalsizeref = 0;
var $bandwidth = 0;
var $speed = 0;
function initialize() {
global $HTTP_SERVER_VARS;
if ($this-use_auth) //use authentication {
if (!$this-_auth()) //no authentication {
header('WWW-Authenticate: Basic realm="Please enter your username and password"');
header('HTTP/1.0 401 Unauthorized');
header('status: 401 Unauthorized');
if ($this-use_autoexit) exit();
return false;
}
}
if ($this-mime == null) $this-mime = "application/octet-stream"; //default mime
if (isset($_SERVER['HTTP_RANGE']) || isset($HTTP_SERVER_VARS['HTTP_RANGE'])) {
if (isset($HTTP_SERVER_VARS['HTTP_RANGE'])) $seek_range = substr($HTTP_SERVER_VARS['HTTP_RANGE'] , strlen('bytes='));
else $seek_range = substr($_SERVER['HTTP_RANGE'] , strlen('bytes='));
$range = explode('-',$seek_range);
if ($range[0] 0) {
$this-seek_start = intval($range[0]);
}
if ($range[1] 0) $this-seek_end = intval($range[1]);
else $this-seek_end = -1;
if (!$this-use_resume) {
$this-seek_start = 0;
//header("HTTP/1.0 404 Bad Request");
//header("Status: 400 Bad Request");
//exit;
//return false;
} else {
$this-data_section = 1;
}
} else {
$this-seek_start = 0;
$this-seek_end = -1;
}
$this-sentSize=0;
return true;
}
function header($size,$seek_start=null,$seek_end=null) {
header('Content-type: ' . $this-mime);
header('Content-Disposition: attachment; filename="' . $this-filename . '"');
header('Last-Modified: ' . date('D, d M Y H:i:s /G/M/T' , $this-data_mod));
if ($this-data_section $this-use_resume) {
header("HTTP/1.0 206 Partial Content");
header("Status: 206 Partial Content");
header('Accept-Ranges: bytes');
header("Content-Range: bytes $seek_start-$seek_end/$size");
header("Content-Length: " . ($seek_end - $seek_start + 1));
} else {
header("Content-Length: $size");
}
}
function download_ex($size) {
if (!$this-initialize()) return false;
ignore_user_abort(true);
//Use seek end here
if ($this-seek_start ($size - 1)) $this-seek_start = 0;
if ($this-seek_end = 0) $this-seek_end = $size - 1;
$this-header($size,$seek,$this-seek_end);
$this-data_mod = time();
return true;
}
function download() {
if (!$this-initialize()) return false;
try {
error_log("begin download/n", 3,"/usr/local/www/apache22/LOGS/apache22_php.err");
$seek = $this-seek_start;
$speed = $this-speed;
$bufsize = $this-bufsize;
$packet = 1;
//do some clean up
@ob_end_clean();
$old_status = ignore_user_abort(true);
@set_time_limit(0);
$this-bandwidth = 0;
$size = $this-data_len;
if ($this-data_type == 0) //download from a file {
$size = filesize($this-data);
if ($seek ($size - 1)) $seek = 0;
if ($this-filename == null) $this-filename = basename($this-data);
$res = fopen($this-data,'rb');
if ($seek) fseek($res , $seek);
if ($this-seek_end $seek) $this-seek_end = $size - 1;
$this-header($size,$seek,$this-seek_end); //always use the last seek
$size = $this-seek_end - $seek + 1;
while (!(connection_aborted() || connection_status() == 1) $size 0) {
if ($size $bufsize) {
echo fread($res , $size);
$this-bandwidth += $size;
$this-sentSize+=$size;
} else {
echo fread($res , $bufsize);
$this-bandwidth += $bufsize;
$this-sentSize+=$bufsize;
}
$size -= $bufsize;
flush();
if ($speed 0 ($this-bandwidth $speed*$packet*1024)) {
sleep(1);
$packet++;
}
}
fclose($res);
}
elseif ($this-data_type == 1) //download from a string
{
if ($seek ($size - 1)) $seek = 0;
if ($this-seek_end $seek) $this-seek_end = $this-data_len - 1;
$this-data = substr($this-data , $seek , $this-seek_end - $seek + 1);
if ($this-filename == null) $this-filename = time();
$size = strlen($this-data);
$this-header($this-data_len,$seek,$this-seek_end);
while (!connection_aborted() $size 0) {
if ($size $bufsize) {
$this-bandwidth += $size;
$this-sentSize+=$size;
} else {
$this-bandwidth += $bufsize;
$this-sentSize+=$bufsize;
}
echo substr($this-data , 0 , $bufsize);
$this-data = substr($this-data , $bufsize);
$size -= $bufsize;
flush();
if ($speed 0 ($this-bandwidth $speed*$packet*1024)) {
sleep(1);
$packet++;
}
}
} else if ($this-data_type == 2) {
//just send a redirect header
header('location: ' . $this-data);
}
if($this-totalsizeref==$this-sentSize )error_log("end download/n", 3,"/usr/local/www/apache22/LOGS/apache22_php.err");
else error_log("download is canceled/n", 3,"/usr/local/www/apache22/LOGS/apache22_php.err");
if ($this-use_autoexit) exit();
//restore old status
ignore_user_abort($old_status);
set_time_limit(ini_get("max_execution_time"));
}
catch(Exception $e) {
error_log("cancel download/n".$e, 3,"/usr/local/www/apache22/LOGS/apache22_php.err");
}
return true;
}
function set_byfile($dir) {
if (is_readable($dir) is_file($dir)) {
$this-data_len = 0;
$this-data = $dir;
$this-data_type = 0;
$this-data_mod = filemtime($dir);
$this-totalsizeref = filesize($dir);
return true;
} else return false;
}
function set_bydata($data) {
if ($data == '') return false;
$this-data = $data;
$this-data_len = strlen($data);
$this-data_type = 1;
$this-data_mod = time();
return true;
}
function set_byurl($data) {
$this-data = $data;
$this-data_len = 0;
$this-data_type = 2;
return true;
}
function set_lastmodtime($time) {
$time = intval($time);
if ($time = 0) $time = time();
$this-data_mod = $time;
}
function _auth() {
if (!isset($_SERVER['PHP_AUTH_USER'])) return false;
if (isset($this-handler['auth']) function_exists($this-handler['auth'])) {
return $this-handler['auth']('auth' , $_SERVER['PHP_AUTH_USER'],$_SERVER['PHP_AUTH_PW']);
} else return true; //you must use a handler
}
}
?
可以通過$_SERVER['HTTP_RANGE']取得用戶請求的文件的range來實現(xiàn)。
其實說簡單點就是通過這個變量$_SERVER['HTTP_RANGE']取得用戶請求的文件的range，然后程序去控制文件的輸出。比如第一次請求一個文件的從0到999字節(jié)，第二次請求1000到1999字節(jié)，以此類推，每次請求1000字節(jié)的內(nèi)容，然后程序通過fseek函數(shù)去取得對應的文件位置，然后輸出。
網(wǎng)上有很多這樣的教程可以去查一查。
現(xiàn)在這個時代文件存儲基本分離到了單獨的存儲服務上面,比如說阿里云的OSS,七牛云的云存儲等等.考慮這些第三方服務的話,那么你的大文件上傳和斷點續(xù)傳等功能實現(xiàn)只需要去對接服務商提供的API接口即可(好處就是上傳服務的壓力等因素服務商幫你抗,不好就是你得付錢給服務商),其中方案就是js-sdk只傳OSS的方式,穩(wěn)定性好,只傳斷點續(xù)傳和實時瀏覽上傳進度。
如果你是大神,需要自己在服務器實現(xiàn)上述功能,那么要考慮的不僅是實現(xiàn)本身的需求,還得考慮服務器是否能抗得住這樣的上傳壓力(帶寬,延時),還有存儲空間是否足夠等額外的問題.
HTTP協(xié)議里, 對斷點下載有支持.
斷點上傳單純靠PHP 是做不了的.
因為普通的瀏覽器端沒那功能.(上傳的時候 還是會整個文件編碼發(fā)送)
想實現(xiàn)的話 , 客戶端需要插件了,
客戶端可以使用flex實現(xiàn). 服務端, PHP可以寫個webservice 接受文件.
可以在網(wǎng)上找找. 關鍵字: "flex php 上傳"
大文件上傳, 走 http 是比較費勁兒的. ?不穩(wěn)定是關鍵.
是實現(xiàn)斷點續(xù)傳，就需要把大文件分割成多個小文件，然后單個上傳。傳完后在合并。
│ merge.PHP –合并文件腳本
│ merge.zip –合并后文件
│ socket.zip –需要分割的文件
│ split.php –分割文件腳本
│
└─split –分割后小文件目錄
下面是源碼
split.php
?php
$fp = fopen("socket.zip", "rb");
$filesize = 10;
$i = 0;
$no = 1;
while(!feof($fp))
{
$file = fread($fp, $filesize);
$fp2 = fopen("./split/socket.port".sprintf("%04d",$no).".".$i."-".($i+$filesize).".tmp", "wb");fwrite($fp2, $file, $filesize);
fclose($fp2);
$i+=$filesize+1;
$no++;
}
fclose($fp);
merge.php
?php
$filelist = glob('./split/*socket*.tmp');$filesize = 10;
//print_r($filelist);
$mergeFileName = 'merg.zip';
unlink($mergeFileName);
$fp2 = fopen($mergeFileName,"w+");
foreach($filelist as $k = $v)
{
$fp = fopen($v, "rb");
$content = fread($fp, $filesize);
fwrite($fp2, $content, $filesize);
unset($content);
fclose($fp);
echo $k,"\n";
}
fclose($fp2);
重慶分公司
重慶分公司
