Skip to content

3 监听队列并处理任务

evalor edited this page Jan 7, 2018 · 1 revision

将任务推送到队列

建立好任务处理类后,就可以向队列推送任务,下面是推送任务的示例方法,支持推送普通任务和延时任务,延时任务即推送到队列后,延迟一定的时间才会被消费

可以作为定时任务,到指定时间才执行,计算当前到指定时间之间的秒数,作为延时秒数即可

<?php

use easySwoole\Queue\Queue;

function PushIntoQueue(){
    // 任务处理类
    $class = someJobs::class;  // 只需要获取任务处理类的完整命名空间即可
    
    Queue::push($class,'data');                     // 推送任务到默认队列
    Queue::pushOn('queueName',$class,'data');       // 推送任务到指定队列
    
    Queue::later(300,$class,'data');                // 延时300秒后可以获取
    Queue::laterOn('queueName',300,$class,'data');  // 推送延时任务到指定队列
}
Clone this wiki locally