0

我升级到 Symfony 3.4.* 以利用新的锁组件。然而,它似乎在开发中工作,但在生产中总是获得锁。这是我的代码:

BaseCommandWrapper:

<?php
namespace CoreBundle\Command;

ini_set('max_execution_time', 3600); 

use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Lock\Factory;
use Symfony\Component\Lock\Store\SemaphoreStore;

use Symfony\Component\Console\Command\LockableTrait;

class BaseCommandWrapper extends ContainerAwareCommand {

    use LockableTrait;

    function start($commandName) {

        $this->commandName = $commandName;

        $store = new SemaphoreStore();
        $factory = new Factory($store);

        $this->lock = $factory->createLock($this->commandName);

        if (!$this->lock->acquire()) {
            echo 'This command is already running in another process.' . PHP_EOL;
            return false;
        }

        echo "Lock aquired" . PHP_EOL;

        return $this->lock;
    }

    function stop() {

        echo "Releasing lock" . PHP_EOL;

        $this->lock->release();

    }

}


?>

命令本身:

class SomeCommand extends BaseCommandWrapper
{
    protected function configure()
    {
        $this
            ->setName('processSomeCommand')
            ->setDescription('Process Some Command')
        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {

        if ($this->start($this->getName()) === false) {
            return 0;
        } 

        sleep(60);

        $this->stop();

    }

所有命令都由 cron 触发,在这种情况下每秒触发一次。

4

1 回答 1

0

它可能链接到 systemd RemoveIPC 参数:

RemoveIPC= 控制是否在用户完全注销时删除属于用户的 System V 和 POSIX IPC 对象。接受一个布尔参数。如果启用,用户可能不会在用户的最后一个会话终止后消耗 IPC 资源。这包括 System V 信号量、共享内存和消息队列,以及 POSIX 共享内存和消息队列。请注意,root 用户和其他系统用户的 IPC 对象不受此设置的影响。默认为“是”。

如果您使用的是 systemd,那么每次 cron 结束时,用户都会注销,并且 systemd 会删除信号量。

  • 第一个 Cron 获取锁
  • 第二个 Cron 获取锁失败,用户注销,信号量被移除
  • Thris Cron 获得锁/First Cron 不再拥有它。

正如本线程中所讨论的,您可以在服务器上禁用 RemoveIPC,或者使用系统用户来避免这种情况。或者正如您在评论中所说:使用另一个商店。

最有可能的是,您应该收到警告:

PHP 警告:sem_remove(): SysV 信号量 14071[redacted]0096 不(不再)存在于第 95 行的 [redacted]/app/vendor/symfony/lock/Store/SemaphoreStore.php

其他人遇到了这个问题:在这个线程中,他们很可能应该将它添加到文档中。

于 2020-01-28T22:10:09.177 回答