소스 코드 분석을 통해 Laravel이 동일한 대기열 작업을 반복적으로 실행하는 이유를 설명합니다.

라라벨의 큐 서비스는 다양한 백그라운드 큐 서비스에 대한 통합 API를 제공합니다. 다음 글에서는 라라벨이 동일한 큐 작업을 반복적으로 실행하는 이유를 소스 코드 분석을 통해 소개합니다. 도움이 필요한 친구들이 참고할 수 있도록 자세히 소개합니다. 이에 대해서는 아래를 살펴보겠습니다.

Preface

Laravel의 대기열 서비스는 다양한 백그라운드 대기열 서비스에 대한 통합 API를 제공합니다. 대기열을 사용하면 이메일 전송과 같이 시간이 많이 걸리는 작업의 실행을 지연시킬 수 있습니다. 이렇게 하면 요청 응답 시간을 효과적으로 줄일 수 있습니다.

문제 발견

Laravel에서 Redis를 사용하여 대기열 작업을 처리합니다. 프레임워크에서 제공하는 기능은 매우 강력하지만 최근에 문제가 발생했습니다. 즉, 작업이 여러 번 실행되는 것을 발견했습니다. 왜 이런가요?

먼저 이유를 이야기해보자:

라라벨에서는 큐(작업) 실행 시간이 60초를 초과하면 실패한 것으로 간주되어 다시 추가되기 때문이다. 동일한 작업이 반복적으로 실행되는 대기열입니다.

이 작업의 논리는 사용자에게 콘텐츠를 푸시하는 것입니다. 사용자는 대기열 콘텐츠를 기반으로 검색 및 이동되어야 하며 요청 백엔드 HTTP 인터페이스를 통해 전송되어야 합니다. 예를 들어 사용자가 10,000명인 경우, 사용자 수가 많거나 인터페이스 처리 속도가 그다지 빠르지 않다면 실행 시간은 당연히 60초보다 커지므로 작업이 대기열에 다시 추가됩니다. 상황은 더욱 심각하다. 이전 작업이 60초 이내에 실행되지 않으면 대기열에 다시 추가되므로 동일한 작업이 한 번만 실행되는 것이 아니라 여러 번 실행된다.

라라벨 소스코드에서 범인을 찾아보자.

소스 코드 파일: Vendor/laravel/framework/src/Illuminate/Queue/RedisQueue.php

/**
 * The expiration time of a job.
 *
 * @var int|null
 */
protected $expire = 60;

이 $expire 멤버 변수는 대기열이 다음보다 오래 지속되지 않을 것이라고 믿습니다. 60초이면 실행이 완료됩니다. 대기열을 가져오는 방법:

public function pop($queue = null)
{
 $original = $queue ?: $this->default; 
 $queue = $this->getQueue($queue); 
 $this->migrateExpiredJobs($queue.':delayed', $queue); 
 if (! is_null($this->expire)) {
  $this->migrateExpiredJobs($queue.':reserved', $queue);
 } 
 list($job, $reserved) = $this->getConnection()->eval(
  LuaScripts::pop(), 2, $queue, $queue.':reserved', $this->getTime() + $this->expire
 ); 
 if ($reserved) {
  return new RedisJob($this->container, $this, $job, $reserved, $original);
 }
}

대기열을 가져오는 데는 여러 단계가 있습니다. 대기열 실행이 실패하거나 실행 시간이 초과되는 등의 이유로 다른 컬렉션에 저장되어 재시도를 위해 저장됩니다. 과정은 다음과 같습니다.

1. Put 실행으로 인해 실패한 큐를 지연된 컬렉션에서 현재 실행 중인 큐로 다시 푸시합니다.

2. 실행 시간 초과로 인해 예약된 컬렉션에서 현재 실행 중인 대기열로 대기열을 다시 푸시합니다.

3. 그런 다음 대기열에서 작업을 가져와 실행을 시작하고 대기열을 예약된 순서 컬렉션에 넣습니다.

여기에서는 이 프로세스를 실행하기 위해 eval 명령이 사용되며 여러 lua 스크립트가 사용됩니다.

실행할 대기열에서 작업 가져오기:

local job = redis.call('lpop', KEYS[1])
local reserved = false
if(job ~= false) then
 reserved = cjson.decode(job)
 reserved['attempts'] = reserved['attempts'] + 1
 reserved = cjson.encode(reserved)
 redis.call('zadd', KEYS[2], ARGV[1], reserved)
end
return {job, reserved}

Laravel이 Redis에서 실행할 대기열을 가져올 때 주문된 세트에 복사본을 넣고 만료 시간을 사용하는 것을 볼 수 있습니다. 시간을 포인트로 찔러보세요.

작업이 완료된 경우에만 주문한 세트에서 작업을 제거하세요. 이 정렬된 컬렉션에서 큐를 제거하는 코드는 생략되었습니다. Laravel이 실행 시간이 60초를 초과하는 큐를 처리하는 방법을 살펴보겠습니다.

이 Lua 스크립트의 기능은 다음과 같습니다.

local val = redis.call('zrangebyscore', KEYS[1], '-inf', ARGV[1])
if(next(val) ~= nil) then
 redis.call('zremrangebyrank', KEYS[1], 0, #val - 1)
 for i = 1, #val, 100 do
  redis.call('rpush', KEYS[2], unpack(val, i, math.min(i+99, #val)))
 end
end
return true

여기서 zrangebyscore는 점수가 극미량에서 현재 타임스탬프까지의 요소, 즉 60초 전에 세트에 추가된 작업을 찾은 다음 통과합니다. zremrangebyrank는 세트에서 이러한 요소를 제거하고 대기열에 푸시합니다.

이걸 보시면 문득 깨닫게 되실 겁니다.

큐가 60초 이내에 실행되지 않으면 프로세스는 큐를 가져올 때 예약된 세트의 작업을 다시 큐로 푸시합니다.

요약

당신이 관심을 가질 만한 기사:

Laravel Redis에서 동시에 대기열을 차지하는 여러 프로세스의 문제에 대한 자세한 설명

php-msf에 대한 자세한 설명 소스 코드

thinkphp5 URL과 라우팅 기능 및 예제에 대한 자세한 설명

위 내용은 소스 코드 분석을 통해 Laravel이 동일한 대기열 작업을 반복적으로 실행하는 이유를 설명합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!