Laravel에서 대기열 사용

라라벨 큐 서비스는 다양한 백그라운드 큐에 대한 통합 API를 제공합니다. 이 글에서는 라라벨에서 큐를 사용하는 가장 기본적인 작업 튜토리얼을 주로 샘플 코드를 통해 소개합니다. 그것이 모두에게 도움이 되기를 바랍니다.

머리말

laravel의 대기열 서비스는 다른 대기열 서비스와 다르지 않습니다. 이는 인간의 생각과 가장 일치하는 가장 단순하고 일반적인 프로세스입니다. 대기열 정보를 저장하는 장소가 있으며, PHP 프로세스가 실행 중입니다. 작업이 작성되고 다른 PHP 데몬이 대기열 정보를 폴링하여 실행 요구 사항을 충족하는 작업이 실행 및 삭제됩니다. PHP는 URL 기반 동기 언어이며 본질적으로 차단되므로 Laravel이 대기열 정보를 쿼리하고 실행하는 데몬 도구를 제공하는 것은 놀라운 일이 아닙니다.

라라벨 큐를 이틀만에 처음 접하게 되었는데, 시간이 많이 걸렸습니다. . . 열심히 노력한 후에도 여전히 Laravel을 어떻게 사용해야 하는지 잘 모르겠다는 생각이 듭니다. 문서가 비교적 간단하고 요약되어 있고, 소스 코드를 읽는 것이 조금 어렵습니다(그러나 소스 코드를 읽고 천천히 디버깅하고 검증하는 것입니다). 여전히 가장 신뢰할 수 있습니다).

다음은 대기열의 가장 기본적인 작업만 사용하는 간단한 데모입니다. 고급 작업에는 더 많은 시간이 필요합니다. :)

나처럼 Laravel 대기열을 시작하는 데 어려움을 겪는 학생들이 공유할 수 있습니다.

Configuration

Redis 패키지 추가

composer.json의 require 섹션에 "predis/predis": "~1.0"을 추가한 다음, Composer up으로 업데이트하세요.

database.php

database.php 구성 파일에 redis 데이터베이스 부분을 구성하세요. 기본적으로 기본 연결이 있으니 그냥 사용하세요 :)

이 기본 연결에 필요한 구성 항목에 따라 편집하세요. .env 구성 파일에서 REDIS_HOST, REDIS_PASSWORD 및 REDIS_PORT를 자신의 서버에 있는 Redis의 해당 값으로 입력합니다.

queue.php

먼저 .env에서 QUEUE_DRIVER를 구성해야 합니다. 이제 Redis를 사용할 계획이므로 redis로 구성합니다.

그런 다음 queue.php의 연결 섹션에서 redis 연결을 구성합니다. 여기서 연결의 해당 값은 Database.php의 redis 기본 연결입니다.

Task 클래스

다음 단계는 실제 작업 클래스를 작성하는 것입니다. Laravel은 작업 클래스 생성을 단순화하기 위해 artisan 명령을 제공합니다.

php artisan make:job Demo

Jobs 디렉터리는 앱 디렉터리에 생성됩니다. 이미 Demo.php Task 클래스가 있습니다.

Lumen에는 이 artisan 명령이 없지만 매우 편리합니다. 기본적으로 이미 작성된 exampleJob.php가 있으므로 복사하고 이름을 변경하면 됩니다.
먼저 핸들 메소드에서 간단한 로그 출력 테스트를 작성합니다.

Log::info('Hello, queue');

Issuing jobs

이제 작업을 대기열에 푸시하는 입력 함수를 작성합니다. 보조 함수 dispatch()를 사용하세요:

Laravel에서 다음 방법을 사용하세요:

Demo::dispatch();

Lumen에서 다음 방법을 사용하세요:

dispatch(new Demo);

Open the queue

모든 것이 잘되면 이것이 마지막 단계입니다 . 명령줄에서 실행:

php artisan queue:listen --queue=default

큐를 모니터링하고 다음과 같은 간단한 실행 상태를 출력합니다.

[2017-11-07 02:12:47] Processing: App\Jobs\Demo
[2017-11-07 02:12:47] Processed: App\Jobs\Demo

문제가 없으면 이 큐 스크립트가 백그라운드에서 실행되도록 할 수 있습니다.

php artisan queue:work --daemon --quiet --queue=default 1>> /dev/null 2>&1

고급: )

큐로 푸시할 때 일반적으로 매개변수를 전달해야 하는데 여기서는 어떻게 전달하나요?

매개변수 전송

전달

입구 함수에서 매개변수 메소드는 다음과 같이 전달됩니다.

다음 방법을 사용합니다.

$param = 'Stephen';
Demo::dispatch($param);

lumen은 다음 방법을 사용합니다.

$param = 'Stephen';
dispatch(new Demo($param));

수신

태스크 클래스에서 매개변수를 받는 방법은 다음과 같습니다.

protected $param;
/**
 * Create a new job instance.
 *
 * @return void
 */
public function __construct($param)
{
  $this->param = $param;
}
/**
 * Execute the job.
 *
 * @return void
 */
public function handle()
{
  Log::info('Hello, ' . $this->param);
}

첫 번째 시도입니다. 지연된 배포, 오류 처리, 우선 순위, 실패 처리 등 고급 사용법이 많이 있습니다. 앞으로도 계속 글을 쓸 예정입니다 :)
Multi-queue

이것은 모든 작업을 기본이라는 대기열에 넣는 것이 불가능하므로 고려해야 할 문제입니다. 대기열을 관리합니다.

다른 대기열을 지정하려면 매우 간단합니다. 파견() 직후에 onQueue() 메서드를 따르세요.

Demo::dispatch()->onQueue('emails');

아니요, 이메일이라는 대기열을 정의하지 않은 것 같습니다. 당연히 몇 가지 변경이 필요합니다. queue.php 구성 파일의 redis 구성 대기열은 기본값에서 {default}로 변경됩니다. 이로 인해 대기열 이름을 런타임 중에 동적으로 얻을 수 있습니다. .

Lumen 프레임워크를 사용하는 경우 직접 작성하면 오류가 발생합니다. 문자열에서 onQueue() 멤버 함수를 호출합니다.

이유는 Lumen의 Job 기본 클래스가 IlluminateFoundationBusDispatchable 특성을 사용하지 않고 IlluminateBusQueueable의 onQueue() 메서드를 직접 사용하기 때문입니다.

이제 Job 클래스가 IlluminateBusQueueable 특성을 사용한다는 것이 확실하므로 Job 클래스에서 이 onQueue() 메서드를 호출해야 합니다. 🎜

$job = new XXXJob();
dispatch($job->onQueue('queue-name'));

🎜큐를 열 때:🎜

php artisan queue:work --queue=emails

这里指定的队列名 emails 和 dispatch 时指定的队列名保持一致即可。

相关推荐：

学习Laravel5的Eloquent 关系

laravel5.5控制器传参顺序问题及解决方案

Laravel 5.5的可相应接口如何使用？

위 내용은 Laravel에서 대기열 사용의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!