如今，企业正在开发高流量 ASP.NET核心 满足无数并发用户的 Web 应用程序。在集群架构中 负载均衡 应用服务器，多个客户端可以访问缓存数据。在这种情况下，当多个用户尝试访问和更改同一数据时，就会发生竞争条件（当两个或多个用户尝试同时查看和编辑同一共享数据时）。
此类竞争条件通常会导致 数据不一致 和完整性问题。此外，这对依赖实时数据准确性的应用程序构成了风险。幸运的是， NCache，企业可以利用分布式 锁定 确保可扩展内存缓存环境中强大数据一致性的机制。
关键精华
- 赛跑条件预防： 分布式锁定通过确保多个并发客户端不能同时修改相同的缓存数据来消除数据不一致。
- 乐观锁定（版本控制）： 利用内部项目版本控制在更新前验证数据。这种方式性能卓越，非常适合数据冲突较少的环境。
- 悲观锁定（独家）： 使用 LockHandle 在源端显式锁定数据项。这最适合处理关键数据，因为在这种情况下，严格的数据一致性比最大吞吐量更重要。
- 可扩展一致性： NCache 在集群环境中提供这些机制，确保锁定逻辑在所有缓存节点上同步，而不仅仅是在单个服务器上同步。
- 战略实施： 选择哪种方式取决于您的工作负载。对于读取密集型应用程序，您可以使用乐观锁定来保持速度；对于写入密集型应用程序，您可以使用悲观锁定来确保数据完整性。
用于数据一致性的分布式锁定
的帮助下 NCache“ 分布式锁定 机制，您可以在并发更新期间锁定特定缓存项。这可以防止竞争情况，因为一次只有一个进程可以修改一个项目，从而确保数据完整性。
NCache 提供两种类型的锁定：
为什么分布式锁定对于数据一致性至关重要？
考虑一个银行应用程序，其中两个用户访问同一个银行账户，账户余额为 30,000。一个用户提取 15,000，而另一个用户存入 5,000。如果不处理竞争条件，最终余额可能会错误地变为 15,000 或 35,000，而不是预期的 20,000。
竞争条件细分：
- 时间t1： 用户 1 获取余额 = 30,000 的银行账户
- 时间t2： 用户 2 获取余额 = 30,000 的银行账户
- 时间t3： 用户1提现15,000，更新余额=15,000
- 时间t4： 用户 2 存入 5,000 并更新余额 = 35,000
为了防止此类情况发生， NCache“ 锁定 机制确保您的应用程序逻辑是线程安全的，并且每次只允许一次更新。
乐观锁定（缓存项版本）
乐观锁定 使用 缓存项版本控制 管理并发更新。每个缓存对象都有一个版本号，每次修改时版本号都会递增。在更新缓存项之前，应用程序会检索其版本号并在保存任何修改之前对其进行验证。如果在此期间另一个更新更改了版本，则拒绝该更新以保持数据完整性。
图 1：乐观锁序列图
实现乐观锁定 NCache
若要实现乐观锁，请参考下面的代码示例：
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 |
//The following C# example demonstrates version-based updates where the "Insert" operation succeeds only if the "version" matches the server-side value. using Alachisoft.NCache.Client; ICache cache = CacheManager.GetCache("myCache"); string key = "order:456"; // Retrieve item with version CacheItem cacheItem = cache.GetCacheItem(key); long version = cacheItem.Version; // Modify data Order order = (Order)cacheItem.Value; order.Status = "Shipped"; try { // Update only if the version matches cache.Insert(key, new CacheItem(order), version); Console.WriteLine("Update successful."); } catch (OperationFailedException ex) { Console.WriteLine("Optimistic lock failed: " + ex.Message); } |
悲观锁定（排他锁定）
悲观锁 阻止其他用户修改缓存项，直到锁定被释放。这种方法在需要严格控制数据修改的场景中非常有用。
图 2：悲观锁定序列图
实现悲观锁定 NCache
实现悲观锁定 NCache，请参见下面的代码示例：
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
//This snippet shows how to acquire an explicit lock using "AcquireLock", ensuring no other thread can modify the item until "ReleaseLock" is called. using Alachisoft.NCache.Client; using Alachisoft.NCache.Runtime.Exceptions; ICache cache = CacheManager.GetCache("myCache"); string key = "customer:123"; LockHandle lockHandle = new LockHandle(); try { // Acquire lock with a timeout cache.AcquireLock(key, TimeSpan.FromSeconds(10), out lockHandle); // Perform operations while holding the lock Customer customer = (Customer)cache.Get(key, lockHandle); customer.Name = "Updated Name"; cache.Insert(key, new CacheItem(customer), lockHandle); } catch (LockingException ex) { Console.WriteLine("Lock acquisition failed: " + ex.Message); } finally { // Release the lock cache.ReleaseLock(key, lockHandle); } |
获取期间锁定以及插入时释放锁定
另一种悲观锁定方法是在以下情况下锁定项目： 正在取得 它和 释放 更新项目时锁定。这可确保获取的数据在更新完成之前保持不变。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
using Alachisoft.NCache.Client; using Alachisoft.NCache.Runtime.Exceptions; ICache cache = CacheManager.GetCache("myCache"); string key = "product:789"; LockHandle lockHandle = new LockHandle(); try { // Lock item during Get operation Product product = (Product)cache.Get(key, TimeSpan.FromSeconds(10), out lockHandle); // Modify the product data product.Price += 10; // Update item and release the lock cache.Insert(key, new CacheItem(product), lockHandle, true); } catch (LockingException ex) { Console.WriteLine("Lock operation failed: " + ex.Message); } finally { // Ensure the lock is released if not already released cache.ReleaseLock(key, lockHandle); } |
| 特性 | 乐观锁定（版本控制） | 悲观锁定（独家） |
| 核心机制 | 使用项目版本控制。系统会检查自上次获取以来版本是否已更改。 | 使用 LockHandle。系统会在设定的时间内授予单个用户独占访问权限。 |
| 并发级别 | 高。多个用户可以同时读取和尝试更新，而不会发生阻塞。 | 低。一次只能有一位用户访问该物品进行修改；其他用户必须等待。 |
| 性能影响 | 极简设计。服务器上不设任何物理锁，确保最大吞吐量。 | 中等至高风险。如果锁长时间保持开启状态或争用程度较高，可能会导致瓶颈。 |
| 处理冲突 | 如果版本不匹配，则更新失败，应用程序必须重试（冲突检测）。 | 通过阻止其他用户直到锁定解除来防止冲突（冲突预防）。 |
| 理想的用例 | 读取密集型/低竞争。例如：产品目录、用户配置文件或配置数据。 | 写入量大/完整性高。例如：财务余额、库存盘点或座位预订。 |
结语
通过雇用 NCache的分布式锁定功能，开发人员可以确保分布式应用程序中的高数据一致性。悲观锁定为关键更新提供严格控制，而乐观锁定则为低冲突场景提供更高的性能。实施这些策略可确保数据完整性，即使在高并发工作负载下也能保持应用程序的可靠性和可扩展性。
常见问题
- 分布式缓存中的锁定是什么？
分布式缓存中的锁定机制确保一次只能有一个客户端在多个服务器上修改缓存项，从而防止并发更新冲突。 - 为什么锁定对于数据一致性至关重要？
当多个应用程序或服务同时尝试读取或写入相同的缓存数据时，锁定机制可以防止出现竞争条件和更新丢失的情况。 - 分布式缓存锁定与数据库锁定有何不同？
分布式缓存锁定在内存中的应用程序节点和缓存服务器之间运行，而数据库锁定通常在存储级别运行，可能会引入更高的延迟。 - 在分布式缓存中使用锁定会影响性能吗？
是的，锁定会引入协调开销，因此应该有选择地将其用于需要严格一致性的数据，而不是用于高吞吐量、读取密集型工作负载。
