我需要一种异步运行某些任务的方法,因为每个任务之间的执行时间不同,我想使用Laravel Jobs和数据库作为驱动程序以异步方式运行.
我创建了使用命令行测试作业：
php artisan make：job TestOne
php artisan make：job TestTwo
TestOne.php
<?php
namespace App\Jobs;
use App\Jobs\Job;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
class TestOne extends Job implements ShouldQueue
{
use InteractsWithQueue, SerializesModels;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct()
{
//
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
sleep(5);
foreach (range(1, 10) as $item)
\Log::info("TestOne: item #" . $item);
}
}
TestTwo.php
<?php
namespace App\Jobs;
use App\Jobs\Job;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
class TestTwo extends Job implements ShouldQueue
{
use InteractsWithQueue, SerializesModels;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct()
{
//
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
foreach (range(1, 10) as $item)
\Log::info("TestTwo: item #" . $item);
}
}
我只是在laravel的日志文件中记录一些消息,并且由于TestOne正在休眠5秒,TestTwo应该首先记录消息
HomeController.php
<?php
namespace App\Http\Controllers;
use Queue;
use App\Jobs\TestOne;
use App\Jobs\TestTwo;
class HomeController extends Controller
{
public function index()
{
$this->dispatch(new TestOne());
$this->dispatch(new TestTwo());
die("stop");
}
}
但是TestTwo作业仍然等待,直到TestOne作业完成：
[2017-03-04 17:00:30] local.INFO: TestOne: item #1
[2017-03-04 17:00:30] local.INFO: TestOne: item #2
[2017-03-04 17:00:30] local.INFO: TestOne: item #3
[2017-03-04 17:00:30] local.INFO: TestOne: item #4
[2017-03-04 17:00:30] local.INFO: TestOne: item #5
[2017-03-04 17:00:30] local.INFO: TestOne: item #6
[2017-03-04 17:00:30] local.INFO: TestOne: item #7
[2017-03-04 17:00:30] local.INFO: TestOne: item #8
[2017-03-04 17:00:30] local.INFO: TestOne: item #9
[2017-03-04 17:00:30] local.INFO: TestOne: item #10
[2017-03-04 17:00:30] local.INFO: TestTwo: item #1
[2017-03-04 17:00:30] local.INFO: TestTwo: item #2
[2017-03-04 17:00:30] local.INFO: TestTwo: item #3
[2017-03-04 17:00:30] local.INFO: TestTwo: item #4
[2017-03-04 17:00:30] local.INFO: TestTwo: item #5
[2017-03-04 17:00:30] local.INFO: TestTwo: item #6
[2017-03-04 17:00:30] local.INFO: TestTwo: item #7
[2017-03-04 17:00:30] local.INFO: TestTwo: item #8
[2017-03-04 17:00:30] local.INFO: TestTwo: item #9
[2017-03-04 17:00:30] local.INFO: TestTwo: item #10
我用php artisan队列运行作业：听
我在这做错了什么？我真的需要这些任务以异步方式运行,就像JS AJAX请求一样.
我正在使用Laravel 5.2.我再次使用“database”作为队列驱动程序,是的,我已经迁移了jobs表.是不是可以使用数据库作为驱动程序？
解决方法:
要并行处理作业,你必须将它们分成不同的队列,正如@dparoli指出的那样.
这样,您不仅可以对它们进行分类,还可以优先考虑队列工作人员如何处理它们.
分派作业时,您将指定它所属的队列：
$this->dispatch((new TestOne())->onQueue('queue1'));
$this->dispatch((new TestTwo())->onQueue('queue2'));
这样,您可以生成多个队列工作程序来单独处理作业：
php artisan queue:work --queue=queue1
php artisan queue:work --queue=queue2
您还可以使用单个队列工作程序来优先处理队列的方式,这样您可以为某些作业提供比其他作业更高或更低的优先级：
php artisan queue:work --queue=queue2,queue1
通过使用像Supervisor这样的进程监视器,您甚至可以在多个进程中生成单个工作程序,如detailed in the documentation.
值得注意的是,除了给定的队列优先级之外,优先处理其队列的单个队列工作者仍将通过获取FIFO优先级来处理其作业.为了实现更好的并行性,您需要生成多个队列工作程序.
这适用于所有队列驱动程序.