Реализация модели параллелизма субъектов с помощью swool в PHP

Что такое актер?

Для Php actor может быть незнакомым, и студенты, написавшие Java, будут знакомы с ним. В Java всегда была концепция потока (хотя в PHP есть поток, он не популярен). Это параллельная модель без общей памяти. Данные в каждом акторе существуют независимо. Взаимодействие между участниками планируется в форме передачи сообщений, а актер-это очень абстрактная модель программирования. Очень подходит для игровой, аппаратной индустрии.

Весь процесс и почтовый ящик

Благодаря swool 4. X мы можем быстро реализовать планирование режима почтового ящика на основе сотрудничества и канала Вулфа. Код моделирования выглядит следующим образом:

use Swoole\Coroutine\Channel;
go(function (){
    //Create ten mailbox channels
    $mailBoxes = [];
    for ($i = 1;$i <= 10;$i++){
        $mailBoxes[$i] = new Channel(16);
    }
    //Simulate master post office scheduling, randomly send messages like a mailbox
    go(function ()use($mailBoxes){
        while (1){
            \co::sleep(2);
            $key = rand(1,10);
            ($mailBoxes[$key])->push(time());
        }
    });
    //Simulated actor entity consumption
    for ($i = 1;$i <= 10;$i++){
        go(function ()use($mailBoxes,$i){
            while (1){
                $msg = ($mailBoxes[$i])->pop();
                echo "Actor {$i} recv msg : {$msg} \n";
            }
        });
    }
});

Над выводом выполнения кода:

php test.php 
Actor 8 recv msg : 1559622691 
Actor 10 recv msg : 1559622693 
Actor 1 recv msg : 1559622695 
Actor 5 recv msg : 1559622697

Когда pip не обнаружит данных, канал сотрудничества автоматически откажется от права на выполнение (подробности см. в разделе Планирование сотрудничества swool).

Библиотека актеров

Основываясь на вышеприведенном принципе, мы реализуем многопроцессорную распределенную библиотеку участников совместного процесса

composer require easyswoole/actor=2.x-dev

Мы полагаемся на библиотеку разработчиков для тестирования, а производство может полагаться на стабильную версию.

Взаимосвязь процессов

В модели актора easyswool есть две группы процессов, одна из которых является прокси-процессом, который используется для реализации внешнего обслуживания актора, другая-рабочий процесс. Связь между прокси-процессом и рабочим процессом осуществляется через unixsock, и экземпляры субъектов равномерно распределены в рабочем процессе.

Пример кода

Например, в комнате чата мы можем определить модель комнаты.

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()
    {
        //Whenever a roomactor entity is created, the callback is executed
        var_dump('room actor '.$this->actorId().' start');
    }
    public function onMessage($msg)
    {
        //Whenever a roomactor entity receives an external message, the callback is executed when
        var_dump('room actor '.$this->actorId().' onmessage: '.$msg);
        return 'reply at '.time();
    }
    public function onExit($arg)
    { 
        //Whenever a roomactor entity exits, the callback is executed
        var_dump('room actor '.$this->actorId().' exit at arg: '.$arg);
        return 'exit at '.time();
    }
    protected function onException(\Throwable $throwable)
    {
        //Whenever an exception occurs to a roomactor, the callback is executed
        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";
}

Создайте тестовый сценарий cli

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)

Более подробную информацию можно найти на веб-сайте проекта easysool/Если вам нравится легкий классный проект, вы можете начать https://github.com/easy-swool…