use Swoole/Coroutine/Channel;go(function (){  //創(chuàng)建十個(gè)信箱通道  $mailBoxes = [];  for ($i = 1;$i <= 10;$i++){    $mailBoxes[$i] = new Channel(16);  }  //模擬master 郵局調(diào)度,隨機(jī)像一個(gè)信箱投遞消息  go(function ()use($mailBoxes){    while (1){      /co::sleep(2);      $key = rand(1,10);      ($mailBoxes[$key])->push(time());    }  });  //模擬actor 實(shí)體消費(fèi)  for ($i = 1;$i <= 10;$i++){    go(function ()use($mailBoxes,$i){      while (1){        $msg = ($mailBoxes[$i])->pop();        echo "Actor {$i} recv msg : {$msg} /n";      }    });  }});

composer require easyswoole/actor=2.x-dev

namespace EasySwoole/Actor/Test;use EasySwoole/Actor/AbstractActor;use EasySwoole/Actor/ActorConfig;class RoomActor extends AbstractActor{  public static function configure(ActorConfig $actorConfig)  {    $actorConfig->setActorName('Room');  }  public function onStart()  {    //每當(dāng)一個(gè)RoomActor實(shí)體被創(chuàng)建的時(shí)候，都會(huì)執(zhí)行該回調(diào)    var_dump('room actor '.$this->actorId().' start');  }  public function onMessage($msg)  {    //每當(dāng)一個(gè)RoomActor實(shí)體收到外部消息的時(shí)候，都會(huì)執(zhí)行該回調(diào)當(dāng)    var_dump('room actor '.$this->actorId().' onmessage: '.$msg);    return 'reply at '.time();  }  public function onExit($arg)  {     //每當(dāng)一個(gè)RoomActor實(shí)體退出的時(shí)候，都會(huì)執(zhí)行該回調(diào)    var_dump('room actor '.$this->actorId().' exit at arg: '.$arg);    return 'exit at '.time();  }  protected function onException(/Throwable $throwable)  {    //每當(dāng)一個(gè)RoomActor出現(xiàn)異常的時(shí)候，都會(huì)執(zhí)行該回調(diào)    var_dump($throwable->getMessage());  }}

use EasySwoole/Actor/Actor;use EasySwoole/Actor/Test/RoomActor;use EasySwoole/Actor/ProxyProcess;Actor::getInstance()->register(RoomActor::class);$list = Actor::getInstance()->generateProcess();foreach ($list['proxy'] as $proxy){  /** @var ProxyProcess $proxy */  $proxy->getProcess()->start();}foreach ($list['worker'] as $actors){  foreach ($actors as $actorProcess){    /** @var ProxyProcess $actorProcess */    $actorProcess->getProcess()->start();  }}while($ret = /Swoole/Process::wait()) {  echo "PID={$ret['pid']}/n";}

use EasySwoole/Actor/Actor;use EasySwoole/Actor/Test/RoomActor;Actor::getInstance()->register(RoomActor::class);go(function (){  $actorId = RoomActor::client()->create('create arg1');  var_dump($actorId);  /co::sleep(3);  var_dump(RoomActor::client()->send($actorId,'this is msg'));  /co::sleep(3);  var_dump(RoomActor::client()->exit($actorId,'this is exit arg'));  /co::sleep(3);  RoomActor::client()->create('create arg2');  /co::sleep(3);  RoomActor::client()->create('create arg3');  /co::sleep(3);  var_dump(RoomActor::client()->sendAll('sendAll msg'));  /co::sleep(3);  var_dump(RoomActor::client()->status());  /co::sleep(3);  var_dump(RoomActor::client()->exitAll('sendAll exit'));});

php test.php string(40) "room actor 00101000000000000000001 start"string(57) "room actor 00101000000000000000001 onmessage: this is msg"string(64) "room actor 00101000000000000000001 exit at arg: this is exit arg"string(40) "room actor 00101000000000000000002 start"string(40) "room actor 00103000000000000000001 start"string(57) "room actor 00101000000000000000002 onmessage: sendAll msg"string(57) "room actor 00103000000000000000001 onmessage: sendAll msg"string(60) "room actor 00101000000000000000002 exit at arg: sendAll exit"string(60) "room actor 00103000000000000000001 exit at arg: sendAll exit"

php test2.php string(23) "00101000000000000000001"string(19) "reply at 1559623925"string(18) "exit at 1559623928"bool(true)array(3) { [1]=> int(1) [2]=> int(0) [3]=> int(1)}bool(true)