45d10d8205
Echo statements were inconsistent in the use of double quotes vs. single quotes. Some echo statements had spaces between arguments, some did not.
75 lines
1.7 KiB
PHP
75 lines
1.7 KiB
PHP
<?php
|
|
|
|
require_once __DIR__ . '/vendor/autoload.php';
|
|
use PhpAmqpLib\Connection\AMQPStreamConnection;
|
|
use PhpAmqpLib\Message\AMQPMessage;
|
|
|
|
class FibonacciRpcClient
|
|
{
|
|
private $connection;
|
|
private $channel;
|
|
private $callback_queue;
|
|
private $response;
|
|
private $corr_id;
|
|
|
|
public function __construct()
|
|
{
|
|
$this->connection = new AMQPStreamConnection(
|
|
'localhost',
|
|
5672,
|
|
'guest',
|
|
'guest'
|
|
);
|
|
$this->channel = $this->connection->channel();
|
|
list($this->callback_queue, ,) = $this->channel->queue_declare(
|
|
"",
|
|
false,
|
|
false,
|
|
true,
|
|
false
|
|
);
|
|
$this->channel->basic_consume(
|
|
$this->callback_queue,
|
|
'',
|
|
false,
|
|
false,
|
|
false,
|
|
false,
|
|
array(
|
|
$this,
|
|
'onResponse'
|
|
)
|
|
);
|
|
}
|
|
|
|
public function onResponse($rep)
|
|
{
|
|
if ($rep->get('correlation_id') == $this->corr_id) {
|
|
$this->response = $rep->body;
|
|
}
|
|
}
|
|
|
|
public function call($n)
|
|
{
|
|
$this->response = null;
|
|
$this->corr_id = uniqid();
|
|
|
|
$msg = new AMQPMessage(
|
|
(string) $n,
|
|
array(
|
|
'correlation_id' => $this->corr_id,
|
|
'reply_to' => $this->callback_queue
|
|
)
|
|
);
|
|
$this->channel->basic_publish($msg, '', 'rpc_queue');
|
|
while (!$this->response) {
|
|
$this->channel->wait();
|
|
}
|
|
return intval($this->response);
|
|
}
|
|
}
|
|
|
|
$fibonacci_rpc = new FibonacciRpcClient();
|
|
$response = $fibonacci_rpc->call(30);
|
|
echo ' [.] Got ', $response, "\n";
|