Laravel队列的实现原理是什么-创新互联
本篇文章为大家展示了Laravel队列的实现原理是什么，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。
查找问题原因
在laravel 队列的操作类Illuminate\Queue\RedisQueue.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实例化的时候从config\queue.php配置中加载的 'queue' => 'default'，$queue 是添加队列时$this->dispatch( new jobClass()->onQueue($queue) )传入的。
// config\queue.php 文件中的redis配置部分 'redis' => [ 'driver' => 'redis', 'connection' => 'default', 'queue' => 'default', 'expire' => 60, ],
至此，两个项目的队列冲突原因就找到了。因为redis队列配置中'queue' => 'default'都使用的默认的default，所以当共用redis时，默认的队列list 都是'queue:default',所以导致了冲突。
因为队列监听 监听的队列名称是由 --queue参数决定的，如果不传就是我们上面设置的默认值，若传了就会根据传入的队列名从前往后优先依次处理，具体见代码Illuminate\Queue\Worker.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()会尝试从指定队列或默认队列中获取队列任务
// Illuminate\Queue\RedisQueue.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
上述内容就是Laravel队列的实现原理是什么，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。
名称栏目：Laravel队列的实现原理是什么-创新互联
链接URL：http://scjbc.cn/article/isegh.html
