使用ThinkPHP6和Swoole开发的RPC服务实现高效任务处理

composer require swoole/swoole

<?php
namespace apppccontroller;

use SwooleCoroutineServerCoServer;
use SwooleCoroutineServerConnection;
use thinkApp;
use thinkContainer;

class RpcServer
{
    /**
     * @var CoServer
     */
    protected $server;

    public function __construct(App $app)
    {
        $this->server = new CoServer('0.0.0.0', 9502);

        $this->server->handle(function (Connection $conn, $data){
            $container = Container::getInstance();
            $response = $container->invoke([$this, 'processData'], [$data]);

            $conn->send(json_encode($response));
        });
    }

    public function start()
    {
        $this->server->start();
    }

    protected function processData($data)
    {
        // 根据请求数据进行具体的处理逻辑
        // 这里只是一个示例，具体的逻辑根据实际需求编写
        $result = 'Hello, ' . $data['name'] . '!';

        return $result;
    }
}

<?php
namespace apppccontroller;

use thinkApp;
use thinkContainer;
use thinkController;
use thinkacadeHttp;

class RpcClient extends Controller
{
    /**
     * @var string
     */
    protected $serverUrl = 'http://127.0.0.1:9502';

    public function index(App $app)
    {
        $data = [
            'name' => 'Tom',
        ];

        $response = Http::post($this->serverUrl, $data);

        $result = json_decode($response->getBody(), true);

        // 处理返回结果
        // 这里只是一个示例，具体的处理逻辑根据实际需求编写
        return $result;
    }
}