这次可能是最后一次到北京农行党校出差了，拍点照片留个记录

## 抵达怀柔第一晚，在荒郊野岭找到这家咖啡馆
![20230415135505.jpg](https://cdn.tyrantg.com/van/static/img/20230415135505.jpg?image_vanblog_tyrantgenesis)



## 党校内风景

![A4240A99F43B2A2819BD8EBBC6B025CF.png](https://cdn.tyrantg.com/van/static/img/a4240a99f43b2a2819bd8ebbc6b025cf.A4240A99F43B2A2819BD8EBBC6B025CF.png?image_vanblog_tyrantgenesis)

![81498E258EF0912A76CA344504862345.png](https://cdn.tyrantg.com/van/static/img/81498e258ef0912a76ca344504862345.81498E258EF0912A76CA344504862345.png?image_vanblog_tyrantgenesis)

![BFE58EBE08EE413FD170BE7A9CA0A876.png](https://cdn.tyrantg.com/van/static/img/bfe58ebe08ee413fd170be7a9ca0a876.BFE58EBE08EE413FD170BE7A9CA0A876.png?image_vanblog_tyrantgenesis)

![2BD4D05C4F484C50255BE7F2921EF0AA.png](https://cdn.tyrantg.com/van/static/img/2bd4d05c4f484c50255be7f2921ef0aa.2BD4D05C4F484C50255BE7F2921EF0AA.png?image_vanblog_tyrantgenesis)

![1457CA5599E9B9D045BBF573D6024240.png](https://cdn.tyrantg.com/van/static/img/1457ca5599e9b9d045bbf573d6024240.1457CA5599E9B9D045BBF573D6024240.png?image_vanblog_tyrantgenesis)

## 最后一天，去红螺寺逛逛

![4112803E86EA826BFCAFE9688623AE19.png](https://cdn.tyrantg.com/van/static/img/4112803e86ea826bfcafe9688623ae19.4112803E86EA826BFCAFE9688623AE19.png?image_vanblog_tyrantgenesis)

![64C5DBEEC6BEB01505EA310AEC45EE09.png](https://cdn.tyrantg.com/van/static/img/64c5dbeec6beb01505ea310aec45ee09.64C5DBEEC6BEB01505EA310AEC45EE09.png?image_vanblog_tyrantgenesis)

![CFE61713E0B92D709150BFD8A520B14D.png](https://cdn.tyrantg.com/van/static/img/cfe61713e0b92d709150bfd8a520b14d.CFE61713E0B92D709150BFD8A520B14D.png?image_vanblog_tyrantgenesis)

![16EBD32D8107425038D319C7B19D521E.png](https://cdn.tyrantg.com/van/static/img/16ebd32d8107425038d319c7b19d521e.16EBD32D8107425038D319C7B19D521E.png?image_vanblog_tyrantgenesis)

![76A652D0B392CE0F9ABBD710784EF654.png](https://cdn.tyrantg.com/van/static/img/76a652d0b392ce0f9abbd710784ef654.76A652D0B392CE0F9ABBD710784EF654.png?image_vanblog_tyrantgenesis)

![64E43F73815E48AE149BD5B57189CBC7.png](https://cdn.tyrantg.com/van/static/img/64e43f73815e48ae149bd5b57189cbc7.64E43F73815E48AE149BD5B57189CBC7.png?image_vanblog_tyrantgenesis)

![D3BEC4A1E89ED02D0EAB01688BBCFD31.png](https://cdn.tyrantg.com/van/static/img/d3bec4a1e89ed02d0eab01688bbcfd31.D3BEC4A1E89ED02D0EAB01688BBCFD31.png?image_vanblog_tyrantgenesis)

![E839915C7A6F5461A5C5485437D8600C.png](https://cdn.tyrantg.com/van/static/img/e839915c7a6f5461a5c5485437d8600c.E839915C7A6F5461A5C5485437D8600C.png?image_vanblog_tyrantgenesis)

![232D072873EC7A8F4DD15575CFC3FA3C.png](https://cdn.tyrantg.com/van/static/img/232d072873ec7a8f4dd15575cfc3fa3c.232D072873EC7A8F4DD15575CFC3FA3C.png?image_vanblog_tyrantgenesis)

![FB2563F6CA3A5284A2E1A391D38A8246.png](https://cdn.tyrantg.com/van/static/img/fb2563f6ca3a5284a2e1a391d38a8246.FB2563F6CA3A5284A2E1A391D38A8246.png?image_vanblog_tyrantgenesis)

## 在故宫、天安门转转

![F7D8F297F25E69AD7E016AF83515AD76.png](https://cdn.tyrantg.com/van/static/img/f7d8f297f25e69ad7e016af83515ad76.F7D8F297F25E69AD7E016AF83515AD76.png?image_vanblog_tyrantgenesis)

![49B76B6D831A28FFF87C7C8CBC3D7D57.png](https://cdn.tyrantg.com/van/static/img/49b76b6d831a28fff87c7c8cbc3d7d57.49B76B6D831A28FFF87C7C8CBC3D7D57.png?image_vanblog_tyrantgenesis)

![0721941FF722DD1A97198F413AC57818.png](https://cdn.tyrantg.com/van/static/img/0721941ff722dd1a97198f413ac57818.0721941FF722DD1A97198F413AC57818.png?image_vanblog_tyrantgenesis)

![C03415A2C40BA6D029C3A93DF9D106C8.png](https://cdn.tyrantg.com/van/static/img/c03415a2c40ba6d029c3a93df9d106c8.C03415A2C40BA6D029C3A93DF9D106C8.png?image_vanblog_tyrantgenesis)

农行研修行记 Part.02 北京

```text
https://pasteme.tyrantg.com/xxxxxx/sh5lpuhpfgq2noar@fkGtHC

小程序：JavWan
```

JavWan海阔规则

```text
https://pasteme.tyrantg.com/xxxxxx/2mv3bevblsp7kfm3@yZTomU

小程序：Everia
```

Everia.club图片规则

```text
https://pasteme.tyrantg.com/xxxxxx/jax06bdltlugeeyv@UufCcR

小程序：Jable
```

:::warning{title="注意"}
需要代理
:::

Jable海阔规则

:::tip{title="提问"}
你是一个经验丰富的程序开发者，我需要你为我的问题提供解决思路和完整代码，我的问题是：如何给Laravel框架设计一套rpc调用
:::

答：
为了在Laravel框架中实现RPC调用，可以按照以下流程进行操作：



1. 安装依赖

在Laravel项目根目录下使用composer安装“php-amqplib/php-amqplib”依赖，用于建立与RabbitMQ的连接。

```
composer require php-amqplib/php-amqplib
```

2. 创建RabbitMQ通道

在Laravel应用程序中创建一个RabbitMQ通道，该通道将用于请求和响应。可以使用以下代码创建通道:

```php
<?php

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class RabbitMQChannel
{
    protected $connection;
    protected $channel;
    protected $callbackQueue;
    protected $response;
    protected $corrId;

    public function __construct()
    {
        $this->connection = new AMQPStreamConnection(
            'localhost',
            5672,
            'guest',
            'guest'
        );

        $this->channel = $this->connection->channel();

        list($this->callbackQueue, ,) = $this->channel->queue_declare(
            '',
            false,
            false,
            true,
            false
        );

        $this->channel->basic_consume(
            $this->callbackQueue,
            '',
            false,
            false,
            false,
            false,
            array($this, 'onResponse')
        );
    }

    public function onResponse($msg)
    {
        if ($msg->get('correlation_id') == $this->corrId) {
            $this->response = $msg->body;
        }
    }

    public function sendRequest($request)
    {
        $this->response = null;
        $this->corrId = uniqid();

        $msg = new AMQPMessage(
            $request,
            array(
                'correlation_id' => $this->corrId,
                'reply_to' => $this->callbackQueue
            )
        );

        $this->channel->basic_publish(
            $msg,
            '',
            'rpc_queue'
        );

        while (!$this->response) {
            $this->channel->wait();
        }

        return $this->response;
    }

    public function __destruct()
    {
        $this->channel->close();
        $this->connection->close();
    }
}
```

在该类中，我们建立了与RabbitMQ的连接，并创建了通道。我们还定义了响应队列

3. 创建RPC服务

在Laravel应用程序中创建一个RPC服务，该服务将使用RabbitMQ通道向远程RPC服务器发送请求并接收响应。可以使用以下代码创建一个RPC服务：

```php
<?php

class RpcService
{
    protected $rabbitMQChannel;

    public function __construct(RabbitMQChannel $rabbitMQChannel)
    {
        $this->rabbitMQChannel = $rabbitMQChannel;
    }

    public function call($methodName, $params)
    {
        $request = json_encode(array(
            'method' => $methodName,
            'params' => $params,
        ));

        $response = $this->rabbitMQChannel->sendRequest($request);

        return json_decode($response);
    }
}
```

在该类中，我们使用RabbitMQ通道发送请求，并等待响应。我们还返回解码的响应。

4. 创建RPC服务器

在Laravel应用程序中创建一个RPC服务器，该服务器将处理RPC请求并返回响应。可以使用以下代码创建一个RPC服务器：

```php
<?php

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class RpcServer
{
    protected $connection;
    protected $channel;
    protected $callbackQueue;

    public function __construct()
    {
        $this->connection = new AMQPStreamConnection(
            'localhost',
            5672,
            'guest',
            'guest'
        );

        $this->channel = $this->connection->channel();

        $this->channel->queue_declare(
            'rpc_queue',
            false,
            false,
            false,
            false
        );

        $this->channel->basic_qos(null, 1, null);

        $this->channel->basic_consume(
            'rpc_queue',
            '',
            false,
            false,
            false,
            false,
            array($this, 'onRequest')
        );
    }

    public function onRequest($request)
    {
        $request = json_decode($request->body);

        $methodName = $request->method;
        $params = $request->params;

        $result = call_user_func_array(array($this, $methodName), $params);

        $response = new AMQPMessage(
            json_encode($result),
            array(
                'correlation_id' => $request->correlation_id
            )
        );

        $request->delivery_info['channel']->basic_publish(
            $response,
            '',
            $request->get('reply_to')
        );

        $request->delivery_info['channel']->basic_ack(
            $request->delivery_info['delivery_tag']
        );
    }

    public function __destruct()
    {
        $this->channel->close();
        $this->connection->close();
    }

    public function sum($a, $b)
    {
        return $a + $b;
    }
}
```

在该类中，我们处理收到的RPC请求，并将响应返回到客户端。

5. 调用RPC服务

在应用程序中调用RPC服务，可以使用以下代码：

```php
<?php

$rabbitMQChannel = new RabbitMQChannel();
$rpcService = new RpcService($rabbitMQChannel);

$result = $rpcService->call('sum', array(10, 20));
```

在该代码中，我们创建了RabbitMQ通道用于RPC服务器通信，并创建了RPC服务。然后，我们使用RPC服务调用sum方法，并传递10和20作为参数，并等待响应。

完整代码可见于下面的代码片段：

```php
<?php

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class RabbitMQChannel
{
    protected $connection;
    protected $channel;
    protected $callbackQueue;
    protected $response;
    protected $corrId;

    public function __construct()
    {
        $this->connection = new AMQPStreamConnection(
            'localhost',
            5672,
            'guest',
            'guest'
        );

        $this->channel = $this->connection->channel();

        list($this->callbackQueue, ,) = $this->channel->queue_declare(
            '',
            false,
            false,
            true,
            false
        );

        $this->channel->basic_consume(
            $this->callbackQueue,
            '',
            false,
            false,
            false,
            false,
            array($this, 'onResponse')
        );
    }

    public function onResponse($msg)
    {
        if ($msg->get('correlation_id') == $this->corrId) {
            $this->response = $msg->body;
        }
    }

    public function sendRequest($request)
    {
        $this->response = null;
        $this->corrId = uniqid();

        $msg = new AMQPMessage(
            $request,
            array(
                'correlation_id' => $this->corrId,
                'reply_to' => $this->callbackQueue
            )
        );

        $this->channel->basic_publish(
            $msg,
            '',
            'rpc_queue'
        );

        while (!$this->response) {
            $this->channel->wait();
        }

        return $this->response;
    }

    public function __destruct()
    {
        $this->channel->close();
        $this->connection->close();
    }
}

class RpcService
{
    protected $rabbitMQChannel;

    public function __construct(RabbitMQChannel $rabbitMQChannel)
    {
        $this->rabbitMQChannel = $rabbitMQChannel;
    }

    public function call($methodName, $params)
    {
        $request = json_encode(array(
            'method' => $methodName,
            'params' => $params,
        ));

        $response = $this->rabbitMQChannel->sendRequest($request);

        return json_decode($response);
    }
}

class RpcServer
{
    protected $connection;
    protected $channel;
    protected $callbackQueue;

    public function __construct()
    {
        $this->connection = new AMQPStreamConnection(
            'localhost',
            5672,
            'guest',
            'guest'
        );

        $this->channel = $this->connection->channel();

        $this->channel->queue_declare(
            'rpc_queue',
            false,
            false,
            false,
            false
        );

        $this->channel->basic_qos(null, 1, null);

        $this->channel->basic_consume(
            'rpc_queue',
            '',
            false,
            false,
            false,
            false,
            array($this, 'onRequest')
        );
    }

    public function onRequest($request)
    {
        $request = json_decode($request->body);

        $methodName = $request->method;
        $params = $request->params;

        $result = call_user_func_array(array($this, $methodName), $params);

        $response = new AMQPMessage(
            json_encode($result),
            array(
                'correlation_id' => $request->correlation_id
            )
        );

        $request->delivery_info['channel']->basic_publish(
            $response,
            '',
            $request->get('reply_to')
        );

        $request->delivery_info['channel']->basic_ack(
            $request->delivery_info['delivery_tag']
        );
    }

    public function __destruct()
    {
        $this->channel->close();
        $this->connection->close();
    }

    public function sum($a, $b)
    {
        return $a + $b;
    }
}

$rabbitMQChannel = new RabbitMQChannel();
$rpcService = new RpcService($rabbitMQChannel);

$result = $rpcService->call('sum', array(10, 20));

var_dump($result);
```

这就是在Laravel框架中实现RPC调用的完整代码。