Rpc-Client

在服務端章節已注冊商品及公共服務。

控制器調用

<?php

namespace App\HttpController;

use EasySwoole\Http\AbstractInterface\Controller;
use EasySwoole\Rpc\Protocol\Response;

class Index extends Controller
{
    public function index()
    {
        // 如果在同server中 直接用保存的rpc實例調用即可
        // 如果不是需要重新new一個rpc 注意config的配置 節點管理器 以及所在ip是否能被其他服務廣播到 如果不能請調整其他服務的廣播地址
        $config = new \EasySwoole\Rpc\Config();
        $rpc = new \EasySwoole\Rpc\Rpc($config);

        $ret = [];
        $client = $rpc->client();
        // client 全局參數
        $client->setClientArg([1,2,3]);
        /**
         * 調用商品列表
         */
        $ctx1 = $client->addRequest('Goods.GoodsModule.list');
        // 設置請求參數
        $ctx1->setArg(['a','b','c']);
        // 設置調用成功執行回調
        $ctx1->setOnSuccess(function (Response $response) use (&$ret) {
            $ret[] = [
                'list' => [
                    'msg' => $response->getMsg(),
                    'result' => $response->getResult()
                ]
            ];
        });

        /**
         * 調用信箱公共
         */
        $ctx2 = $client->addRequest('Common.CommonModule.mailBox');
        // 設置調用成功執行回調
        $ctx2->setOnSuccess(function (Response $response) use (&$ret) {
            $ret[] = [
                'mailBox' => [
                    'msg' => $response->getMsg(),
                    'result' => $response->getResult()
                ]
            ];
        });

        /**
         * 獲取系統時間
         */
        $ctx2 = $client->addRequest('Common.CommonModule.serverTime');
        // 設置調用成功執行回調
        $ctx2->setOnSuccess(function (Response $response) use (&$ret) {
            $ret[] = [
                'serverTime' => [
                    'msg' => $response->getMsg(),
                    'result' => $response->getResult()
                ]
            ];
        });

        // 執行調用
        $client->exec();
        $this->writeJson(200, $ret);
    }
}