phluxor / phluxor-remote
remoting library for phluxor / actor model
Fund package maintenance!
ytake
Requires
- php: ^8.3
- google/protobuf: 3.25.4
- phluxor/phluxor: ^0.1.10
- phluxor/phluxor-websocket: ^0.1.5
Requires (Dev)
- phpstan/phpstan: ^1.10.67
- phpunit/phpunit: ^10.5.11
- slevomat/coding-standard: ^8.15.0
- squizlabs/php_codesniffer: ^3.10.1
- swoole/ide-helper: ^5.0.0
Suggests
- ext-opentelemetry: Automatic instrumentation with PHP requires at least PHP 8.0
- ext-protobuf: serialization with protobuf
README
About
Phluxor Remoteは、Phluxorアクターシステムを活用したリモートアクターシステムを作成するためのライブラリです。
Phluxor Remote is a library that allows you to create remote actor systems in Phluxor.
It is inspired by the Proto.Remote.
with Phluxor Remote you can create a remote actor system that can communicate with other actor systems over network.
Phluxor Remote uses Swoole.
Between the two nodes, use the ProtoBuf
serialization format.
Websocket is used as the transport layer.
Usage
Install
$ composer require phluxor/phluxor-remote
Node1
<?php require_once __DIR__ . '/vendor/autoload.php'; use Phluxor\ActorSystem; use Phluxor\Remote\Config; use Phluxor\Remote\Kind; use Phluxor\Remote\Remote; use Test\ProtoBuf\HelloRequest; use Test\ProtoBuf\HelloResponse; \Swoole\Coroutine\run(function () { \Swoole\Coroutine\go(function () { $system = ActorSystem::create(); $config = new Config('localhost', 50053, Config::withUseWebSocket(true)); $remote = new Remote($system, $config); $remote->start(); $props = ActorSystem\Props::fromFunction( new ActorSystem\Message\ReceiveFunction( function (ActorSystem\Context\ContextInterface $context) { $message = $context->message(); if ($message instanceof HelloRequest) { $context->respond(new HelloResponse([ 'Message' => 'Hello from remote node', ])); } } ) ); $system->root()->spawnNamed($props, 'hello'); }); });
Node2
<?php require_once __DIR__ . '/vendor/autoload.php'; use Phluxor\ActorSystem; use Phluxor\Remote\Config; use Phluxor\Remote\Kind; use Phluxor\Remote\Remote; use Test\ProtoBuf\HelloRequest; use Test\ProtoBuf\HelloResponse; \Swoole\Coroutine\run(function () { \Swoole\Coroutine\go(function () { $system = ActorSystem::create(); $config = new Config('localhost', 50052, Config::withUseWebSocket(true)); $remote = new Remote($system, $config); $remote->start(); $future = $system->root()->requestFuture( new ActorSystem\Ref(new ActorSystem\ProtoBuf\Pid([ 'address' => 'localhost:50053', 'id' => 'hello', ])), new HelloRequest(), 1 ); $r = $future->result()->value(); $r->getMessage(); // Hello from remote node! }); });