如何进行cakephp并行处理并用回调返回api响应？

Question

我正试图用CakePHP3制作一个api。有了这个api，我将向系统发送一些批量电子邮件的信息。在将api请求存储到databse中之后，我希望返回已收到请求的确认并开始批处理。完成处理后，我想发送一个回调响应来返回处理状态。在我目前的编码系统中，我必须等待完成这个过程。我怎么能并行地做呢？

    // Store api request to database
    $saveQueue = EmailQueue::enqueue($to, $data, $options);

    if ($saveQueue) {
        $this->Flash->success('Request saved in queue.');

        $shell = new ShellDispatcher();
        $output = $shell->run(['cake', 'EmailQueue.sender']);

        if (0 === $output) {
            $this->Flash->success('Success from shell command.');
        } else {
            $this->Flash->error('Failure from shell command.');
        }
        return;

    }
    $this->Flash->error('Failed to save in queue.'); 

[我不确定实际问题的标题应该是什么，请随意编辑。:)]

Answer 1

你的系统被设计破坏了。不要在web环境中使用shell。他们是两个不同的世界。老实说，我懒得写一个详尽的解释这种方法还有什么问题，但这里有一个适当的答案：

1. API通过POST接收数据
2. 应用程序创建任务并将其放入队列
3. API响应类似“OK job put in queue,这是您的作业ID”
4. 在服务器后台（而不是在请求中）运行的shell正在处理队列

现在有两种选择：

null