PHP 基于 SW-X 框架，搭建RPC微服务支持

1、需要先安装Redis服务，与PHP-Redis扩展
2、需要准备2个端口，与2份SW-X框架源码，因为服务中心(http)与微服务服务端(rpc)是需要分别启动不同的服务端口。

# 进入目录
cd /www/wwwroot/swoole_web/
# 安装服务中心-web组件
php sw-x rpc start

# 启动HTTP服务后台运行
php sw-x start http -d

# 进入目录
cd /www/wwwroot/swoole_rpc/
# 启动RPC服务[不退后台运行]
php sw-x start rpc

[
    // +-----------------------------
    // | 服务请求统计相关
    // +-----------------------------
    // 是否开启统计
    'chat_status' => true,
    // 统计记录的Redis连接池标识
    'chat_redis_driver' => 'default',
    // 统计记录保留天数
    'chat_days' => 14,
];

<?php
// 微服务-同步调用演示
namespace app\rpc\order;
use x\controller\Rpc;
class test extends Rpc{
    // 对应 order/test->run 服务
    public function run() {
        // 可以这样获取请求头
        $headers = $this->headers();
        // 可以这样获取请求参数
        $param = $this->param();
        // 可以return值就是调用结果值
        return $param;
    }
}

<?php
namespace app\index\controller;
use think\Controller;
class Index extends Controller{
    public function index() {
        // 调用微服务客户端
        $Rpc = new \SwooleXRpc\RpcClient();
        // 请求RPC服务
        $body = $Rpc->route('order/test') // 路由地址
        ->func('run') // 方法
        ->param([ // 请求参数
            'longitude' => '113.383523',
            'latitude' => '23.131044'
        ])
        ->header(array()) // 请求头
        ->max(3) // 当RPC请求失败时，最多递归几个服务节点直至成功为止，默认1
        // ->task() // 是否投递异步任务池
        // ->callback('http://baidu.com', 'post') // 异步任务可以设置回调通知
        ->send(); // 发送请求
        // 结果集
        dump($body);
        // 状态码 == 200 == 成功
        dump($Rpc->getStatus());
        // 错误原因
        dump($Rpc->getMsg());
    }
}

<?php
// 微服务-异步调用演示
namespace app\rpc\order;
use x\controller\Rpc;
class task extends Rpc{
  // 对应 order/task->run 服务
    public function run() {
        // 可以这样获取请求参数
        $param = $this->param();
        // 记录日志，看看服务是否调用成功
        error_log(json_encode($param).PHP_EOL, 3, ROOT_PATH.'/task_test.log');
        // 可以return值就是调用结果值，如果是设置了回调通知地址，就会发送过去
        return $param;
    }
}

<?php
namespace app\index\controller;
use think\Controller;
class Index extends Controller{
    public function index() {
        // 调用微服务客户端
        $Rpc = new \SwooleXRpc\RpcClient();
        // 请求RPC服务
        $body = $Rpc->route('order/task') // 路由地址
        ->func('run') // 方法
        ->param([ // 请求参数
            'longitude' => '113.383523',
            'latitude' => '23.131044'
        ])
        ->header(array()) // 请求头
        ->max(3) // 当RPC请求失败时，最多递归几个服务节点直至成功为止，默认1
        ->task() // 投递异步任务池
        ->callback('http://你的TP测试地址/index.php/callback/index', 'post') // 异步任务可以设置回调通知，如果不需要回调通知，可以不设置
        ->send(); // 发送请求
        // 结果集
        dump($body);
        // 状态码 == 200 == 成功
        dump($Rpc->getStatus());
        // 错误原因
        dump($Rpc->getMsg());
    }
}

<?php
namespace app\index\controller;
use think\Controller;
class Callback extends Controller{
  // 测试-记录异步服务调用回调通知
    public function index() {
        $param = \think\facade\Request::param();
        error_log(json_encode($param).PHP_EOL, 3, 'task_test.log');
    }
}