Topic: help me! php multi curl requests then echo with diff data format (Read 1611 times)

      require_once("getInfo.php");
			
			$getInfo = new getInfo();
			
			$infoObject = $getInfo->getInfoObject();
			
			echo("
");
			print_r($infoObject);
			echo("

");
			
			echo("Difficulty = " . $infoObject->difficulty . "
");
			echo("Estimate = " . $infoObject->estimate . "
");
			echo("Hash Rate = " . $infoObject->hashrate . "
");
			echo("Interval = " . $infoObject->interval . "
");
			echo("Hashes to Win = " . $infoObject->hashestowin . "
");
?>

                        class getInfo
	                  {
			  var $difficultyUrl = "http://blockexplorer.com/q/getdifficulty";
				var $estimateUrl   = "http://blockexplorer.com/q/estimate";
				var $hashrateUrl   = "http://blockchain.info/q/hashrate";
				var $intervalUrl   = "http://blockexplorer.com/q/interval";
				var $hashesUrl     = "http://blockexplorer.com/q/hashestowin";
				var $difficulty;
				var $estimate;
				var $hashrate;
				var $interval;
				var $hashestowin;
										 
				public function getInfo()
			       {
                                        $this->curl($this->difficultyUrl, $result);
					$this->difficulty = $result;

					$this->curl($this->estimateUrl, $result);
					$this->estimate = $result;
					
					$this->curl($this->hashrateUrl, $result);
					$this->hashrate = $result;
					
					$this->curl($this->intervalUrl, $result);
					$this->interval = $result;
					
					$this->curl($this->hashesUrl, $result);
					$this->hashestowin = $result;
			          } 
				
			  public function curl($url, &$result)
			  {
			         $ch = curl_init();
                                  curl_setopt($ch, CURLOPT_URL, $url);
				  curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
				  $result = json_decode(curl_exec($ch));
				  curl_close($ch);
				  return 1;
			  }
				
				public function getInfoObject()
				{
				  return $this;
				}
			}
?>

$urls = array(
  "http://blockexplorer.com/q/getdifficulty",
  "http://blockexplorer.com/q/estimate",
  "http://blockchain.info/q/hashrate",
  "http://blockexplorer.com/q/interval",
  "http://blockexplorer.com/q/hashestowin"
);

// Class to run parallel GET requests and return the transfer
class ParallelGet
{
  function __construct($urls)
  {
    // Create get requests for each URL
    $mh = curl_multi_init();
    foreach($urls as $i => $url)
    {
      $ch[$i] = curl_init($url);
      curl_setopt($bhash4win_Curl, CURLOPT_HEADER, 0);
	  curl_setopt($ch[$i], CURLOPT_RETURNTRANSFER, 1);
      curl_multi_add_handle($mh, $ch[$i]);
    }

    // Start performing the request
    do {
        $execReturnValue = curl_multi_exec($mh, $runningHandles);
    } while ($execReturnValue == CURLM_CALL_MULTI_PERFORM);
    // Loop and continue processing the request
    while ($runningHandles && $execReturnValue == CURLM_OK) {
      // Wait forever for network
      $numberReady = curl_multi_select($mh);
      if ($numberReady != -1) {
        // Pull in any new data, or at least handle timeouts
        do {
          $execReturnValue = curl_multi_exec($mh, $runningHandles);
        } while ($execReturnValue == CURLM_CALL_MULTI_PERFORM);
      }
    }

    // Check for any errors
    if ($execReturnValue != CURLM_OK) {
      trigger_error("Curl multi read error $execReturnValue\n", E_USER_WARNING);
    }

    // Extract the content
    foreach($urls as $i => $url)
    {
      // Check for errors
      $curlError = curl_error($ch[$i]);
      if($curlError == "") {
        $res[$i] = curl_multi_getcontent($ch[$i]);
		echo $res[$i]."\n";
		
      } else {
        print $i."error to get a result"."\n";
      }
	  	
      // Remove and close the handle
      curl_multi_remove_handle($mh, $ch[$i]);
      curl_close($ch[$i]);
    }
    // Clean up the curl_multi handle

	
    curl_multi_close($mh);
    }


}
?>

include('a.php');
echo("
");
print_r($res);

echo("
");
print_r($res);
echo("

");

// Define the URLs
$urls = array(
  "http://example.com/1/",
  "http://example.com/2/",
  "http://example.com/3/",
  "http://example2.com/4/",
  "http://example3.com/5/",
);

// Class to run parallel GET requests and return the transfer
class ParallelGet
{
  function __construct($urls)
  {
    // Create get requests for each URL
    $mh = curl_multi_init();
    foreach($urls as $i => $url)
    {
      $ch[$i] = curl_init($url);
      curl_setopt($ch[$i], CURLOPT_HEADER, 0);
      curl_setopt($ch[$i], CURLOPT_RETURNTRANSFER, 1);
      curl_multi_add_handle($mh, $ch[$i]);
    }

    // Start performing the request
    do {
        $execReturnValue = curl_multi_exec($mh, $runningHandles);
    } while ($execReturnValue == CURLM_CALL_MULTI_PERFORM);
    // Loop and continue processing the request
    while ($runningHandles && $execReturnValue == CURLM_OK) {
      // Wait forever for network
      $numberReady = curl_multi_select($mh);
      if ($numberReady != -1) {
        // Pull in any new data, or at least handle timeouts
        do {
          $execReturnValue = curl_multi_exec($mh, $runningHandles);
        } while ($execReturnValue == CURLM_CALL_MULTI_PERFORM);
      }
    }

    // Check for any errors
    if ($execReturnValue != CURLM_OK) {
      trigger_error("Curl multi read error $execReturnValue\n", E_USER_WARNING);
    }

    // Extract the content
    foreach($urls as $i => $url)
    {
      // Check for errors
      $curlError = curl_error($ch[$i]);
      if($curlError == "") {
        $res[$i] = curl_multi_getcontent($ch[$i]);
	echo $res[$i]."\n";
      } 
      else {
        print $i."error to get result"."\n";
      }
	  	
      // Remove and close the handle
      curl_multi_remove_handle($mh, $ch[$i]);
      curl_close($ch[$i]);
    }

    // Clean up the curl_multi handle

	
    curl_multi_close($mh);
    }
    // Print the response data


}
?>