使用 Supervisor 处理 Symfony 命令执行

首页 > 编程 > 使用 Supervisor 处理 Symfony 命令执行

使用 Supervisor 处理 Symfony 命令执行

发布于2024-11-01

介绍

在这篇文章中，我们将学习如何使用supervisord来处理symfony命令的执行。基本上，supervisord 将允许我们：

自动启动命令
自动重启命令
指定我们希望主管启动的进程数。

问题

有时我们会使用 unix crontab 来自动执行进程。这可能在大多数情况下有效，但在某些情况下可能会导致问题。

假设我们有一个记录用户通知的数据库表。该表存储以下信息：

用户
文本
渠道
状态（等待，已发送）
创建于
更新于

另一方面，我们编写了一个命令，其执行遵循以下步骤：

查询最近的WAITING通知
循环查询的通知并且：
- 将每一个发送给相应的用户。
- 将通知状态从 WAITING 更新为 SENT

我们在 Linux crontab 中设置此命令每隔一段时间运行一次（1 分钟、2 分钟等）。到目前为止，一切都很好。

现在让我们想象一下当前进程已经查询了 500 个通知，当它发送了 400 个通知时，一个新进程启动。这意味着新进程将查询上一个进程尚未更新的 100 条通知以及新的通知：

Using Supervisor to handle a Symfony Command execution

这可能会导致这 100 个通知发送两次，因为两个进程都查询了它们。

解决方案

作为解决方案，我们可以求助于使用supervisor。它将保持我们的进程运行并在需要时重新启动它。这样，我们只保留一个进程并避免重叠。让我们分析一下命令应该是什么样子：

#[AsCommand(
    name: 'app:notification'
)]
class NotificationCommand extends Command
{
    private bool $forceFinish = false;

    protected function configure(): void
    {
        $this
            ->addOption('time-limit', null, InputOption::VALUE_OPTIONAL, 'Max time alive in seconds')
            ->addOption('time-between-calls', null, InputOption::VALUE_OPTIONAL, 'Time between every loop call')

        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $this->forceFinish = false;
        pcntl_signal(SIGTERM, [$this, 'signalHandler']);
        pcntl_signal(SIGINT, [$this, 'signalHandler']);

        $timeLimit = $input->getOption('time-limit');
        $timeBetweenCalls = $input->getOption('time-between-calls');
        $dtMax = (new \DateTimeImmutable())->add(\DateInterval::createFromDateString("  {$timeLimit} seconds"));

        do{
           // Here we should execute a service to query and send notifications
           // ......

           sleep($timeBetweenCalls);
           $dtCurrent = new \DateTimeImmutable();

        }while($dtCurrent forceFinish);

        return Command::SUCCESS;
    }

    public function signalHandler(int $signalNumber): void
    {
        echo 'Signal catch: ' . $signalNumber . PHP_EOL;
        match ($signalNumber) {
            SIGTERM, SIGINT => $this->forceFinish = true,
            default => null
        };
    }
}

我们来一步步解释一下命令：

configure方法声明输入选项：
- time-limit：命令进程可以存活的最长时间。之后，它将完成，主管将重新启动它。
- time- Between-calls：每次循环迭代后的睡眠时间。该循环调用处理通知的服务，然后在此期间休眠。
execute方法的行为如下：
- 将 forceFinish 类变量设置为 true
- 使用 PHP pnctl 库注册方法 signalHandler 来处理 Unix SIGTERM 和 SIGINT 信号。
- 获取输入选项值并计算命令可以有效的最大日期，直到使用时间限制选项值。
- do-while 循环执行所需的代码来获取通知并发送通知（它没有放在命令中，而是有注释）。然后，它会休眠由 time- Between-calls 选项建立的时间，然后再继续。
- 如果当前日期（在每次循环迭代中计算）低于最大日期并且 forceFinish 为 false，则循环继续。否则命令完成。
signalHandler函数捕获SIGTERM和SIGINT Unix信号。 SIGINT是当我们按下Ctrl C时发送的信号，SIGTERM是当我们使用kill命令时的默认信号。当 signalHandler 函数检测到它们时，它将 forceFinish 变量设置为 true，这样，当当前循环结束时，命令将完成，因为 forceFinish 变量为不再虚假。这允许用户终止进程，而不必等到最大日期完成。

配置主管

到目前为止，我们已经创建了命令。现在是时候设置主管了，以便它可以处理它。在开始配置之前，我们必须安装supervisor。您可以运行以下命令来完成此操作：

sudo apt update && sudo apt install supervisor

安装后，您可以通过执行以下命令来确保supervisor正在运行：

sudo systemctl status supervisor

Supervisor配置文件放置在以下文件夹中：/etc/supervisor/conf.d。让我们创建一个名为 notif.conf 的文件并粘贴以下内容：

command=php /bin/console app:notifications --time-limit=120 --time-between-calls=10
user=
numprocs=1
autostart=true
autorestart=true
process_name=%(program_name)s_%(process_num)02d

让我们解释一下每个键：