首頁  >  文章  >  php框架  >  Laravel開發:如何使用Laravel Queues和Supervisor管理非同步任務?

Laravel開發:如何使用Laravel Queues和Supervisor管理非同步任務?

王林
王林原創
2023-06-13 16:04:16892瀏覽

Laravel開發:如何使用Laravel Queues和Supervisor管理非同步任務?

在現代網路應用程式中,非同步任務已成為日常業務中不可或缺的一部分。非同步任務可以提高應用程式的回應時間,優化使用者體驗並增強應用程式的可擴展性。 Laravel Queues是Laravel框架提供的一個強大工具,用於處理非同步任務和訊息佇列。本文將介紹Laravel Queues的概念和使用方法,並結合Supervisor來管理非同步任務。

什麼是Laravel Queues?

Laravel Queues是一種用來處理非同步任務和訊息佇列的方法。透過Laravel Queues,您可以將耗時的任務放入佇列中,而不會影響Web請求的回應時間。例如,發送電子郵件,處理視訊或生成PDF,這些都是耗時的操作,使用佇列將它們放置到後台處理,可以使應用程式更加有效率和回應。

Laravel Queues透過一些內建的佇列驅動程式來支援多個後端技術,例如Database,Redis,Beanstalkd和Amazon SQS。這使開發人員可以使用他們喜歡的佇列技術來處理非同步任務。

使用Laravel Queues

下面我們將一步步驟介紹如何使用Laravel Queues處理非同步任務。

第一步:設定佇列驅動程式

Laravel設定檔中有一個名為queue.php的文件,您可以使用它來設定Queues和佇列驅動程式。您可以透過以下命令產生queue.php檔案:

php artisan queue:table
php artisan queue:failed-table
php artisan migrate

這將產生遷移檔案和隊列表。執行migrate指令以執行遷移。

在queue.php檔案中,您可以選擇使用多種佇列驅動程式:

  • #Database驅動程式 - 將任務儲存在資料庫中,可作為入門級隊列系統。
  • Redis驅動程式 - 使用Redis的內建佇列支援。
  • Beanstalkd驅動程式 - 使用Beanstalkd訊息佇列服務。
  • Amazon SQS驅動程式 - 使用Amazon Simple Queue Service(SQS)。

例如,如果您要使用Redis佇列驅動程序,請配置queue.php檔案如下:

'default' => env('QUEUE_CONNECTION', 'redis'),
'connections' => [
    'redis' => [
        'driver' => 'redis',
        'connection' => 'default',
        'queue' => env('REDIS_QUEUE', 'default'),
        'retry_after' => 90,
        'block_for' => null,
    ],
]

第二步:建立一個佇列任務類別

接下來,您需要建立一個佇列任務類,用於處理非同步任務。這個類別應該是一個簡單的PHP類,定義了任務的邏輯。例如,以下程式碼是一個用於發送電子郵件的非同步任務類別:

class SendEmail implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $email;
    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($email)
    {
        $this->email = $email;
    }
    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        Mail::to($this->email)->send(new WelcomeEmail());
    }
}

該類別實作了ShouldQueue接口,這是必需的,用於告訴Laravel將該類別轉換​​為非同步任務類別。 handle()方法定義了任務的具體邏輯,因此可以在這裡執行您需要非同步處理的任務。

第三個步驟:將任務推入佇列

現在您已經準備好了佇列任務和佇列驅動程序,下一步是將任務放入佇列。使用下列程式碼,在專案的任何位置呼叫一個E​​loquent佇列:

use AppJobsSendEmail; 
use IlluminateSupportFacadesQueue;
...
Queue::push(new SendEmail('example@test.com'));

或您可以使用dispatch()方法將任務放入佇列中,如下所示:

SendEmail::dispatch('example@test.com');

第四步:執行佇列任務

一旦您將任務放入佇列中,任務將會被dispatch 到佇列中,等待執行。您可以使用下列程式碼來執行佇列:

php artisan queue:work

執行此命令將會啟動一個監聽器並處理佇列中的任務。

使用Supervisor管理非同步任務

由於佇列任務需要在背景執行,因此需要在伺服器上設定進程守護程序,以確保任務可以持續執行。 Supervisor是一種常用的程序守護程序,可確保後台程序不會異常終止,並在需要時重新啟動它們。

第一步:安裝Supervisor

在Ubuntu系統中,您可以使用下列命令來安裝Supervisor:

sudo apt-get update
sudo apt-get install supervisor

第二步:建立一個Supervisor設定檔

在/etc/supervisor/conf.d目錄中建立一個設定文件,例如myqueue.conf:

nano /etc/supervisor/conf.d/myqueue.conf

將以下內容新增到設定檔中,確保更改路徑,命令和使用者名稱以符合您的程式:

[program:myqueue]
process_name=%(program_name)s_%(process_num)02d
command=/usr/bin/php /path/to/artisan queue:work --sleep=3 --tries=3 --daemon
autostart=true
autorestart=true
user=username
numprocs=1
redirect_stderr=true
stdout_logfile=/path/to/storage/logs/myqueue.log

第三步:重新載入Supervisor

在您變更了Supervisor的設定檔之後,您需要通知Supervisor重新載入設定檔。使用以下命令可以重新載入Supervisor:

sudo supervisorctl reread

sudo supervisorctl update

sudo supervisorctl start all

第四步:查看Supervisor日誌

您可以在Supervisor的日誌檔案中查看非同步任務的輸出和錯誤訊息。例如,您可以查看剛才設定檔中指定的路徑和日誌檔案名稱來查看Supervisor日誌:

tail -f /path/to/storage/logs/myqueue.log

結論

本文介紹如何使用Laravel Queues和Supervisor來管理非同步任務,使用Laravel Queues可以輕鬆將耗時的任務放入佇列中,並使應用程式更有效率且更能回應。使用Supervisor可以確保背景任務可以持續運行,並在需要時自動重新啟動。希望該文章對您的開發有所幫助。

以上是Laravel開發:如何使用Laravel Queues和Supervisor管理非同步任務?的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn