2017-04-03 68 views
1

我有一张表,我希望在维护期间运行PHP脚本。在While循环中执行PHP CURL

我有以下代码。

$sql = "SELECT `id`, `url` FROM `log_requests` WHERE `is_sent` = '0'"; 
$e = $conn->execute($sql); 

我的url数组在从DB中获取表之后。

Array 
(
[0] => https://www.smsgatewaycenter.com/library/send_sms_2.php?UserName=username&Password=password&Type=Individual&To=9999999999&Mask=Senderid&Message=Hello+World+1 
[1] => https://www.smsgatewaycenter.com/library/send_sms_2.php?UserName=username&Password=password&Type=Individual&To=9999999999&Mask=Senderid&Message=Hello+World+2 
[2] => https://www.smsgatewaycenter.com/library/send_sms_2.php?UserName=username&Password=password&Type=Individual&To=9999999999&Mask=Senderid&Message=Hello+World+3 
[3] => https://www.smsgatewaycenter.com/library/send_sms_2.php?UserName=username&Password=password&Type=Individual&To=9999999999&Mask=Senderid&Message=Hello+World+4 
) 

然后我跑while循环

$ch = curl_init(); 
while($row = $e->FetchRow()){ 
    curl_setopt($ch, CURLOPT_URL, $row['url']); 
    curl_setopt($ch, CURLOPT_HEADER, 0); 
    $q = "UPDATE `log_requests` SET `is_sent` = '1' WHERE `id` = '".$row['id']."'"; 
    $conn->execute($q); 
} 
curl_close($ch); 

问题是唯一一个使用curl执行URL,然后在我的表中只有一行获取is_sent列更新为1。

为什么在我while循环运行单个URL。我在这里犯了什么错误?

*************************编辑********************

好吧,现在我想出了下面,现在运行成功。我只想知道我是否正确。

$set = array(); 
while ($row = $executequery2->FetchRow()) { 
    $set[$row['url']][] = $row; 
} 

$curl_handles = array(); 
foreach($set as $url => $rows) { 
    $curl_handles[$url] = curl_init(); 
    curl_setopt($curl_handles[$url], CURLOPT_URL, $url); 
    foreach($rows as $row) { 
     $query3 = "UPDATE `log_requests` SET `is_sent` = '1' WHERE `id` = '" . $row['id'] . "'"; 
     $conn->Execute($query3); 
    } 
} 

$curl_multi_handle = curl_multi_init(); 
$i = 0; 
$block = array(); 

foreach($curl_handles as $a_curl_handle) { 
    $i++; 
    curl_multi_add_handle($curl_multi_handle, $a_curl_handle); 
    $block[] = $a_curl_handle; 
    if (($i % 5 == 0) or ($i == count($curl_handles))) { 
     $running = NULL; 
     do { 
      $running_before = $running; 
      curl_multi_exec($curl_multi_handle, $running); 
      if ($running != $running_before) { 
       echo ("Waiting for $running sites to finish...<br />"); 
      } 
     } 
     while ($running > 0); 
     foreach($block as $handle) { 
      $code = curl_getinfo($handle, CURLINFO_HTTP_CODE); 
      $curl_errno = curl_errno($handle); 
      $curl_error = curl_error($handle); 
      if ($curl_error) { 
       echo (" *** cURL error: ($curl_errno) $curl_error\n"); 
      } 
      curl_multi_remove_handle($curl_multi_handle, $handle); 
     } 
     $block = array(); 
    } 
} 

curl_multi_close($curl_multi_handle); 

更新表列是正确的方法吗?

+0

您使用的是PDO吗? '$ row'的转储会产生什么结果? – Andrew

+0

使用ADODB。我给了'url' $ row yield数组 – yuri1000

+0

您需要初始化curl并在while循环中关闭它,或者使用[multi_curl_exec](http://php.net/manual/en/function.curl -multi-exec.php)而不是 – hassan

回答

0

我遇到过同样的问题,并在线获得了此解决方案。只需将循环代码与循环分开,然后尝试。

事情是这样的:

while($row = $e->FetchRow()) { 
    $result = call_curl($row['url']); 
    if($result === FALSE) { 
     die("Error"); 
    } 
    else 
    { 
     $q = "UPDATE `log_requests` SET `is_sent` = '1' WHERE `id` = '".$row['id']."'"; 
    } 
} 


function call_curl($url) 
{ 
    $ch = curl_init(); 
    curl_setopt($ch, CURLOPT_URL, $url); 
    curl_setopt($ch, CURLOPT_HEADER, 0); 
    $result = curl_exec ($ch); 
    curl_close($ch); 
    return $result; 
} 

希望这有助于你。

+0

嗨,感谢您的帮助。它隐约奔跑,有时它跑1个网址,有时3个,有时2个。我不明白 – yuri1000