pangou/fifo

a php lib for fifo

单进程, _(*1)

<?php 

require __DIR__ . '/../vendor/autoload.php';

$protocol = new Pangou\Fifo\Protocol\LengthProtocol();

$write = new Pangou\Fifo\Fifo($protocol, '/tmp/serv.fifo', '0666', false);
$read = new Pangou\Fifo\Fifo($protocol, '/tmp/serv.fifo', '0666', true);
$write -> write('hello, fifo!!!');
echo $read -> read();

多进程, _(*2)

<?php 

require __DIR__ . '/../vendor/autoload.php';

$pid = pcntl_fork();

if ($pid == -1) {
    exit('fork error');
} else if ($pid == 0) {
    # child

    $protocol = new Pangou\Fifo\Protocol\LengthProtocol();
    $read = new Pangou\Fifo\Fifo($protocol, '/tmp/serv.fifo', '0666', true);
    echo $read -> read(), "\n";
    echo "child over\n";
} else if ($pid > 0) {
    # parent
    $protocol = new Pangou\Fifo\Protocol\LengthProtocol();
    $write = new Pangou\Fifo\Fifo($protocol, '/tmp/serv.fifo', '0666', false);
    $write -> write('hello, fifo');
    pcntl_wait($status);
    echo "parent over\n";
}

阻塞与非阻塞, _(*3)

<?php 

require __DIR__ . '/../vendor/autoload.php';

$protocol = new Pangou\Fifo\Protocol\LengthProtocol();

$write = new Pangou\Fifo\Fifo($protocol, '/tmp/serv.fifo', '0666', false);
$read = new Pangou\Fifo\Fifo($protocol, '/tmp/serv.fifo', '0666', true);

var_dump($read -> setBlock(0));  // 非阻塞
var_dump($read -> setBlock(1));  // 阻塞
var_dump($read -> read());