ReadyScheduler
Easyswoole 基礎組件1.8.7版本起,提供了一個基于Swoole Table實現的就緒計劃程序,用于解決主服務啟動時,部分子服務未就緒問題。
基礎測試使用
namespace EasySwoole\Component\Tests;
use EasySwoole\Component\ReadyScheduler;
use PHPUnit\Framework\TestCase;
use Swoole\Coroutine;
class ReadySchedulerTest extends TestCase
{
function testNormal()
{
ReadyScheduler::getInstance()->addItem('worker');
ReadyScheduler::getInstance()->addItem('rpc');
ReadyScheduler::getInstance()->addItem('fastCache');
go(function (){
Coroutine::sleep(1);
ReadyScheduler::getInstance()->ready('worker');
ReadyScheduler::getInstance()->ready('rpc');
});
$this->assertEquals(false,ReadyScheduler::getInstance()->waitReady(['rpc','worker'],0.1));
$this->assertEquals(true,ReadyScheduler::getInstance()->waitReady('rpc'));
$this->assertEquals(true,ReadyScheduler::getInstance()->waitReady(['rpc','worker']));
$this->assertEquals(false,ReadyScheduler::getInstance()->waitReady(['rpc','worker','fastCache'],1.1));
}
}
EasySwoole服務中使用
以Http服務作為基礎例子
namespace EasySwoole\EasySwoole;
use EasySwoole\Component\ReadyScheduler;
use EasySwoole\EasySwoole\Swoole\EventRegister;
use EasySwoole\EasySwoole\AbstractInterface\Event;
use EasySwoole\Http\Request;
use EasySwoole\Http\Response;
use Swoole\Coroutine;
class EasySwooleEvent implements Event
{
public static function initialize()
{
// TODO: Implement initialize() method.
date_default_timezone_set('Asia/Shanghai');
}
public static function mainServerCreate(EventRegister $register)
{
/*
* 主進程初始化table
*/
ReadyScheduler::getInstance();
/*
* 假設,服務啟動的時候,依賴 serviceOne,serviceTwo 兩個服務,例如鏈接第三方api等。
* 在服務未就緒的時候,我們不希望本機器開始對外服務
*/
$register->add($register::onWorkerStart,function ($serv, $workerId){
if($workerId == 0){
/*
* 若不是強制準備,請注意addItem,unready,ready實現方法
*/
Coroutine::sleep(3);
ReadyScheduler::getInstance()->ready('serviceOne',true);
var_dump('r1');
}else if($workerId == 1){
Coroutine::sleep(4);
ReadyScheduler::getInstance()->ready('serviceTwo',true);
var_dump('r2');
}
});
}
public static function onRequest(Request $request, Response $response): bool
{
/*
* 鏈接進來的時候,判斷依賴的服務是否就緒,等待時間為1s (tcp,ws服務也同理)
* 在服務未就緒的時候,我們先拒絕服務
*/
if(!ReadyScheduler::getInstance()->waitReady(['serviceOne','serviceTwo'],1.0)){
$response->write('not ready,try again');
return false;
}
return true;
}
public static function afterRequest(Request $request, Response $response): void
{
}
}