Laravel 作业队列未使用 Redis 驱动程序处理

Question

我正在创建一个作业，将其推送到自定义队列，并尝试使用 Redis 驱动程序在它到达队列时处理该作业，但没有成功：

class MyController extends Controller {
    public function method() {
        $job = (new UpdateLiveThreadJob())->onQueue('live');
        $this->dispatch($job);
    }
}

这是我的队列配置：

    'default' => env('QUEUE_DRIVER'),

    'redis' => [
        'driver' => 'redis',
        'connection' => 'default',
        'queue'  => 'default',
        'expire' => 60,
    ],

这是我的.env 文件：

# Drivers (Queues & Broadcasts)
CACHE_DRIVER=file
SESSION_DRIVER=file
QUEUE_DRIVER=redis
BROADCAST_DRIVER=redis

这是我的工作：

class UpdateLiveThreadJob extends Job implements SelfHandling, ShouldQueue
{
    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct()
    {
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        // Rerender content
        $templatedOutput = view('templates.livethreadcontents')->with([
            'updates' => collect(Redis::lrange('live:updates', 0, -1))->reverse()->map(function($update) {
                return json_decode($update);
            })
        ])->render();

        // Connect to external service

        // Update Thread
    }
}

确实，我可以将 handle 方法更改为什么都不做，以确保它在工作中实际上没有导致它失败，并且它仍然没有处理：

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        print_r('test');
    }

使用 Redis，我可以看到它已被推入队列：

> lrange queues:live 0 -1
> // json encoded job present
> llen queues:live
> // shows there is a job in the queue

然而，据我所知，它从未真正触发过。观看php artisan queue:listen 什么也没有显示（只有不相关的事件广播）。这是怎么回事？

Answer 1

在 Laravel 5.3 中，队列发生了变化。现在您将运行php artisan queue:work --queue=live，这应该可以满足您的需要。

我在下面留下了我原来的答案。

---

你还记得运行php artisan queue:listen --queue=live 吗？

你需要在运行listen命令时定义队列名称，否则你最终只能监听default队列。

如果你想在生产环境中运行多个队列并管理事物，你可以使用 Upstart（与设置 Laravel 队列没有直接关系，但提供了一个很好的起点）或 Supervisor 之类的东西来管理进程。这两个都可以在 Forge 和 Homestead 上找到。

最后假设您使用的是 Laravel 5，您可能需要考虑运行 php artisan queue:work --daemon --queue=live，因为这会减少运行 worker 的 CPU 开销，因为它不会为每个作业重新加载框架。但是当你为你的工作部署新代码时，你必须记住重启工作器，否则事情将不会被拾取。