在我們的web應用中，經(jīng)常會遇到這樣的情況：
用戶在進行了某項操作后，我們需要在后臺完成一個耗時且耗費資源的任務，以對應用戶的操作。
通常來說，web應用中的操作都是同步的（synchronous），即用戶的操作可以立即得到回饋。
但是在以上情況下，同步等待操作結(jié)果將是災難性的。比如用戶點擊了申請密碼重置郵件，倘若我們讓用戶一直停滯在等待頁面，直至郵件發(fā)送成功，那么用戶體驗將非常地不好，因為有時候可能需要很長的時間才能將郵件發(fā)送完成。
從另一個角度來說，如果我們服務器處于高負荷的情況，當多個用戶同時請求發(fā)送郵件等操作時，我們不希望同時地給服務器增加負荷，否則可能會導致服務器崩潰，造成無法預估的情況。
從以上的討論可以看出，我們需要一種機制，可以非同步地響應用戶操作，并且不會給服務器增加過大的負荷。
那么這樣一種機制就是Queues和Jobs（即隊列和工作）。
如果你系統(tǒng)地學習過計算機科學，那么隊列的概念你應該不陌生。假設我們?nèi)ャy行辦事，我們拿了一個號，發(fā)現(xiàn)前面有8個人在等待，那么我們實際上就處在一個隊列之中，隊列中靠前的人會先被叫到號碼，并且叫號的順序即拿號的順序。這樣的隊列就叫做Queue，采用的是先到先處理的方式，不允許插隊的情況存在。而我們要辦的事情就叫Job。
在Laravel中，我們可以很方便地使用Queues及Jobs來達到我們的目的。首先我們需要先來看一下，Laravel中有哪些Queues。
打開config/queue.php，我們可以看到幾種常見的隊列設置：
return [
/*
|--------------------------------------------------------------------------
| Default Queue Connection Name
|--------------------------------------------------------------------------
|
| Laravel's queue API supports an assortment of back-ends via a single
| API, giving you convenient access to each back-end using the same
| syntax for every one. Here you may define a default connection.
|
*/
'default' => env('QUEUE_DRIVER', 'sync'),
/*
|--------------------------------------------------------------------------
| Queue Connections
|--------------------------------------------------------------------------
|
| Here you may configure the connection information for each server that
| is used by your application. A default configuration has been added
| for each back-end shipped with Laravel. You are free to add more.
|
| Drivers: "sync", "database", "beanstalkd", "sqs", "redis", "null"
|
*/
'connections' => [
'sync' => [
'driver' => 'sync',
],
'database' => [
'driver' => 'database',
'table' => 'jobs',
'queue' => 'default',
'retry_after' => 90,
],
'beanstalkd' => [
'driver' => 'beanstalkd',
'host' => 'localhost',
'queue' => 'default',
'retry_after' => 90,
],
'sqs' => [
'driver' => 'sqs',
'key' => env('SQS_KEY', 'your-public-key'),
'secret' => env('SQS_SECRET', 'your-secret-key'),
'prefix' => env('SQS_PREFIX', 'https://sqs.us-east-1.amazonaws.com/your-account-id'),
'queue' => env('SQS_QUEUE', 'your-queue-name'),
'region' => env('SQS_REGION', 'us-east-1'),
],
'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => 'default',
'retry_after' => 90,
'block_for' => null,
],
],
/*
|--------------------------------------------------------------------------
| Failed Queue Jobs
|--------------------------------------------------------------------------
|
| These options configure the behavior of failed queue job logging so you
| can control which database and table are used to store the jobs that
| have failed. You may change them to any database / table you wish.
|
*/
'failed' => [
'database' => env('DB_CONNECTION', 'mysql'),
'table' => 'failed_jobs',
],
];
在connections中，我們看到sync這個連接。sync是Laravel默認的隊列，代表的就是synchronous，即同步隊列。
今天我們要來看一下，如何使用database，即數(shù)據(jù)庫來實現(xiàn)異步任務處理。
要使用database來作為隊列的內(nèi)部實現(xiàn)機制，我們需要建立一張用于儲存Jobs的表：
$ php artisan queue:table
$ php artisan migrate
以上命令將會在數(shù)據(jù)庫創(chuàng)建名為jobs的表。
隊列我們有了，那么現(xiàn)在我們來看一下Jobs。Laravel中jobs文件默認位置在app/Jobs文件夾下，我們可以通過make:job這個Artisan命令快速創(chuàng)建我們的job類：
$ php artisan make:job SendEmail
生成的job會實現(xiàn)Illuminate\Contracts\Queue\ShouldQueue這個接口，表明生成的job對象將被推到隊列中進行異步處理。
job類其實很簡單，里面只有一個名為handle的方法，該方法在job被queue處理的時候自動被調(diào)用。
在上面的命令中，我們創(chuàng)建了一個名為SendEmail的類：
?php
namespace App\Jobs;
use App\Email;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
class SendEmail implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
protected $email;
/**
* Create a new job instance.
*
* @param Podcast $podcast
* @return void
*/
public function __construct(Email $email)
{
$this->email = $email;
}
/**
* Execute the job.
*
* @param AudioProcessor $processor
* @return void
*/
public function handle()
{
// Process email and send the email to recipient(s)
// 這里我們可以處理我們的郵件并將郵件發(fā)送至接收人
}
}
可以看到，我們可以將model傳遞進job的constructor中。Laravel會自動序列化（Serialize）模型的識別信息，在job真正被處理的時候，完整的模型數(shù)據(jù)才會被從數(shù)據(jù)庫調(diào)用出來。另外，在handle方法中，我們也可以注入我們的依賴dependencies。
好了，現(xiàn)在我們有了job類，可以創(chuàng)建job對象了，那么如何把job添加進隊列呢？
在我們的控制器中，我們可以調(diào)用job的dispatch方法來將其添加進隊列中：
?php
namespace App\Http\Controllers;
use App\Jobs\SendEmail;
use Illuminate\Http\Request;
use App\Http\Controllers\Controller;
use App\Email;
class EmailsController extends Controller
{
/**
* Store a new email.
*
* @param Request $request
* @return Response
*/
public function send(Request $request)
{
// Create email...
// 這里我們提取email信息并創(chuàng)建$email, Email是我們自定義的Model
$email = Email::create($request->only('sender', 'to', 'content'));
SendEmail::dispatch($email);
}
}
這樣一來，每當我們的控制器調(diào)用send方法時，就會創(chuàng)建一個SendEmail的job在數(shù)據(jù)庫中。
那么怎么樣調(diào)用Queue Worker來處理我們的jobs呢？
在.env文件中，我們將QUEUE_DRIVER=sync改為QUEUE_DRIVER=database。
接下來，我們運行以下Artisan命令：
隊列的worker會一直運行，每當有任務被添加進數(shù)據(jù)庫jobs表中，worker便會自動抓取出任務進行處理。當任務失敗時，worker會重復執(zhí)行任務，直至最大嘗試次數(shù)（默認為255）。我們可以手動設置最大嘗試次數(shù)：
$ php artisan queue:work --tries=3
當然，我們也可以手動設置任務的超時（默認90s，在config/queue.php中的retry_after設置）：
$ php artisan queue:work --timeout=30
最后，當沒有任務的時候，我們可以設置一個睡眠時間，當worker在睡眠時間時，將不會處理任務：
$ php artisan queue:work --sleep=10
上面的命令意思是每當worker處理完所有任務后，會睡眠10s，然后才會再次檢查任務隊列
本文使用Laravel 5.6進行講解
本文主要講解了Laravel框架中隊列和工作(Queues、Jobs)操作實例詳解，更多關(guān)于Laravel框架的使用技巧請查看下面的相關(guān)鏈接
您可能感興趣的文章:- laravel5.6 框架郵件隊列database驅(qū)動簡單demo示例
- Laravel使用Queue隊列的技巧匯總
- Docker部署Laravel應用實現(xiàn)隊列&任務調(diào)度
- Laravel 6 將新增為指定隊列任務設置中間件的功能
- Laravel 隊列使用的實現(xiàn)
- Laravel框架隊列原理與用法分析
- Laravel中為什么不使用blpop取隊列詳析
- 關(guān)于 Laravel Redis 多個進程同時取隊列問題詳解
- 源碼分析 Laravel 重復執(zhí)行同一個隊列任務的原因
- Laravel使用消息隊列需要注意的一些問題
- Laravel中利用隊列發(fā)送郵件的方法示例
- 淺談Laravel隊列實現(xiàn)原理解決問題記錄
- 淺析Laravel5中隊列的配置及使用
- PHP的Laravel框架中使用消息隊列queue及異步隊列的方法
- Laravel 4.2 中隊列服務（queue）使用感受
