0

我已经用 RabbitMQ RPC 消息替换了对 API 的 CURL 调用。rabbitmq示例一切正常

仍然看起来实现是错误的,因为每个请求都打开连接、打开通道、发送消息、等待响应、获取响应、关闭通道并关闭连接。

如何使用 PHP 实现 RabbitMQ RPC 调用以对每个请求使用相同的连接?

我使用https://github.com/videlalvaro/php-amqplib

我的实现看起来像这样https://gist.github.com/fordnox/fa41e1233a207ec5416c

像这样使用它:

$rpc = new RabbitRpc([/* config array */]);
$result = $rpc->callOnServer(1, ["foo":"bar"]);
4

0 回答 0