danog/ipc

IPC component for Amp.

Maintainers

Details

github.com/danog/ipc

Homepage

Source

Issues

Installs: 503 313

Dependents: 5

Suggesters: 0

Security: 0

Stars: 5

Watchers: 3

Forks: 5

Open Issues: 0

1.0.0 2023-02-14 13:19 UTC

Requires

Requires (Dev)

MIT ab6a5af03950e61846b36e65301e2bc278581a39

  • Daniil Gentili <daniil.woop@daniil.it>
  • Aaron Piotrowski <aaron.woop@trowski.com>
  • Stephen Coakley <me.woop@stephencoakley.com>

asyncasynchronousconcurrentmulti-threadingmulti-processing

This package is auto-updated.

Last update: 2024-11-04 17:33:51 UTC

README

Continuous Integration License

danog/ipc provides an async IPC server.

Installation

composer require danog/ipc

Example

Server:

<?php declare(strict_types=1);

require 'vendor/autoload.php';

use Amp\Ipc\Sync\ChannelledSocket;

use function Amp\async;
use function Amp\Ipc\listen;

$clientHandler = function (ChannelledSocket $socket) {
    echo "Accepted connection".PHP_EOL;

    while ($payload = $socket->receive()) {
        echo "Received $payload".PHP_EOL;
        if ($payload === 'ping') {
            $socket->send('pong');
            $socket->disconnect();
        }
    }
    echo "Closed connection".PHP_EOL."==========".PHP_EOL;
};

$server = listen(sys_get_temp_dir().'/test');
while ($socket = $server->accept()) {
    async($clientHandler, $socket);
}

Client:

<?php declare(strict_types=1);

require 'vendor/autoload.php';

use Amp\Ipc\Sync\ChannelledSocket;

use function Amp\async;
use function Amp\Ipc\connect;

$clientHandler = function (ChannelledSocket $socket) {
    echo "Created connection.".PHP_EOL;

    while ($payload = $socket->receive()) {
        echo "Received $payload".PHP_EOL;
    }
    echo "Closed connection".PHP_EOL;
};

$channel = connect(sys_get_temp_dir().'/test');

$thread = async($clientHandler, $channel);

$channel->send('ping');

$thread->await();