Laravel 대기열 및 작업 스케줄러: 동시에 많은 수의 작업 처리
- 王林원래의
- 2023-08-13 09:51:152231검색
Laravel 대기열 및 작업 스케줄러: 많은 수의 작업을 동시에 처리
현대 웹 애플리케이션 개발에는 많은 수의 작업을 처리해야 하는 시나리오가 종종 있습니다. 예를 들어 이메일 보내기, 보고서 생성, 빅데이터 처리 등이 있습니다. 그러나 작업량이 매우 많은 경우 이러한 작업을 처리하기 위한 단일 요청으로 인해 요청이 오랫동안 지연되거나 시스템 리소스가 소진될 수 있습니다. 이러한 문제를 해결하기 위해 라라벨은 많은 수의 작업을 동시에 처리할 수 있는 큐 및 작업 스케줄러 기능을 제공합니다.
1. Laravel Queue
대기열은 대기열을 통해 작업을 백그라운드로 푸시하는 메커니즘으로, 우리 애플리케이션은 사용자의 요청 응답 속도에 영향을 주지 않고 백그라운드에서 시간이 많이 걸리는 작업을 처리할 수 있습니다.
Laravel에서는 데이터베이스 큐, Redis 큐, Beanstalkd 큐 등과 같은 다양한 방법을 사용하여 큐 기능을 구현할 수 있습니다. 여기서는 동시 처리 작업 기능을 구현하는 방법을 보여주기 위해 데이터베이스 큐를 예로 들어 보겠습니다.
- 큐 드라이버 구성
먼저 Laravel의 구성 파일 config/queue.php에서 큐 드라이버를 구성해야 합니다. 데이터베이스 대기열을 사용하기로 선택하고 connection 옵션을 database로 설정하고 일부 데이터베이스 연결 관련 구성을 설정합니다. config/queue.php中配置队列驱动。我们选择使用数据库队列，将connection选项设置为database，以及设置一些数据库连接的相关配置。
'default' => env('QUEUE_CONNECTION', 'database'),
'connections' => [
'database' => [
'driver' => 'database',
'table' => 'jobs',
'queue' => 'default',
'retry_after' => 90,
],
],2.创建队列表
接下来，我们需要创建一个用于存储队列任务的数据表。可以使用Laravel提供的Artisan命令php artisan queue:table快速生成迁移文件，并执行迁移。
php artisan queue:table php artisan migrate
- 创建任务类
然后，我们需要创建一个任务类，用于处理具体的任务逻辑。在Laravel中，任务类一般放在app/Jobs目录下，可以通过Artisan命令php artisan make:job快速生成一个任务类。
php artisan make:job SendEmail
生成的任务类SendEmail位于app/Jobs目录下，我们可以在该类的handle方法中编写任务逻辑。
<?php
namespace AppJobs;
use IlluminateBusQueueable;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;
use IlluminateQueueInteractsWithQueue;
use IlluminateQueueSerializesModels;
class SendEmail implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
// 处理发送邮件的逻辑
// ...
}
}在任务类中，我们需要实现ShouldQueue接口，并定义handle方法来处理任务逻辑。
- 推送任务到队列
最后，我们可以通过以下代码将任务推送到队列中。
use AppJobsSendEmail; SendEmail::dispatch();
通过dispatch方法将任务加入到队列中，系统会自动根据配置选择相应的队列驱动进行处理。
二、Laravel任务调度器
Laravel还提供了一个任务调度器的功能，可以将任务设置为定时执行或者周期性执行。我们可以通过任意的Laravel自带的时间表（Laravel Time Scheduling）来设置任务的执行规则。
- 定义任务调度
首先，我们需要在app/Console/Kernel.php文件的schedule方法中定义任务调度。例如，我们定义一个每分钟执行一次的任务。
protected function schedule(Schedule $schedule)
{
$schedule->job(new SendEmail)->everyMinute();
}在上述代码中，我们使用了任务类SendEmail作为调度的执行体，然后通过everyMinute方法设置任务执行频率为每分钟一次。
- 初始化任务调度
任务调度定义成功之后，我们需要在服务器上设置一个Cron表达式以便执行任务调度。
在Linux系统上，可以通过crontab命令来编辑和设置Cron表达式。
crontab -e
然后，在打开的文件中加入以下代码：
* * * * * php /path/to/artisan schedule:run >> /dev/null 2>&1
上述代码表示每分钟执行一次php artisan schedule:runrrreee
php artisan queue:table을 사용하면 마이그레이션 파일을 빠르게 생성하고 마이그레이션을 수행할 수 있습니다. rrreee
- 작업 클래스 만들기
그런 다음 특정 작업 논리를 처리하는 작업 클래스를 만들어야 합니다. Laravel에서 작업 클래스는 일반적으로 app/Jobs 디렉터리에 배치됩니다. Artisan 명령 php artisan make:job을 통해 작업 클래스를 빠르게 생성할 수 있습니다.
SendEmail는 app/Jobs 디렉터리에 있습니다. 이 클래스의 handle 메서드에 작업 논리를 작성할 수 있습니다. . 🎜rrreee🎜작업 클래스에서는 ShouldQueue 인터페이스를 구현하고 작업 로직을 처리하기 위한 handle 메서드를 정의해야 합니다. 🎜- 🎜작업을 대기열에 푸시🎜🎜🎜마지막으로 다음 코드를 통해 작업을 대기열에 푸시할 수 있습니다. 🎜rrreee🎜
dispatch 메서드를 통해 대기열에 작업을 추가하면 시스템이 구성에 따라 처리할 해당 대기열 드라이버를 자동으로 선택합니다. 🎜🎜2. Laravel 작업 스케줄러🎜🎜Laravel은 작업이 정기적으로 또는 주기적으로 실행되도록 설정할 수 있는 작업 스케줄러 기능도 제공합니다. Laravel 자체 일정(Laravel Time Scheduling)을 통해 작업 실행 규칙을 설정할 수 있습니다. 🎜🎜🎜작업 일정 정의🎜🎜🎜먼저 app/Console/Kernel.php 파일의 schedule 메서드에서 작업 일정을 정의해야 합니다. 예를 들어, 매분 실행되는 작업을 정의합니다. 🎜rrreee🎜위 코드에서는 SendEmail 작업 클래스를 일정의 실행 본문으로 사용한 다음 everyMinute를 통해 작업 실행 빈도를 분당 1회로 설정했습니다. 방법. 🎜- 🎜작업 스케줄링 초기화🎜🎜🎜작업 스케줄링이 성공적으로 정의된 후 작업 스케줄링을 수행하려면 서버에 Cron 표현식을 설정해야 합니다. 🎜🎜Linux 시스템에서는
crontab 명령을 통해 Cron 표현식을 편집하고 설정할 수 있습니다. 🎜rrreee🎜그런 다음 열린 파일에 다음 코드를 추가하세요: 🎜rrreee🎜위 코드는 php artisan Schedule:run 명령이 1분마다 실행되어 작업 예약이 시작된다는 의미입니다. 🎜🎜위 구성을 통해 예약 실행 기능과 주기적 작업 실행 기능을 구현할 수 있습니다. 🎜🎜요약: 🎜🎜Laravel 큐와 작업 스케줄러의 기능을 통해 우리는 많은 수의 작업을 동시에 처리해야 하는 필요성을 쉽게 인식할 수 있습니다. 대기열은 사용자 요청 차단을 방지하기 위해 비동기 처리를 위해 작업을 백그라운드로 푸시할 수 있습니다. 작업 스케줄러를 사용하면 작업을 시간 규칙에 따라 정기적으로 또는 주기적으로 실행할 수 있어 작업 처리 효율성이 향상됩니다. 🎜🎜이상은 Laravel 큐와 작업 스케줄러에 대한 소개입니다. 모든 분들께 도움이 되었으면 좋겠습니다! 🎜위 내용은 Laravel 대기열 및 작업 스케줄러: 동시에 많은 수의 작업 처리의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!