在開發需要處理并發執行的應用程序時，確保關鍵代碼段的互斥訪問是至關重要的。最近，我在開發一個需要處理多個用戶同時訪問銀行賬戶余額的系統時，遇到了一個棘手的問題：多個用戶同時嘗試更新賬戶余額，導致數據不一致。我嘗試了多種方法來解決這個問題，但效果不佳。直到我發現了 malkusch/lock 庫，才真正解決了我的困擾。
malkusch/lock 是一個用于 php 的互斥鎖庫，通過 Composer 可以輕松安裝：
composer require malkusch/lock
這個庫提供了幾種鎖的實現方式，包括 FlockMutex、MemcachedMutex、redisMutex、SemaphoreMutex、mysqlMutex、PostgreSQLMutex 和 DistributedMutex。這些實現可以根據你的需求選擇，確保在并發環境中，關鍵代碼段只能被一個進程或線程執行。
以下是一個使用 redisMutex 的簡單示例，展示如何確保銀行賬戶余額的更新操作互斥執行：
use MalkuschLockMutexRedisMutex; $redis = new Redis(); $redis->connect('localhost'); $mutex = new RedisMutex($redis, 'balance'); $newBalance = $mutex->synchronized(static function () use ($bankAccount, $amount) { $balance = $bankAccount->getBalance(); $balance -= $amount; if ($balance < 0) { throw new DomainException('You have no credit'); } $bankAccount->setBalance($balance); return $balance; });
在這個例子中，$mutex->synchronized() 方法確保了代碼塊在任何時刻只能被一個進程執行，避免了多個用戶同時更新余額導致的數據不一致問題。
此外，malkusch/lock 庫還支持雙重檢查鎖定模式，通過 check() 和 then() 方法，可以在鎖定之前先進行條件檢查，進一步優化性能和資源使用：
use MalkuschLockMutexRedisMutex; use MalkuschLockUtilDoubleCheckedLocking; $redis = new Redis(); $redis->connect('localhost'); $mutex = new RedisMutex($redis, 'balance'); $newBalance = $mutex->check(static function () use ($bankAccount, $amount): bool { return $bankAccount->getBalance() >= $amount; })->then(static function () use ($bankAccount, $amount) { $balance = $bankAccount->getBalance(); $balance -= $amount; $bankAccount->setBalance($balance); return $balance; });
在這個例子中，只有當賬戶余額足夠時，才會嘗試獲取鎖并執行更新操作，避免了不必要的鎖等待。
使用 malkusch/lock 庫不僅解決了我的并發問題，還大大簡化了代碼，提高了系統的可靠性和性能。如果你也面臨類似的并發執行問題，強烈推薦嘗試這個庫。
? 版權聲明
文章版權歸作者所有，未經允許請勿轉載。
THE END
