浅谈Laravel队列实现原理解决问题记录-无忧网

问题

公司项目使用laravel的开发的两个项目在同一个测试服务器部署，公用同一个redis。在使用laravel中的队列时，产生冲突干扰。

查找问题原因

在laravel 队列的操作类illuminatequeueredisqueue.php中可以看到pushraw()方法：

// 将一任务推入队列中 public function pushraw($payload, $queue = null, array $options = []) { $this->getconnection()->rpush($this->getqueue($queue), $payload); return arr::get(json_decode($payload, true), 'id'); }

从该方法中可以看出lrarvel队列的redis实现是通过list结构实现的，rpush(key, value)是将value推入键值为key的redis队列，key的值则是通过$this->getqueue($queue) 获取到的

protected function getqueue($queue) { return 'queues:'.($queue ?: $this->default); }

所以的redis中list中的key是 'queues:'.($queue ?: $this->default);拼接的，$this->default 的值是 redisqueue 实例化的时候从configqueue.php配置中加载的 'queue' => 'default'，$queue 是添加队列时$this->dispatch( new jobclass()->onqueue($queue) )传入的。

// configqueue.php 文件中的redis配置部分 'redis' => [ 'driver' => 'redis', 'connection' => 'default', 'queue' => 'default', 'expire' => 60, ],

至此，两个项目的队列冲突原因就找到了。因为redis队列配置中 'queue' => 'default' 都使用的默认的default，所以当共用redis时，默认的队列list 都是'queue:default',所以导致了冲突。

因为队列监听监听的队列名称是由 --queue参数决定的，如果不传就是我们上面设置的默认值，若传了就会根据传入的队列名从前往后优先依次处理，具体见代码illuminatequeueworker.php中：

protected function getnextjob($connection, $queue) { if (is_null($queue)) { return $connection->pop(); } foreach (explode(',', $queue) as $queue) { if (! is_null($job = $connection->pop($queue))) { return $job; } } }

$queue就是--queue=传入的参数，当 $queue不存在是直接调用$connection->pop()当参数存在时会将参数解析，优先处理排在前面的队列名称，将队列名称传入pop($queue), pop()会尝试从指定队列或默认队列中获取队列任务

// illuminatequeueredisqueue.php public function pop($queue = null) { $original = $queue ?: $this->default; $queue = $this->getqueue($queue); if (! is_null($this->expire)) { $this->migrateallexpiredjobs($queue); } $job = $this->getconnection()->lpop($queue); if (! is_null($job)) { $this->getconnection()->zadd($queue.':reserved', $this->gettime() + $this->expire, $job); return new redisjob($this->container, $this, $job, $original); } }

至此搞清了队列执行的原理。

解决方法

将queue的配置文件中默认队列修改为不同的名称，比如： 'queue' => laravel1','queue' => laravel2'。

队列监听 php artisan queue:listen redis --queue=laravel1,syncexpress

最后

遇到问题，莫要病急乱投医。从代码入手，分析理解实现原理，找对点，解决方法也许很简单，希望对大家的学习有所帮助，也希望大家多多支持硕编程。

【说明】：本文章由站长整理发布，文章内容不代表本站观点，如文中有侵权行为，请与本站客服联系(QQ:254677821)！

浅谈Laravel队列实现原理解决问题记录

相关教程推荐

其他课程推荐