我对 Laravel 很陌生，正在尝试创建队列来处理我的处理脚本。处理脚本将由每晚的 cron 作业触发。
我已经设置了 beanstalkd 并使用了队列。我还设置了非常简单的命令，允许我使用 artisan 启动脚本。我对 Laravel 很陌生，正在尝试创建队列来处理我的处理脚本。处理脚本将由每晚的 cron 作业触发。
我已经设置了 beanstalkd 并使用了队列。我还设置了非常简单的命令，这将允许我使用 artisan 启动脚本。
我遇到的主要问题是我的脚本中有依赖项。例如：
A -> B -> C
-> D
我首先需要脚本 A 成功运行，然后 B 需要成功运行，然后 C 和 D 需要运行，但 C 和 D 的顺序并不重要
这些都是非常不同的任务，我想将它们分开，但需要管理我队列中的依赖关系。我已经创建了模型和库来处理我的处理，一切都很好。
由于我已经在模型中有我的逻辑，我只需要对我的队列进行一个小调用。最初我只想使用闭包并将其全部写入一个文件，下面是一个简单的示例。
Queue::push(function($jobA) use ($id)
{
ProcessA::doStuff($id);
$jobA->delete();
});
这行得通，但这仅适用于 A，我仍然需要添加 B、C 和 D。所以我决定在其中添加一个闭包。
Queue::push(function($jobA) use ($id)
{
$statusA = ProcessA::doStuff($id);
if($statusA)
{
Queue::push(function($jobB) use ($id)
{
ProcessB::doStuff($id);
$jobB->delete();
});
}
$jobA->delete();
});
这不起作用。在闭包内运行闭包似乎存在问题。也可能存在作业 A 可能在作业 B 开始之前被删除的问题。
这个例子比我实际需要做的要简单一些。这是一个更好的例子......在完成A之后，我现在需要获取一系列事物并遍历每个事物并运行B。然后从前面我说我有C和D，它们是从B产生的。 ..但我什至还没有进入C和D部分，因为这已经变得很复杂了。
Queue::push(function($jobA) use ($id)
{
$statusA = ProcessA::doStuff($id);
if($statusA)
{
$things = getThings($id);
foreach($things as $thing)
{
Queue::push(function($jobB) use ($thing)
{
ProcessB::doStuff($thing);
$jobB->delete();
});
}
}
$jobA->delete();
});
所以嵌套闭包仍然不起作用。我的下一步是不嵌套闭包，而是编写类。要开始我必须做的 A 过程
Queue::push('ProcessA', array('id' => $id));
然后
class ProcessA {
public function fire($job, $data)
{
$things = getThings($data['id']);
foreach($things as $thing)
{
Queue::push('ProcessB', array('thing' => $thing));
}
$job->delete();
}
}
然后
class ProcessB {
public function fire($job, $thing)
{
Queue::push('ProcessC', array('id' => $thing['id']));
Queue::push('ProcessD', array('id' => $thing['id']));
}
$job->delete();
}
ProcessC 和 ProcessD 在这一点上是无关紧要的，只要它们运行。这种方法似乎有效，但我认为有时当 processA 在 ProcessB 生成之前完全完成时我会遇到问题。弄清楚这些事情是漫长的一天，也许这确实工作正常......需要进行更多测试。
由于 Laravel 或 PHP 5.4 中的自动加载魔法，此方法还需要我为正在运行的每个 ProcessA/B/C/DI 创建一个单独的文件。正如你所看到的，每一个都很短。这似乎是一种相当复杂的做事方式。
- 这种方法在任何方面似乎都有缺陷吗？
- 我应该以其他方式这样做吗？
- 我是否应该将其初始化为工匠命令并切换到路由并使用 curl 调用它们？
- 有没有办法让嵌套闭包工作？