swrpc是一個基于swoole開發(fā)的高性能rpc包，swrpc提供了注冊發(fā)現(xiàn)，鏈路追蹤，中間件等等功能，可以很容易集成到第三方框架，如laravel，yii等等。

功能

• 支持多進程模式或協(xié)程模式
• 支持同步，異步調(diào)用
• 支持自定義中間件
• 支持服務端按類提供對外服務
• 支持鏈路追蹤
• 支持注冊服務發(fā)現(xiàn)
• 支持客戶端負載均衡，包含隨機，權(quán)重兩種模式
• 支持自定義日志，包協(xié)議，序列化方式等等

安裝

php composer.phar require wuzhc/swprc ~1.0 -vvv

快速體驗

假設我們User和School兩個模塊，為了獲得用戶學校名稱，我們需要在User模塊發(fā)起rpc請求調(diào)用School模塊的服務。

School模塊

use Swrpc\LogicService;
class SchoolService extends LogicService 
{
    public function getUserSchool($userID) {
        $name = $userID == 123 ? '火星' : '水星';
        return $name.'學校';
    }    
}

School模塊將作為rpc服務端，對外提供服務，啟動如下：

namespace SwrpcTests;
use Swrpc\Server;

$basePath = dirname(dirname(__FILE__));
require_once $basePath . "/vendor/autoload.php";

$options = [
    'enable_coroutine' => true,
    'pid_file'         => __DIR__ . '/swrpc.pid',
];
$server = new Server('School_Module', '127.0.0.1', 9501, 1, $options);
$server->addService(\SwrpcTests\services\SchoolService::class); 
$server->start();

將SchoolService添加到server，server會自動檢索類中所有可用的public方法。

User模塊

User模塊作為客戶端，調(diào)用School模塊服務如下

namespace SwrpcTests;
use Swrpc\Request;
use Swrpc\LogicService;
use Swrpc\Client;

class UserService extends LogicService
{
    public function getUserSchoolName()
    {
        $userID = 123;
        $module = 'School_Module'; //請求目標模塊名稱，需要和服務端定義的一致
        $client = Client::create($module, '127.0.0.1', 9501);
        return $client->send(Request::create('\SwrpcTests\services\SchoolService_getUserSchool', [$userID]));
    }
}

//調(diào)用
echo UserService::factory()->getUserSchoolName();

注意：

• Request.method 為服務類命名 + 下劃線 + 方法名，例如上面的\SwrpcTests\services\SchoolService_getUserSchool，如果服務類有命名空間，記得一定要帶上命名空間

多進程和協(xié)程模式

多進程或協(xié)程模式需要和swoole配置一致，具體參考swoole配置

多進程模式

創(chuàng)建10進程來處理請求

$options = [
    'worker_num'       => 10
    'pid_file'         => __DIR__ . '/swrpc.pid',
];
$server = new Server('School_Module', '127.0.0.1', 9501, 1, $options);

協(xié)程模式

目前swrpc協(xié)程模式是運行在單進程的

$options = [
    'enable_coroutine' => true,
    'pid_file'         => __DIR__ . '/swrpc.pid',
];
$server = new Server('School_Module', '127.0.0.1', 9501, 1, $options);

同步調(diào)用和異步調(diào)用

在客戶端發(fā)起同步調(diào)用，客戶端會一直等待服務端返回結(jié)果

$client = \Swrpc\Client::create($module, '127.0.0.1', 9501);
return $client->send(SyncRequest::create('SchoolService_getUserSchool', [$userID]));

在客戶端發(fā)起異步調(diào)用，客戶端會立馬得到響應結(jié)果，請求將被swoole的task進程處理

$client = \Swrpc\Client::create($module, '127.0.0.1', 9501);
return $client->send(AsyncRequest::create('SchoolService_getUserSchool', [$userID]));

自定義中間件

中間件允許程序可以對請求進行前置操作和后置操作，底層使用了責任鏈設計模式，所以為了執(zhí)行下一個中間件，必須返回$next($request)，如果想提前返回，則返回結(jié)果必須是Swrpc\Response類型

//中間件除了用匿名函數(shù)定義，還可以用實現(xiàn)Swrpc\Middlewares\MiddlewareInterface接口的類
$middleware = function (\Swrpc\Request $request, Closure $next) {
    $start = microtime(true); //前置操作，記錄請求開始時間
    $result = $next($request);
    echo '耗時：'.(microtime(true) - $start).PHP_EOL; //后置操作，記錄請求結(jié)束時間，從而計算請求耗時
    return $result; //繼續(xù)下個中間件的處理
};
$server = new Server('School_Module', '127.0.0.1', 9501, 1, $options);
$server->addService(SchoolService::class); 
$server->addMiddleware($middleware); //添加中間件
$server->start();

如果要提前中止中間件，可以提前在匿名函數(shù)或類方法中返回\Swrpc\Response對象，如下

$middleware = function (\Swrpc\Request $request, Closure $next) {
    if (empty($request->getParams())) {
        return \Swrpc\Response::error('參數(shù)不能為空'); //提前返回，必須是Response類型
    }   
    return $next($request); 
};

服務端按類提供對外服務

從上面的例子中，我們把SchoolService整個類添加的server中，這樣server就能對外提供SchoolService類所有public方法的功能。

$server = new Server('School_Module', '127.0.0.1', 9501, 1, $options);
$server->addService(SchoolService::class); //提供SchoolService所有public方法功能
$server->addService(AreaService::class); //提供AreaService所有public方法功能
$server->start();

客戶端使用參考上面的快速體驗

注冊服務發(fā)現(xiàn)

如果服務端啟動的時候有設置注冊中心，則啟動成功會自動向注冊中心注冊服務端地址。目前swrpc提供了Consul作為注冊中心，使用如下

$server = new Server('School_Module', '127.0.0.1', 9501, 1, $options);
$server->addRegister(new Consul());
$server->addService(SchoolService::class); 
$server->start();

如上，使用Consul作為服務的注冊中心，通過http://127.0.0.1:8500可以查看注冊信息，如果想用etcd等其他注冊中心，只要實現(xiàn)Swrpc\Middlewares\RegisterInterface接口即可，然后在通過$server->addRegister()添加到server

客戶端負載均衡

如果服務端啟動多個節(jié)點，例如School模塊啟動3個節(jié)點，并且注冊到了注冊中心，那么我們可以從注冊中心獲取所有服務端節(jié)點信息，然后做一些策略處理。

$register = new Consul();
$client = \Swrpc\Client::createBalancer('School_Module', $register, \Swrpc\Client::STRATEGY_WEIGHT);
$result = $client->send(Request::create('SchoolService_getUserSchool', [$userID]);

目前swrpc提供兩種簡單策略模式，\Swrpc\Client::STRATEGY_WEIGHT權(quán)重模式，\Swrpc\Client::STRATEGY_RANDOM隨機模式

鏈路追蹤

當我們的服務非常多并且需要互相調(diào)用時候，如果其中某個調(diào)用失敗，會導致我們得不到我們想要的結(jié)果，而要調(diào)試出是哪個環(huán)節(jié)出了問題也比較麻煩，可能你需要登錄每臺機器看下有沒有錯誤日志，或者看返回的錯誤信息是哪個服務提供的。鏈路追蹤記錄了整個調(diào)用鏈過程，如果某個環(huán)節(jié)出錯，我們可以快速從調(diào)用鏈得到調(diào)用中斷地方。

class UserService extends LogicService
{
    public function getUserSchoolName()
    {
        $userID = 123;
        $module = 'School_Module'; //請求目標模塊名稱，需要和服務端定義的一致
        $client = Client::create($module, '127.0.0.1', 9501);
        return $client->send(Request::create('SchoolService_getUserSchool', [$userID], $this->getTracerContext(__FUNCTION__))); //getTracerContext()用于提供追蹤上下文
    }
}

$users = UserService::factory()
    ->setModule('User_Module') //當前模塊，用于調(diào)用鏈的起點
    ->setTracerUrl('http://127.0.0.1:9411/api/v2/spans') //zipkin鏈路追蹤地址
    ->getUserSchoolName();

如圖，User_Module調(diào)用Class_Module，Class_Module又去調(diào)用School_Module

每個調(diào)用還記錄響應結(jié)果

自定義日志處理器

默認使用Monolog/Logger作為日志處理器，日志信息會輸出到控制臺?？筛鶕?jù)自己需求覆蓋默認處理器，只要日志類 實現(xiàn)Psr\Log\LoggerInterface即可

use Swrpc\Server;
use Monolog\Handler\StreamHandler;
use Monolog\Logger;

$logger = new Logger('swrpc');
$logger->pushHandler(new StreamHandler(fopen('xxxx.log','w+'), Logger::DEBUG));

$server = new Server('127.0.0.1', 9501, ['enable_coroutine'=>true]);
$server->addService(UserService::class);
$server->addLogger($logger); //覆蓋默認日志處理器
$server->start();

序列化方式

默認使用固定頭+包體來解決tcp粘包問題，默認配置為'package_length_type' => 'N','package_body_offset' => 4?默認序列化數(shù)據(jù)會使用serialize()，如果swoole版本在4.5以上的自動使用swoole_substr_unserialize()，可以實現(xiàn)的類來覆蓋默認配置，只要實現(xiàn)src/Packer/PackerInterface即可，注意服務端和客戶端需要使用一樣的協(xié)議，否則解析不了。

use Swrpc\Server;

$packer = new \Swrpc\Packer\SerializeLengthPacker();
$server = new Server('127.0.0.1', 9501, ['enable_coroutine'=>true]);
$server->addService(UserService::class); 
$server->addPacker($packer); //覆蓋默認值

安全證書配置

參考：https://wiki.swoole.com/#/server/setting?id=ssl_cert_file

服務端

$options = [
    'ssl_cert_file' => __DIR__.'/config/ssl.crt',
    'ssl_key_file'  => __DIR__.'/config/ssl.key',
    'pid_file'      => __DIR__ . '/swrpc.pid',
];
$server = new Server('School_Module', '127.0.0.1', 9501, $options, SWOOLE_PROCESS, SWOOLE_SOCK_TCP | SWOOLE_SSL);
$server->addService(SchoolService::class); 
$server->start();

注意：

• 文件必須為?PEM?格式，不支持?DER?格式，可使用?openssl?工具進行轉(zhuǎn)換

測試

使用phpuint實現(xiàn)的簡單測試案例，配置文件phpunit.xml

php phpunit.phar tests --debug

phpunit 測試報告

Client (SwrpcTests\Client)
 [x] Client connect
 [x] Client sync request
 [x] Client async request

Packer (SwrpcTests\Packer)
 [x] Serialize length pack
 [x] Serialize lenght unpack
 [x] Serialize eof pack
 [x] Serialize eof unpack

Server (SwrpcTests\Server)
 [x] Server register to consul
 [x] Server unregister from consul
 [x] Server add service
 [x] Server add middleware