直接上代码

//php下载m3u8文件

$url = $argv['1'];

if(!file_exists('./tmp/')) {

if(!mkdir('./tmp/')) {

die('请手动在当前目录创建tmp目录');

}

}

$indexPage = file_get_contents($url);

preg_match_all('/.*.ts/', $indexPage, $matches);

if(empty($matches)) {

die('m3u8 文件格式错误');

}

go(function() use($matches) {

$chan = new chan(100); //最大并发数

foreach($matches['0'] as $key => $value) {

if(file_exists('./tmp/'.$key.'.ts')) {

continue;

}

$chan->push('xx');

go(function() use($key, $value, $chan) {

echo "

Add task:".$key;

while(1) {

$rs = co_curl($value);

if(strlen($rs) > 0) {

file_put_contents('./tmp/'.$key.'.ts', $rs);

break;

}

}

echo "

Task ok:".$key;

$chan->pop();

});

}

//确保所有下载已经完成

for($i = 0; $i < 100; $i++) {

$chan->push('over');

}

//合并文件

foreach ($matches['0'] as $key => $value) {

file_put_contents('out.mp4', file_get_contents('./tmp/'.$key.'.ts'), FILE_APPEND);

unlink('./tmp/'.$key.'.ts');

}

echo "

下载完成，转换成功 (out.mp4)";

});

function co_curl($url, $cookies = '', $data = array(), $userHeaders = array(), $retJson = 0)

{

while(1) {

$urlInfo = parse_url($url);

$domain = $urlInfo['host'];

if($urlInfo['scheme'] == 'https') {

$port = 443;

$ssl = true;

} else {

$port = isset($urlInfo['port']) ? $urlInfo['port'] : 80;

$ssl = false;

}

$filename = $urlInfo['path'];

$filename .= isset($urlInfo['query']) ? '?' . $urlInfo['query'] : '';

$cli = new SwooleCoroutineHttpClient($domain, $port, $ssl);

$headers = [

'Host' => $domain,

"User-Agent" => 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/66.0.3359.139 Safari/537.36',

'Accept' => 'text/html,application/xhtml+xml,application/xml',

'Accept-Encoding' => 'gzip',

];

if ($userHeaders) {

$headers = array_merge($headers, $userHeaders);

$headers = $userHeaders;

}

if ($cookies) {

$headers['Cookie'] = $cookies;

}

$cli->setHeaders($headers);

$cli->set(['timeout' => 60]);

if ($data) {

if($data == 'post') {

$data = '';

}

$cli->post($filename, $data);

} else {

$cli->get($filename);

}

$body = $cli->body;

$cli->close();

if($cli->statusCode < 1 || ($retJson && empty(json_decode($body, true)))) {

// echo "

status code:" . $cli->statusCode;

// echo "

body: ".$body;

// echo "

retry...";

} else {

return $body;

}

}

}