競争の激しいアプリケーションでは、レース条件はデータの整合性の静かな殺人者です。予約システムで二重予約を防ぐこと、Cron ワークを 1 つのサーバーで実行することを保証すること、または API の使用を妨げること、 あなたの防衛の第一線です。 Symfony Lock Component 釈放の後、 , エコシステムが成熟し、クリーンな属性、クラウドネイティブストアとのより良い統合(例えば、 )とPHP 8.4のサポート この記事は、私が生産に使用する戦闘テストのベストプラクティスをカバーし、あなたのアプリケーションが強力でブロックフリーであることを保証します。 Symfony 7.4 DynamoDB インストールと構成 コンポーネントをインストールすることから始めます. We will use the standard パッケージ. Redis (分散システムで推奨) を使用する予定がある場合は、クライアントが OR 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 jobs のローカル ファイル vs. 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)%'
 The Golden Rule: The Try-Finally Pattern(ゴールデンルール) ロックで作業する際に最も重要なルールは、コードが故障した場合でも、ロックがリリースされることを確認することです。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
    }
}
 この機能を確認するには、開発中にトライブロックの内部に例外を投げる。 
 
 
 
 ロックを購入。 Throw new \Exception(『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 を使用してローカルに移動し、単一のマシンで実行している場合、最小限のオーバーヘッドで最大速度が必要です。 Go Distributed with Redis for most modern web applications, where multiple nodes need to coordinate quickly. ほとんどの現代のウェブアプリケーションで、複数のノードが迅速に調整する必要があります。 DynamoDB を使用して Cloud-Native に移行する場合、Redis のようなキャッシュへの永続的な接続を維持することは非効率的なサーバーレス環境で構築しています。 Kubernetes で実行している場合は、アプリケーションレベルのロックのために Flock または Semaphore を使用しないでください. Always use Redis, Memcached, or Database stores (PDO/DynamoDB). Declarative Locking with Attributes(アトラブティブ) Symfony 7.4 + PHP 8.x では、コントローラを大幅にクリアできます。 それぞれのコントローラーに、私たちはコードを作成することができます。 これは、ドメインの論理をきれいに保つ「Senior Developer」パターンです。 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
    ) {}
}
 Event Listenerを作成する We use the kernel events to acquire the lock before the controller executes and release it afterwards. コネルのイベントを使用して、コントローラが実行する前にロックを取得し、その後リリースします。 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');
    }
 Long-Running Tasks: The refresh() Method(リフレッシュ()メソッド) タスクが 31 秒かかりますが、ロック TTL が 30 秒の場合、ロックは終了し、別のプロセスが起動し、データを損なう可能性があります。 故障が発生した場合にシステムをブロックする巨大な TTL (例えば、1 時間) を設定する代わりに、より短い TTL を使用してそれをリフレッシュします。 $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)。 ブロック vs. 非ブロック デフォルトで、 リソースが忙しい場合は直ちに false を返します. Pass true to wait indefinitely: acquire() // Wait forever until lock is free
$lock->acquire(true);
 HTTP リクエストにおける無期限のブロックを避けます. It links up your PHP-FPM workers and can lead to a 504 Gateway Timeout. Use a loop with a timeout for better control: 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
}
 結論 使用する The コンポーネントはファイルを「ロックする」ことだけでなく、アーキテクチャ的な意図のことです。 symfony/lock 
 
 
 
 
 常に Named Lockers を使用する: ロックストアをドメイン(オーダー、Cron、ユーザー)によって分割します。 リモートストアを好む: Redis または DynamoDB を使用して、1 つ以上のサーバー上で実行されているアプリケーションに使用します。 Clean Code: Attribute パターンを採用して、コントローラから boilerplate を削除します。 安全第一:試用ブロックは交渉できない。 競合バグは複製しにくいが、これらのパターンを今日実装すると、明日のデバッグの時間を節約できます。 完全な実装とプロジェクトの進捗状況を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

フロキのヴァルハラがインドのスリランカツアーのアソシエイトスポンサーに加わる

AI/ML データレイクのリファレンスアーキテクチャを構築するためのアーキテクトガイド

Claude Sonnet 3.5 システムプロンプトの漏洩: 法医学的分析

フォーラムからフィードへ: ソーシャルメディアアルゴリズムがデジタルインタラクションを形作る仕組み

フロキのヴァルハラがインドのスリランカツアーのアソシエイトスポンサーに加わる

AI/ML データレイクのリファレンスアーキテクチャを構築するためのアーキテクトガイド

Claude Sonnet 3.5 システムプロンプトの漏洩: 法医学的分析

フォーラムからフィードへ: ソーシャルメディアアルゴリズムがデジタルインタラクションを形作る仕組み

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps