php fpm queue

Antrian Async PHP-FPM

Gunakan php-fpm sebagai antrian async bawaan sederhana. Berdasarkan antarmuka antrian antrian yang dapat dioperasikan Interop.

Penggunaan

composer makasim/php-fpm-queue:0.1.x-dev queue-interop/queue-interop:0.7.x-dev enqueue/dsn:0.9.x-dev

Skrip pengirim:

 <?php
# sender.php

use Makasim  PhpFpm  PhpFpmConnectionFactory ;

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

$ context = ( new PhpFpmConnectionFactory ( ' tcp://localhost:9000 ' ))-> createContext ();

$ queue = $ context -> createQueue ( ' /app/worker.php ' );
$ message = $ context -> createMessage ( ' aBody ' );

$ context -> createProducer ()-> send ( $ queue , $ message );

Skrip pekerja:

 <?php
# worker.php

use Makasim  PhpFpm  PhpFpmConnectionFactory ;

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

$ context = ( new PhpFpmConnectionFactory ( ' tcp://localhost:9000 ' ))-> createContext ();
// or
// $ context = ( new PhpFpmConnectionFactory ( 'unix:///var/run/php/php7.1-fpm.sock' )) - > createContext (); 

$ queue = $ context -> createQueue ( __FILE__ );

$ consumer = $ context -> createConsumer ( $ queue );

if ( $ message = $ consumer -> receiveNoWait ()) {
    // process message

    $ consumer -> acknowledge ( $ message );
}

Mulai PHP-FPM:

docker run -v ` pwd ` :/app -p 9000:9000 php:7.2-fpm

Kirim pesan:

php sender.php

Kredit

Terinspirasi oleh Benjamin Post menggunakan php-fpm sebagai antrian async bawaan sederhana

Lisensi

Lisensi MIT