Here I will explain how to call multiple apis in parallel process. So I am going to use PHP CURL function to achieve it
#Default GET method
$nodes =array(array('url'=>"http://rest.example1.com"),
array('url'=>"http://rest.example2.com?id=2¶m1=yourvalue"),
array('url'=>"http://rest.example3.com?id=2¶m1=yourvalue")
);
$results = multiThreading($nodes);
#POST Method And PUT Method
$user_data will be array of your post data
like $user_data['name']= 'dev';
$user_data['email']= 'xyz@test.com';
$nodes[0]['url'] ="http://rest.";
$nodes[0]['post'] = $user_data;
$results = multiThreading($nodes);
#POST Method And PUT Method - XML Input
$user_data will be array of your post data
like $user_data['name']= 'dev';
$user_data['email']= 'xyz@test.com';
$nodes[0]['url'] ="http://rest.";
$nodes[0]['post'] = $user_data;
$results = multiThreading($nodes,array('Content-Type: application/xml'));
Output - var_dump( $results);
function multiThreading($nodes){
$node_count = count($nodes);
$RESP_TIMEOUT = 30;
$curl_arr = array();
$tmp_str_cookies = "";
/* pass your Headers */
$tmp_arr_httpheader = array("Connection: Close");
$master = curl_multi_init();
$options = array(
CURLOPT_RETURNTRANSFER => true, // return web page
CURLOPT_HEADER => false, // don't return headers
CURLOPT_FOLLOWLOCATION => true, // follow redirects
CURLOPT_AUTOREFERER => true, // set referer on redirect
CURLOPT_CONNECTTIMEOUT => 10, // timeout on connect
// CURLOPT_TIMEOUT => $RESP_TIMEOUT, // timeout on response
CURLOPT_MAXREDIRS => 10, // stop after 10 redirects
CURLOPT_SSL_VERIFYHOST => 0, // don't verify ssl
CURLOPT_SSL_VERIFYPEER => false, //
CURL_HTTP_VERSION_1_1 => 1,
CURLOPT_NOSIGNAL => true,
CURLOPT_HTTPHEADER =>$tmp_arr_httpheader,
CURLOPT_REFERER => 'http://'.$_SERVER['HTTP_HOST'].$_SERVER['REQUEST_URI']
);
for($i = 0; $i < $node_count; $i++)
{
$url = (is_array($nodes[$i]) && !empty($nodes[$i]['url'])) ? $nodes[$i]['url'] : $nodes[$i];
$resp_timeout = (is_array($nodes) && array_key_exists('resp_timeout',$nodes[$i])) ? $nodes[$i]['resp_timeout'] : $RESP_TIMEOUT;
// default 5 secs timeout
$curl_arr[$i] = curl_init();
curl_setopt($curl_arr[$i], CURLOPT_URL, $url);
if (is_array($nodes[$i])) {
if (!empty($nodes[$i]['post'])) {
if (is_array($nodes[$i]['post']))
{
$o="";
foreach ($nodes[$i]['post'] as $k=>$v)
{
$o.= "$k=".$v."&";
}
$post_data=substr($o,0,-1);
}
else
{
$post_data = $nodes[$i]['post'];
}
curl_setopt($curl_arr[$i], CURLOPT_POST,1);
curl_setopt($curl_arr[$i], CURLOPT_POSTFIELDS,$post_data);
}
elseif (!empty($nodes[$i]['put']))
{
if (is_array($nodes[$i]['put']))
{
$o="";
foreach ($nodes[$i]['put'] as $k=>$v)
{
$o.= "$k=".$v."&";
}
$post_data=substr($o,0,-1);
}
else
{
$post_data = $nodes[$i]['put'];
}
curl_setopt($curl_arr[$i], CURLOPT_CUSTOMREQUEST,'PUT');
curl_setopt($curl_arr[$i], CURLOPT_POSTFIELDS,$post_data);
}
elseif (!empty($nodes[$i]['delete']))
{
curl_setopt($curl_arr[$i], CURLOPT_CUSTOMREQUEST,'DELETE');
}
}
curl_setopt($curl_arr[$i], CURLOPT_TIMEOUT, $resp_timeout);
curl_setopt_array($curl_arr[$i],$options);
curl_multi_add_handle($master, $curl_arr[$i]);
}
do {
curl_multi_exec($master,$running);
usleep(10000);
} while($running > 0);
for($i = 0; $i < $node_count; $i++)
{
$results[$i] = curl_multi_getcontent ( $curl_arr[$i] );
$tmp_arr = (curl_getinfo($curl_arr[$i]));
curl_multi_remove_handle($master, $curl_arr[$i]);
curl_close($curl_arr[$i]);
}
$rest_latency = $res_latency_array;
curl_multi_close($master);
return $results;
}
