PHP code example of playcat / queue-base

1. Go to this page and download the library: Download playcat/queue-base library. Choose the download type require.

2. Extract the ZIP file and open the index.php.

3. Add this code to the index.php.

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

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

playcat / queue-base example snippets


use Playcat\Queue\Manager;
use Playcat\Queue\Protocols\ProducerData;

  $manager_config = [
        'driver' => \Playcat\Queue\Driver\Redis::class,
        'timerserver' => '127.0.0.1:6678',
        'Redis' => ['host' => '127.0.0.1:6379']
        ];
  $payload = new ProducerData();
  //对应消费队列里的任务名称
  $payload->setChannel('test');
  //对应消费队列里的任务使用的数据
  $payload->setQueueData([1,2,3,4]);
  //推入队列并且获取消息id
  $id = Manager::getInstance()
        ->setConf($manager_config)
        ->push($payload);

  //延迟消费消息
  $payload_delay = new ProducerData();
  $payload_delay->setChannel('test');
  $payload_delay->setQueueData([6,7,8,9]);
  //设置60秒后执行的任务
  $payload_delay->setDelayTime(60);
  //推入队列并且获取消息id
  $id = Manager::getInstance()
        ->setConf($manager_config)
        ->push($payload_delay);
  //取消延迟消息
  Manager::getInstance()->del($id);