在竞争激烈的应用中,比赛条件是数据完整性的沉默杀手,无论是防止预订系统中的双重预订,确保 cron 工作只在一个服务器上运行,还是阻止 API 使用, 这是你的第一道防线。 Symfony Lock Component 随着释放的 ,生态系统成熟了,提供更清洁的属性,更好地与云本地商店集成(如 本文涵盖了我在生产中使用的战斗测试的最佳实践,确保您的应用程序保持强大和无僵局。 Symfony 7.4 DynamoDB 安装与配置 开始安装组件,我们将使用标准 如果您打算使用 Redis (推荐用于分布式系统),请确保您有一个客户端,如 或 The 扩展。 symfony/lock predis/predis ext-redis composer require symfony/lock
# If using Redis
composer require predis/predis
# If using the new DynamoDB store (Symfony 7.4+)
composer require symfony/amazon-dynamo-db-lock
 配置 在 定义你的“ .” 一个常见的错误是使用一个默认商店为一切。 用于不同的业务域,以避免碰撞,并允许不同的存储策略(例如,用于 cron 工作的本地文件,而用于用户操作的 Redis)。 config/packages/lock.yaml lockers named lockers framework:
    lock:
        # Default store (good for single-server setups)
        enabled: true

        # Named lockers
        resources:
            # Critical business locks (Distributed)
            order_processing: '%env(REDIS_DSN)%'

            # CLI command locks (Local is usually fine)
            cron_jobs:
                - 'flock'

            # New in 7.4: DynamoDB for serverless architectures
            # This is commented out as it requires AWS credentials and the symfony/amazon-dynamo-db-lock package.
            # To use it, install the package and configure your AWS credentials.
            # invoice_generation:
            #     - 'dynamodb://default/lock_table'

            # For the attribute example, we'll just use redis.
            invoice_generation: '%env(REDIS_DSN)%'
 黄金规则:最终试图模式 处理锁时最重要的一个规则是确保它们被释放,即使你的代码崩溃. 虽然 Symfony 试图在对象破坏时自动释放锁,但你绝不应该依赖关键资源的暗示行为。 模式 始终将您的关键部分包裹在试用块中,并最终释放。 namespace App\Service;

use Psr\Log\LoggerInterface;
use Symfony\Component\DependencyInjection\Attribute\Target;
use Symfony\Component\Lock\LockFactory;

readonly class OrderProcessor
{
    public function __construct(
        #[Target('order_processing')]
        private LockFactory     $lockFactory,
        private LoggerInterface $logger,
    ) {}

    public function processOrder(int $orderId, bool $crash = false): void
    {
        // The resource name should be unique for each order.
        $lock = $this->lockFactory->createLock('order_' . $orderId, 30);

        $this->logger->info(sprintf('Attempting to acquire lock for order %d.', $orderId));

        if (!$lock->acquire()) {
            // Fail fast if another process is already handling this order.
            $this->logger->warning(sprintf('Order %d is already being processed.', $orderId));
            throw new \RuntimeException(sprintf('Order %d is already being processed.', $orderId));
        }

        $this->logger->info(sprintf('Lock acquired for order %d.', $orderId));

        try {
            // CRITICAL SECTION
            // This is where you would perform payment capture, inventory updates, etc.
            $this->logger->info(sprintf('Processing order %d. This will take a few seconds.', $orderId));
            sleep(5); // Simulate work

            if ($crash) {
                $this->logger->error(sprintf('Simulating a crash while processing order %d.', $orderId));
                throw new \Exception('Something went wrong! The payment gateway is down.');
            }

            $this->chargeUser($orderId);
            $this->logger->info(sprintf('Finished processing order %d.', $orderId));

        } finally {
            $this->logger->info(sprintf('Releasing lock for order %d.', $orderId));
            $lock->release();
        }
    }

    private function chargeUser(int $id): void
    {
        // In a real application, this would interact with a payment service.
        $this->logger->info(sprintf('Charging user for order %d.', $id));
        // ... payment logic
    }
}
 要验证此功能,在开发过程中将例外扔进试用区块中。 
 
 
 
 买了锁。 扔新的“例外”(“Crash!”)。 检查您的存储空间(例如,Redis KEYS *)。锁键应该在例外被内核捕捉或泡沫后立即消失。 选择合适的商店 选择错误的商店是一个常见的建筑缺陷。 +----------+--------------------------------------+---------------------------------------+-----------------------------------------------------------+
| Store    | Use Case                             | Pros                                  | Cons                                                      |
+----------+--------------------------------------+---------------------------------------+-----------------------------------------------------------+
| Flock    | Single-server cron jobs, local dev.  | Zero dependency, persistent on disk.  | Fails in Kubernetes/Docker Swarm (filesystems aren't shared). |
+----------+--------------------------------------+---------------------------------------+-----------------------------------------------------------+
| Redis    | Distributed apps, user requests,     | Extremely fast, supports TTL.         | Requires Redis. Volatile (locks lost if Redis             |
|          | API limits.                          |                                       | crashes without AOF).                                     |
+----------+--------------------------------------+---------------------------------------+-----------------------------------------------------------+
| Semaphore| Local high-performance IPC.          | Fastest for local processes.          | OS-dependent constraints. Hard to debug.                  |
+----------+--------------------------------------+---------------------------------------+-----------------------------------------------------------+
| DynamoDB | Serverless / AWS Lambda environments.| Highly available, no server management.| Higher latency than Redis (network roundtrip).            |
+----------+--------------------------------------+---------------------------------------+-----------------------------------------------------------+
 
 
 
 
 使用 Flock 或 Semaphore 进行本地操作,如果您在单台机器上运行,并且需要最大速度,最低限度的超速。 适用于大多数现代Web应用程序,其中多个节点需要快速协调。 如果您正在构建在无服务器环境中,则使用 DynamoDB 使用 Cloud-Native 来保持与 Redis 等缓存的持久连接是不有效的。 如果您使用的是 Kubernetes,请永远不要使用 Flock 或 Semaphore 来锁定应用程序级别,也不要使用 Redis、Memcached 或数据库存储(PDO/DynamoDB)。 具有属性的声明锁定 在Symfony 7.4 + PHP 8.x中,我们可以显著清理我们的控制器。 在每个控制器中,我们可以创建一个习惯 属性. 这是一个“高级开发人员”模式,使您的域逻辑保持干净。 LockFactory #[Lock] 创建属性 namespace App\Attribute;

use Attribute;

#[Attribute(Attribute::TARGET_METHOD)]
final class Lock
{
    public function __construct(
        public string $resourceName,
        public int $ttl = 30,
        public bool $blocking = false
    ) {}
}
 创建事件倾听器 我们使用内核事件在控制器执行之前获得锁,然后释放它。 namespace App\EventListener;

use App\Attribute\Lock;
use Symfony\Component\EventDispatcher\Attribute\AsEventListener;
use Symfony\Component\HttpKernel\Event\ControllerEvent;
use Symfony\Component\HttpKernel\Event\TerminateEvent;
use Symfony\Component\HttpKernel\KernelEvents;
use Symfony\Component\Lock\LockFactory;
use Symfony\Component\Lock\LockInterface;
use Symfony\Component\HttpKernel\Exception\TooManyRequestsHttpException;
use Psr\Log\LoggerInterface;
use Symfony\Component\DependencyInjection\Attribute\Target;

class LockAttributeListener
{
    private \WeakMap $locks;

    public function __construct(
        #[Target('invoice_generation')]
        private readonly LockFactory $lockFactory,
        private readonly LoggerInterface $logger,
    ) {
        $this->locks = new \WeakMap();
    }

    #[AsEventListener(event: KernelEvents::CONTROLLER)]
    public function onKernelController(ControllerEvent $event): void
    {
        $attributes = $event->getAttributes();
        if (!isset($attributes[Lock::class])) {
            return;
        }

        /** @var Lock $lockAttr */
        $lockAttr = $attributes[Lock::class][0];

        $request = $event->getRequest();
        $resource = $lockAttr->resourceName;

        // Simple interpolation for request attributes (e.g., 'invoice_{id}')
        foreach ($request->attributes->all() as $key => $value) {
            if (is_scalar($value)) {
                $resource = str_replace("{{$key}}", (string) $value, $resource);
            }
        }

        $this->logger->info(sprintf('Attempting to acquire lock for resource "%s".', $resource));

        $lock = $this->lockFactory->createLock($resource, $lockAttr->ttl);

        if (!$lock->acquire($lockAttr->blocking)) {
            $this->logger->warning(sprintf('Resource "%s" is currently locked.', $resource));
            throw new TooManyRequestsHttpException(null, 'Resource is currently locked.');
        }

        $this->logger->info(sprintf('Lock acquired for resource "%s".', $resource));

        // Store lock to release it later
        $this->locks[$event->getRequest()] = $lock;
    }

    #[AsEventListener(event: KernelEvents::TERMINATE)]
    public function onKernelTerminate(TerminateEvent $event): void
    {
        $request = $event->getRequest();
        if (isset($this->locks[$request])) {
            /** @var LockInterface $lock */
            $lock = $this->locks[$request];
            $resource = 'unknown'; // Can't easily get the resource name back from the lock object

            $this->logger->info(sprintf('Releasing lock for request to "%s".', $request->getPathInfo()));
            $lock->release();
            unset($this->locks[$request]);
        }
    }
}
 在您的控制器中使用它 现在,您的控制器是干净的,可读的,安全的。 namespace App\Controller;

use App\Attribute\Lock;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Attribute\Route;

class InvoiceController extends AbstractController
{
    #[Route('/invoice/{id}/generate', name: 'invoice_generate')]
    #[Lock(resourceName: 'invoice_{id}', ttl: 60)]
    public function generate(int $id): Response
    {
        // This code executes ONLY if the lock is acquired
        // ... heavy generation logic ...
        
        return new Response('Invoice generated');
    }
 处理长期任务:更新( )方法 如果你的任务需要 31 秒,但你的锁定 TTL 是 30 秒,锁定将到期,允许另一个进程启动,可能损坏数据。 使用更短的 TTL (例如, 1 小时),如果发生故障,将系统阻止。 $lock = $factory->createLock('import_job', ttl: 30);
$lock->acquire(blocking: true);

try {
    foreach ($largeDataSet as $row) {
        $this->processRow($row);
        
        // Extend the lock by another 30 seconds
        $lock->refresh(); 
    }
} finally {
    $lock->release();
}
 Verification: 
 
 
 
 设置 5 秒的 TTL。 运行一个循环,睡眠2秒钟,并呼叫更新()。 监控你的商店的到期时间(例如,Redis TTL lock_key)。你应该看到它重复重置到30s,永远不会下降到0。 封锁 vs. 非封锁 由于故障, 它会立即返回假的,如果资源忙碌。 通过 true 等待无限期: acquire() // Wait forever until lock is free
$lock->acquire(true);
 在 HTTP 请求中避免无限期封锁,它将您的 PHP-FPM 员工联系起来,并可能导致 504 Gateway Timeout。 Best Practice: $maxRetries = 5;
$retryCount = 0;

while (!$lock->acquire()) {
    if ($retryCount++ >= $maxRetries) {
        throw new \Exception('Could not acquire lock after 5 attempts');
    }
    sleep(1); // Wait 1 second before retrying
}
 结论 使用的 组件不仅仅是关于“锁定”文件;它是关于建筑意图。 symfony/lock 
 
 
 
 
 始终使用命名锁定器:按域(订单、Cron、用户)分离锁定库。 偏好远程商店:在一个以上服务器上运行的任何应用程序中使用 Redis 或 DynamoDB。 清洁代码:采用属性模式,从控制器中删除锅炉板。 安全第一:试验最后的块是不可谈判的。 竞争对手的错误是难以复制的,今天实施这些模式将节省你明天的调试时间。 您可以在GitHub上找到完整的实施并跟踪项目的进展: ] Source Code: https://github.com/mattleads/SymfonyLockSample https://github.com/mattleads/SymfonyLockSample 让我们连接! 如果您觉得这是有用的,或者您对实施有任何问题,我很乐意从您那里听到,让我们保持联系,并在这些平台上保持对话: 
 
 
 
 
 联系人: [https://www.linkedin.com/in/matthew-mochalkin/] 马克思(Twitter): [https://x.com/MattLeads] 电报: [https://t.me/MattLeads] GitHub: [https://github.com/mattleads] https://www.linkedin.com/in/matthew-mochalkin/ https://x.com/MattLeads https://t.me/MattLeads https://github.com/mattleads

This story contains AI-generated text. The author has used AI either for research, to generate outlines, or write the text itself. 

Read My Stories

該音頻是用故事的原始語言製作的！

如何掌握竞争力:对Symfony 7.4的锁定组件的最佳实践

About Author

註釋

標籤

这篇文章刊登在

Related Stories

使用这 18 种开发工具来提高你的工作效率 🚀🔥

扬帆起航：利用数据湖开发生产级 RAG 应用程序

加密货币增长：创建有效的用户角色

Floki 的 Valhalla 成为印度环斯里兰卡赛事联合赞助商

使用这 18 种开发工具来提高你的工作效率 🚀🔥

扬帆起航：利用数据湖开发生产级 RAG 应用程序

加密货币增长：创建有效的用户角色

Floki 的 Valhalla 成为印度环斯里兰卡赛事联合赞助商

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps