源码分析 Laravel 重复执行同一个队列任务的原因

1

2

3

4

5

6

/**

 * The expiration time of a job.

 *

 * @var int|null

 */

protected $expire = 60;

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

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

2

3

4

5

6

7

8

9

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}

1

2

3

4

5

6

7

8

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