php nginx shell Ubuntu Windows google wordpress HTML5 mysql Python 开源 linux命令 Firefox linux Android 微软 程序员 java apache centos

使用PHP CURL的POST数据

curl 是使用URL语法的传送文件工具,支持ftp、FTPS、HTTP HTPPS scp sftp tftp telnet DICT file和LDAP。curl 支持SSL证书、HTTP POST、HTTP PUT 、FTP 上传,kerberos、基于HTT格式的上传、代理、cookie、用户+口令证明、文件传送恢复、http代理通道和大量其他有用的技巧。

原来PHP默认并不进行此项功能的扩展,但还是有的,只是没有让它生效罢了。打开php安装目录,搜索以下三个文件 ssleay32.dll、libeay32.dll和 php_curl.dll,一一拷贝到系统目录下的system32文件夹下,修改php.ini文件,找到;extension= php_curl.dll行,去掉前面的;号,保存,重启服务器。

下面举几个例子。

短彩信发送

    $xml_data = '<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
    <TaskDataTransfer4EReq xmlns="http://www.aspirehld.com/iecp/TaskDataTransfer4EReq">
    <eid> </eid>
    <username> </username>
    <password> </password>
    <src> </src>
    <destmsisdn>'.$pns.'</destmsisdn>
    <content type="sms">
        <title>'.$content.'</title>
    </content>
    </TaskDataTransfer4EReq>';

    $url = 'http://www.nowamagic.net/service/taskSubmit';//接收XML地址

    $header = "Content-type: text/xml";//定义content-type为xml
    $ch = curl_init(); //初始化curl
    curl_setopt($ch, CURLOPT_URL, $url);//设置链接
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);//设置是否返回信息
    curl_setopt($ch, CURLOPT_HTTPHEADER, $header);//设置HTTP头
    curl_setopt($ch, CURLOPT_POST, 1);//设置为POST方式
    curl_setopt($ch, CURLOPT_POSTFIELDS, $xml_data);//POST数据
    $response = curl_exec($ch);//接收返回信息
    if(curl_errno($ch)){//出错则显示错误信息
        print curl_error($ch);
    }
    curl_close($ch); //关闭curl链接
    echo $response;//显示返回信息

POST数据飞信接口

$username = 13800138000;
$password = 123456;
$sendto = 13912345678;
$message = "测试一个试试看!";

$curlPost = 'username='.urlencode($username).'&
password='.urlencode($password).'&
sendto='.urlencode($sendto).'&
message='.urlencode($message).'';

$ch = curl_init();//初始化curl
curl_setopt($ch,CURLOPT_URL,'http://sms.api.bz/fetion.php');//抓取指定网页
curl_setopt($ch, CURLOPT_HEADER, 0);//设置header
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);//要求结果为字符串且输出到屏幕上
curl_setopt($ch, CURLOPT_POST, 1);//post提交方式
curl_setopt($ch, CURLOPT_POSTFIELDS, $curlPost);
$data = curl_exec($ch);//运行curl
curl_close($ch);
print_r($data);//输出结果

飞信接口模式:http://sms.api.bz/fetion.php?username=您的移动飞信登录手机号,&password=您的移动飞信登录密码,&sendto=接收短信的飞信好友手机号,&message=短信内容。

总结一下使用curl方法:

  1. 初始化curl
  2. 使用curl_setopt设置目标url,和其他选项
  3. curl_exec,执行curl
  4. 执行后,关闭curl
  5. 最后一步就是输出

CERL 多线程

curl一般用来抓取网页,第二种就是get或者post数据,第三种应用就是实现PHP的多线程任务。下面来实现多线程的:

<?php
/*
curl 多线程抓取
*/

 /** 
     * curl 多线程 
     *  
     * @param array $array 并行网址 
     * @param int $timeout 超时时间
     * @return array 
     */ 
 function Curl_http($array,$timeout){
     $res = array();
     $mh = curl_multi_init();//创建多个curl语柄
    $startime = getmicrotime();
     foreach($array as $k=>$url){
         $conn[$k]=curl_init($url);
         
        curl_setopt($conn[$k], CURLOPT_TIMEOUT, $timeout);//设置超时时间
        curl_setopt($conn[$k], CURLOPT_USERAGENT, 'Mozilla/5.0 (compatible; MSIE 5.01; Windows NT 5.0)');
        curl_setopt($conn[$k], CURLOPT_MAXREDIRS, 7);//HTTp定向级别
        curl_setopt($conn[$k], CURLOPT_HEADER, 0);//这里不要header,加块效率
        curl_setopt($conn[$k], CURLOPT_FOLLOWLOCATION, 1); // 302 redirect
        curl_setopt($conn[$k],CURLOPT_RETURNTRANSFER,1);
        curl_multi_add_handle ($mh,$conn[$k]);
     }
     //防止死循环耗死cpu 这段是根据网上的写法
        do {
            $mrc = curl_multi_exec($mh,$active);//当无数据,active=true
        } while ($mrc == CURLM_CALL_MULTI_PERFORM);//当正在接受数据时
        while ($active and $mrc == CURLM_OK) {//当无数据时或请求暂停时,active=true
            if (curl_multi_select($mh) != -1) {
                do {
                    $mrc = curl_multi_exec($mh, $active);
                } while ($mrc == CURLM_CALL_MULTI_PERFORM);
            }
        }
     
     foreach ($array as $k => $url) {
           curl_error($conn[$k]);
          $res[$k]=curl_multi_getcontent($conn[$k]);//获得返回信息
          $header[$k]=curl_getinfo($conn[$k]);//返回头信息
          curl_close($conn[$k]);//关闭语柄
          curl_multi_remove_handle($mh  , $conn[$k]);   //释放资源  
        }
        
        curl_multi_close($mh);
        $endtime = getmicrotime();
        $diff_time = $endtime - $startime;
        
        return array('diff_time'=>$diff_time,
                     'return'=>$res,
                    'header'=>$header        
                    );
     
 }
 //计算当前时间
 function getmicrotime() {
        list($usec, $sec) = explode(" ",microtime());
        return ((float)$usec + (float)$sec);
    }
    
    //测试一下,curl 三个网址
    $array = array(
                "http://www.weibo.com/",
                "http://www.renren.com/",
                "http://www.qq.com/"
                );

    $data = Curl_http($array,'10');//调用
    var_dump($data);//输出
     
?>

因为$active要等全部url数据接受完毕才变成false,所以这里用到了curl_multi_exec的返回值判断是否还有数据,当有数据的时候就不停调用curl_multi_exec,暂时没有数据就进入select阶段,新数据一来就可以被唤醒继续执行。这里的好处就是CPU的无谓消耗没有了。

这个多线程的写法步骤:

  • 调用curl_multi_init
  • 循环调用curl_multi_add_handle,这一步需要注意的是,curl_multi_add_handle的第二个参数是由curl_init而来的子handle。
  • 持续调用curl_multi_exec
  • 根据需要循环调用curl_multi_getcontent获取结果
  • 调用curl_multi_remove_handle,并为每个字handle调用curl_close
  • 调用curl_multi_close

延伸阅读

评论