ReadyScheduler

Easyswoole 基础组件1.8.7版本起，提供了一个基于Swoole Table实现的就绪计划程序，用于解决主服务启动时，部分子服务未就绪问题。

基础测试使用

  1. namespace EasySwoole\Component\Tests;
  3. use EasySwoole\Component\ReadyScheduler;
  4. use PHPUnit\Framework\TestCase;
  5. use Swoole\Coroutine;
  7. class ReadySchedulerTest extends TestCase
  8. {
  9.     function testNormal()
  10.     {
  11.         ReadyScheduler::getInstance()->addItem('worker');
  12.         ReadyScheduler::getInstance()->addItem('rpc');
  13.         ReadyScheduler::getInstance()->addItem('fastCache');
  15.         go(function (){
  16.             Coroutine::sleep(1);
  17.             ReadyScheduler::getInstance()->ready('worker');
  18.             ReadyScheduler::getInstance()->ready('rpc');
  19.         });
  20.         $this->assertEquals(false,ReadyScheduler::getInstance()->waitReady(['rpc','worker'],0.1));
  21.         $this->assertEquals(true,ReadyScheduler::getInstance()->waitReady('rpc'));
  22.         $this->assertEquals(true,ReadyScheduler::getInstance()->waitReady(['rpc','worker']));
  23.         $this->assertEquals(false,ReadyScheduler::getInstance()->waitReady(['rpc','worker','fastCache'],1.1));
  24.     }
  25. }

EasySwoole服务中使用

以Http服务作为基础例子

  1. namespace EasySwoole\EasySwoole;
  3. use EasySwoole\Component\ReadyScheduler;
  4. use EasySwoole\EasySwoole\Swoole\EventRegister;
  5. use EasySwoole\EasySwoole\AbstractInterface\Event;
  6. use EasySwoole\Http\Request;
  7. use EasySwoole\Http\Response;
  8. use Swoole\Coroutine;
  10. class EasySwooleEvent implements Event
  11. {
  13.     public static function initialize()
  14.     {
  15.         // TODO: Implement initialize() method.
  16.         date_default_timezone_set('Asia/Shanghai');
  17.     }
  19.     public static function mainServerCreate(EventRegister $register)
  20.     {
  21.         /*
  22.          * 主进程初始化table
  23.          */
  24.         ReadyScheduler::getInstance();
  25.         /*
  26.          * 假设，服务启动的时候，依赖 serviceOne，serviceTwo 两个服务，例如链接第三方api等。
  27.          * 在服务未就绪的时候，我们不希望本机器开始对外服务
  28.          */
  29.         $register->add($register::onWorkerStart,function ($serv, $workerId){
  30.             if($workerId == 0){
  31.                 /*
  32.                  * 若不是强制准备，请注意addItem,unready，ready实现方法
  33.                  */
  34.                 Coroutine::sleep(3);
  35.                 ReadyScheduler::getInstance()->ready('serviceOne',true);
  36.                 var_dump('r1');
  37.             }else if($workerId == 1){
  38.                 Coroutine::sleep(4);
  39.                 ReadyScheduler::getInstance()->ready('serviceTwo',true);
  40.                 var_dump('r2');
  41.             }
  42.         });
  43.     }
  45.     public static function onRequest(Request $request, Response $response): bool
  46.     {
  47.         /*
  48.          * 链接进来的时候，判断依赖的服务是否就绪,等待时间为1s (tcp，ws服务也同理)
  49.          * 在服务未就绪的时候，我们先拒绝服务
  50.         */
  51.         if(!ReadyScheduler::getInstance()->waitReady(['serviceOne','serviceTwo'],1.0)){
  52.             $response->write('not ready,try again');
  53.             return false;
  54.         }
  55.         return true;
  56.     }
  58.     public static function afterRequest(Request $request, Response $response): void
  59.     {
  61.     }
  62. }