PHP code example of fair / queue

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

fair / queue example snippets

/**
 * @var BrokerInterface $broker
 */
$message = new SomeMessageOrJob(somePayload: 'user1-job1', fairTag: 'user1');
$broker->push($message);
$message = new SomeMessageOrJob(somePayload: 'user1-job2', fairTag: 'user1');
$broker->push($message);
$message = new SomeMessageOrJob(somePayload: 'user2-job1', fairTag: 'user2');
$broker->push($message);
$message = new SomeMessageOrJob(somePayload: 'user2-job2', fairTag: 'user2');
$broker->push($message);
$message = new SomeMessageOrJob(somePayload: 'user3-job1', fairTag: 'user3');
$broker->push($message);

while (($message = $broker->pop()) !== null) {
    echo $message->getSomePayload() . "\n";
}
//Output (not same order as in input):
//user1-job1
//user2-job1
//user3-job1
//user1-job2
//user2-job2

// NOT SAFE in case of an empty queue! It would cause 100% CPU load + constant Redis instance requests
while (true) {
    $message = $broker->pop();
    echo $message->getSomePayload() . "\n";
    //sleep(1); <= a classic solution to solve the 100% CPU problem
}

// SAFE in case of an empty queue! Zero resources (both CPU + network traffic to Redis) usage during waiting
$timeout = 1.23; //seconds
while (true) {
    $message = $broker->popBlocking($timeout);
    echo $message->getSomePayload() . "\n";
}

declare(strict_types=1);

se Fair\Queue\Message\MessageInterface;
use Fair\Queue\Namer\PrefixQueueNamer;
use Fair\Queue\Serializer\PhpMessageSerializer;
use Fair\Queue\Storage\RedisStorage;
use Redis;

class SomeMessageOrJob implements MessageInterface
{
    private string $somePayload;
    private string|null $fairTag;

    public function __construct(
        string $somePayload,
        string|null $fairTag = null,
    ) {
        $this->fairTag = $fairTag;
        $this->somePayload = $somePayload;
    }

    public function getFairTag(): string|null
    {
        return $this->fairTag;
    }

    public function getSomePayload(): string
    {
        return $this->somePayload;
    }
}

$redis = new Redis([
    'host' => 'redis',
    'port' => 6379,
]);
$serilizer = new PhpMessageSerializer();
$namer = new PrefixQueueNamer(prefix: 'fair/queue');
$storage = new RedisStorage($redis, $serilizer);
$broker = new Broker($storage, $namer);
$message = new SomeMessageOrJob(somePayload: 'user1-job1', fairTag: 'user1');
$broker->push($message);
$message = new SomeMessageOrJob(somePayload: 'user1-job2', fairTag: 'user1');
$broker->push($message);
$message = new SomeMessageOrJob(somePayload: 'user2-job1', fairTag: 'user2');
$broker->push($message);
$message = new SomeMessageOrJob(somePayload: 'user2-job2', fairTag: 'user2');
$broker->push($message);
$message = new SomeMessageOrJob(somePayload: 'user3-job1', fairTag: 'user3');
$broker->push($message);

while (($message = $broker->pop()) !== null) {
    echo $message->getSomePayload() . "\n";
}
// Output:
// user1-job1
// user2-job1
// user3-job1
// user1-job2
// user2-job2