Laravel 프레임워크의 큐 사용법 소개(코드 포함)

이 글은 라라벨 프레임워크(코드 포함)에서 큐의 사용법을 소개합니다. 필요한 친구들이 참고할 수 있기를 바랍니다.

실제 프로젝트 개발에서는 문자 메시지 보내기, 이메일 보내기 등 경량 대기열이 필요한 상황에 자주 직면합니다. 이러한 작업은 kafka 및 RabbitMQ와 같은 무거운 메시지 대기열을 사용하기에는 충분하지 않지만 비동기식, 재시도가 필요합니다 , 동시성 제어 및 기타 기능. 일반적으로 우리는 Redis, Beanstalk 및 Amazon SQS를 사용하여 관련 기능을 구현하는 경우가 많습니다. Laravel은 다양한 백그라운드 대기열 서비스에 대한 통합 API를 제공합니다. 이 기사에서는 가장 널리 사용되는 Redis 대기열을 소개합니다.

laravel의 대기열 서비스를 설명하기 전에 먼저 redis 기반의 대기열 서비스에 대해 이야기해야 합니다. 우선 Redis는 캐싱을 위해 설계되었지만 그 자체의 일부 특성으로 인해 메시지 큐에 사용할 수 있습니다

redis 큐 데이터 구조

List linked list

redis는 FIFO와 같은 메시지 큐에 대한 기능(먼저- in-first-out) (out)은 구현하기 쉽습니다. 처음부터 데이터를 가져오고 꼬리부터 데이터를 채우려면 목록 개체가 필요합니다.

관련 명령: (1) 왼쪽 입력 및 오른쪽 출력: lpush/rpop (2) 오른쪽 입력 및 왼쪽 출력: rpush/lpop.

이 간단한 메시지 대기열은 구현하기 쉽습니다.

Zset 주문 세트

일부 작업 시나리오에서는 작업을 즉시 실행할 필요가 없지만 일부 작업은 매우 중요하므로 작업이 실패하면 다시 시도해야 합니다. 이러한 기능은 목록에만 의존하여 수행할 수 없습니다. 이때 Redis의 Ordered Collection이 필요합니다.

Redis 주문 세트는 Redis 세트와 유사하며 동일한 문자열을 포함하지 않는 컬렉션입니다. 이들 사이의 차이점은 순서 집합의 각 구성원이 점수와 연관되어 있으며, 이 점수는 순서 집합의 구성원을 가장 낮은 점수에서 가장 높은 점수까지 순위를 매기는 데 사용된다는 것입니다.

순서된 세트와 지연된 작업 사이에는 아무런 관계가 없지만, 주문된 세트의 점수를 지연된 작업이 시작되는 시간으로 설정한 다음 주문된 세트를 폴링하여 만료된 작업을 처리용으로 꺼낼 수 있습니다. . 이러한 방식으로 작업 지연 기능이 실현됩니다.

재시도해야 하는 중요한 작업의 경우 작업이 실행되기 전에 작업을 순서대로 컬렉션에 넣고 작업의 가장 긴 실행 시간이 설정됩니다. 작업이 성공적으로 실행되면 해당 작업은 주문된 컬렉션에서 삭제됩니다. 지정된 시간 내에 작업이 완료되지 않으면 주문한 세트의 작업이 다시 대기열에 들어갑니다.

관련 명령:

(1) ZADD 주문한 세트에 하나 이상의 구성원을 추가하거나 이미 존재하는 경우 점수를 업데이트합니다.

(2) ZRANGEBYSCORE 점수별로 정렬된 멤버 범위 집합을 반환합니다.

(3) ZREMRANGEBYRANK 지정된 인덱스 내의 순서가 지정된 세트에서 모든 구성원을 제거합니다.

laravel 큐 서비스의 작업 스케줄링

큐 서비스의 작업 스케줄링 프로세스는 다음과 같습니다.

laravel의 큐 서비스는 두 프로세스에 의해 제어됩니다. 하나는 생산자이고 다른 하나는 소비자입니다. 이 두 프로세스는 세 개의 Redis 대기열을 조작합니다. 그 중 하나는 즉각적인 작업을 담당하는 List이고, 지연된 작업과 보류 중인 작업을 담당하는 두 개의 Zset입니다.

생산자는 작업을 redis로 푸시할 책임이 있습니다. 즉각적인 작업인 경우 기본적으로 queue:default로 푸시됩니다. 지연된 작업인 경우 queue:default:delayed로 푸시됩니다.

소비자는 두 개의 대기열을 폴링하고 지속적으로 대기열에서 작업을 꺼내고 먼저 작업을 queue:default:reserved에 넣은 다음 관련 작업을 실행합니다. 작업이 성공적으로 실행되면 queue:default:reserved의 작업이 삭제되고, 그렇지 않으면 queue:default:delayed 대기열에 다시 배치됩니다.

라라벨 큐 서비스의 전반적인 과정

작업 분배 과정:

작업 프로세서 동작:

작업 생성

queue 설정

'redis' => [
        'driver' => 'redis',
        'connection' => 'default',
        'queue' => 'default',
        'retry_after' => 90,
    ],

config/queue.php에서 구성
일반적으로 말하면 , 기본 redis 구성은 위와 같습니다. 연결은 데이터베이스에 있는 redis의 연결 이름이고, queue는 redis의 대기열 이름입니다. Redis 클러스터를 사용하는 경우 키 해시 태그를 사용해야 합니다. is, { default}; 작업이 retry_after 시간을 초과하여 실행되면 작업이 다시 대기열에 들어갑니다.

작업 클래스 생성

작업 클래스의 구조는 매우 간단합니다. 일반적으로 대기열이 이 작업을 호출하는 데 사용하는 핸들 메서드만 포함합니다.

동기적으로 실행하는 대신 작업을 대기열에 푸시하려면 IlluminateContractsQueueShouldQueue 인터페이스를 구현해야 합니다.

redis 또는 sqs와 같은 특정 연결로 작업을 푸시하려면 연결 변수를 설정해야 합니다.

작업을 특정 대기열로 푸시하려면 대기열 변수를 설정할 수 있습니다.

如果想要让任务延迟推送，那么需要设置 delay 变量。

如果想要设置任务至多重试的次数，可以使用 tries 变量；

如果想要设置任务可以运行的最大秒数，那么可以使用 timeout 参数。

如果想要手动访问队列，可以使用 trait : IlluminateQueueInteractsWithQueue。

任务的分发
分发服务
写好任务类后，就能通过 dispatch 辅助函数来分发它了。唯一需要传递给 dispatch 的参数是这个任务类的实例：

class PodcastController extends Controller
{
    public function store(Request $request)
    {
        // 创建播客...

        ProcessPodcast::dispatch($podcast);
    }
}

如果想延迟执行一个队列中的任务，可以用任务实例的 delay 方法。

 ProcessPodcast::dispatch($podcast)
                ->delay(Carbon::now()->addMinutes(10));

通过推送任务到不同的队列，可以给队列任务分类，甚至可以控制给不同的队列分配多少任务。要指定队列的话，就调用任务实例的 onQueue 方法：

ProcessPodcast::dispatch($podcast)->onQueue('processing');

如果使用了多个队列连接，可以将任务推到指定连接。要指定连接的话，可以在分发任务的时候使用 onConnection 方法：

ProcessPodcast::dispatch($podcast)->onConnection('redis
');

위 내용은 Laravel 프레임워크의 큐 사용법 소개(코드 포함)의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!