php多线程thread开发与应用的例子

php多线程的使用,首先需要php5.3以上版本,并安装pthreads php扩展,可以使php真正的支持多线程,扩展如何安装请自行百度.

PHP扩展下载：https://github.com/krakjoe/pthreads

PHP手册文档：http://php.net/manual/zh/book.pthreads.php

在安装好扩展之后,就可以运用多线程了,下面贴个通过搜索结果抓取百度网盘内容的代码:

BJXSHOP网上购物系统 - 书店版

BJXSHOP购物管理系统是一个功能完善、展示信息丰富的电子商店销售平台；针对企业与个人的网上销售系统；开放式远程商店管理；完善的订单管理、销售统计、结算系统；强力搜索引擎支持；提供网上多种在线支付方式解决方案；强大的技术应用能力和网络安全系统 BJXSHOP网上购物系统 - 书店版，它具备其他通用购物系统不同的功能，有针对图书销售而进行开发的一个电子商店销售平台，如图书ISBN，图书目录

下载

start();
            }
            foreach ($thread_array as $thread_array_key => $thread_array_value) { //检查线程是否执行结束
                while ($thread_array[$thread_array_key]->isRunning()) {
                    usleep(10);
                }
                if ($thread_array[$thread_array_key]->join()) { //如果执行结束，取出结果
                    $temp = $thread_array[$thread_array_key]->data;
                    if ($temp != null) $infos['res'][] = $temp;
                }
            }
            $infos['pages'] = $ret['pages'];
            $infos['status'] = "1";
        } else $infos = null;
    } else $infos = null;
    return $infos;
}
/** 
 * 获取百度搜索结果列表URL
 *
 * @param string $url
 *         搜索结果页URL
 * @param int $format
 *         默认$format=0，获取默认地址；$format=1获取跳转后真实地址
 * @return NULL multitype:array()
 */
function BaiduSRLinksGet($url, $format = 0) {
    $html = CurlLoad::HtmlGet($url); // 获取页面
    if ($html == null) return null;
    try {
        preg_match_all("/"url":"( ? < links > . *) "}/", $html, $rets); // 搜索结果链接筛选
        if (!array_key_exists('links', $rets)) // 如果数组中不包含Links键名，表示获取失败
        return null;
        $ret = array();
        if ($format == 1) {
            $number = count($rets['links']);
            for ($i = 0; $i < $number; $i++) {
                $headr_temp = CurlLoad::Get_Headers($rets['links'][$i], 1); // 通过headr获取真实地址
                if (array_key_exists("Location", $headr_temp)) $ret['links'][$i] = $headr_temp['Location'];
                else $ret['links'] = $rets['links'];
            }
        } else $ret['links'] = $rets['links'];
        preg_match_all('/href="?/s?wd=site%3Apan.baidu.com%20(?.+?)&ie=utf-8">/', $html, $out);
        unset($out['url'][0]);
        $number = count($out['url']);
        for ($i = 1; $i < $number; $i++) {
            preg_match_all('/&pn=(.*)/', $out['url'][$i], $temp);
            $ret['pages'][$temp[1][0] / 10] = base64_encode($out['url'][$i]);
        }
        return $ret;
    }
    catch(Exception $e) {
        WriteLog($e);
        return null;
    }
}
/** 
 * 百度网盘资源信息获取
 *
 * @param string $url
 *         网盘资源页URL
 * @return NULL array
 */
function PanInfoGet($url) {
    $html = CurlLoad::HtmlGet($url); // 获取页面
    if ($html == null) return null;
    try {
        if (preg_match_all("/文件名:(?.*) 文件大小:(?.*) 分享者:(?.*) 分享时间:(?.*) 下载次数:(?[0-9]+)/", $html, $ret) == 0) return null;
        $rets['name'] = $ret['name'][0];
        $rets['size'] = $ret['size'][0];
        $rets['user'] = $ret['user'][0];
        $rets['date'] = $ret['date'][0];
        $rets['number'] = $ret['number'][0];
        $rets['link'] = $url;
        return $rets;
    }
    catch(Exception $e) {
        WriteLog($e);
        return null;
    }
}
function WriteLog($str) {
    $file = fopen("../error.log", "a+");
    fwrite($file, "Warning:" . date("Y/m/d H:i:s") . ":" . $str . "rn");
    fclose($file);
}
/** 
 * 多线程抓取对象
 * @author MuXi
 *
 */
class baidu_thread_run extends Thread {
    public $url;
    public $data;
    public function __construct($url) {
        $this->url = $url;
    }
    public function run() {
        if (($url = $this->url)) {
            $this->data = PanInfoGet($url); //线程执行方法
            
        }
    }
}
?>

立即学习“PHP免费学习笔记（深入）”；