Laravel IronMq队列的非期望并行执行

Question

我正在尝试用Laravel来设置一个IronMq队列，而且我已经让它工作了，但重点是这种行为并不是理想的行为。

我希望IronMq等待一个作业完成($ job >delete())来推送一个新的作业，但是我发现它在前一个任务完成之前推送消息。

守则的结构如下：

Route::post('queue/send' ,function() 
{
    ...
    Queue::push(function($job) use ($data)
    {
        ...
        $job->delete();
    }
    return true;
}

有没有人找到了防止这种平行行为并使其连续发生的方法？

非常感谢!

Answer 1

谢谢你的回答，我决定用Beanstalkd代替IronMQ。

它要混乱得多，但它提供了所需的功能，我不依赖于任何人。

Answer 2

推送队列自然会继续推送消息，不管是否完成了任务，因为它们是两个独立的系统。其次，使用推送队列的目的是使其尽可能实时。

IronMQ特别是重试，听起来，它将尝试在指定的时间间隔内将消息推送到所需的端点X次数(设置)--希望这将有助于解决您的问题。

如果您希望只在完成前一个任务之后才处理作业，并且稍微延迟是可以接受的，那么我建议轮询队列并分批检索。

Answer 3

您还可以尝试使用IronMQ类而不是laravel类：

$ironmq = new \IronMQ(array(
    'token' => Config::get('queue.connections.iron.token', 'xxx'),
    'project_id' => Config::get('queue.connections.iron.project', 'xxx')
));
$ironmq->postMessage($queue_name, "Hello world");