define('DEBUG', 'on');

define('WEBPATH', dirname(__DIR__));

require __DIR__ . '/../libs/lib_config.php';

$cloud = Swoole\Client\SOA::getInstance();

$cloud->putEnv('app', 'test');

$cloud->putEnv('appKey', 'test1234');

$cloud->addServers(array('127.0.0.1:8888'));

$s = microtime(true);

$ok = $err = 0;

for ($i = 0; $i < 1; $i++)

{

$s2 = microtime(true);

$ret1 = $cloud->task("BL\\Test::test1", ["hello{$i}_1"], function($retObj) {

echo "task1 finish\n";

});

$ret2 = $cloud->task("BL\\Test::hello");

$ret3 = $cloud->task("BL\\Test::test1", ["hello{$i}_3"]);

$ret4 = $cloud->task("BL\\Test::test1", ["hello{$i}_4"]);

$ret5 = $cloud->task("BL\\Test::test1", ["hello{$i}_5"]);

$ret6 = $cloud->task("BL\\Test::test1", ["hello{$i}_6"]);

$ret7 = $cloud->task("BL\\Test::test1", ["hello{$i}_7"]);

$ret8 = $cloud->task("BL\\Test::test1", ["hello{$i}_8"]);

echo "send " . (microtime(true) - $s2) * 1000, "\n";

$n = $cloud->wait(0.5); //500ms超时

//表示全部OK了

if ($n === 8)

{

var_dump($ret1->data, $ret2->data, $ret3->data, $ret4->data, $ret5->data, $ret6->data, $ret7->data, $ret8->data);

echo "finish\n";

$ok++;

}

else

{

echo "#{$i} \t";

echo $ret1->code . '|' . $ret2->code . '|' . $ret3->code . '|' . $ret4->code . '|' . $ret5->code . '|' . $ret6->code . '|' . $ret7->code . '|' . $ret8->code . '|' . "\n";

$err++;

exit;

}

unset($ret1, $ret2, $ret3, $ret4, $ret5, $ret6, $ret7, $ret8);

}

echo "failed=$err.\n";

echo "success=$ok.\n";

echo "use " . (microtime(true) - $s) * 1000, "ms\n";

unset($cloud, $ret1, $ret2);