Symfony 2 CronJob

Question

您好，我在控制器中有一个功能：

if (!function_exists("ssh2_connect"))
die("function ssh2_connect doesn't exist");

if (!($con = ssh2_connect("myipadresherenotshowingtoyouguys", 22))) {
echo "fail: unable to establish connection\n";
} else {
// try to authenticate with username root, password secretpassword
if (!ssh2_auth_password($con, "blablabla", "blablabla!")) {
    echo "fail: unable to authenticate\n";
} else {
    // allright, we're in!
    echo "okay: logged in...\n";

    // execute a command
    $command = 'ssid "Wentzo test2" hide-ssid';
    if (!($stream = ssh2_exec($con, $command))) {
        echo "fail: unable to execute command\n";
    } else {

        $stream2 = ssh2_exec($con, $command_save);
        // collect returning data from command
        stream_set_blocking($stream, true);
        $data = "";
        while ($buf = fread($stream, 4096)) {
            $data .= $buf;
        }

        fclose($stream);
    }
}
}

我想在按下提交按钮时将此脚本作为 cronjob 运行。 但我不知道如何在 symfony 2 中做到这一点。

有人有解决方案吗？ 可能是例子？

Answer 1

您正在寻找的概念是排队。

我建议您使用 Beanstalkd、RabbitMQ 或任何其他排队系统来处理此问题。

我们的想法是将处理方法放入 Symfony 命令中： http://symfony.com/doc/current/components/console/introduction.html#creating-a-basic-command

在该命令中，您将从队列中读取，并根据队列中的“作业”运行进程。

在您的控制器中，您唯一要做的就是将新作业推送到该队列中。该作业将包含一些数据，您可以在命令中使用这些数据进行处理。

要进一步了解这个概念，您可以浏览这些幻灯片：http://www.slideshare.net/cakper/2014-0821-symfony-uk-meetup-scaling-symfony2-apps-with-rabbit-mq

您可能还想了解更多有关排队概念的信息。

由于某种原因，我找不到关于 Symfony2 和排队的好教程。