AppFabric缓存并发问题？

Question

在对我们全新的主系统的原型进行压力测试时，我遇到了 AppFabric 缓存的并发问题。当使用相同的cacheKey同时调用多个DataCache.Get()和Put()时，我尝试存储相对较大的对象，收到“ErrorCode:SubStatus:There is atemporary failure.Please retry later”。可以通过以下代码重现：

        var dcfc = new DataCacheFactoryConfiguration
        {
            Servers = new[] {new DataCacheServerEndpoint("localhost", 22233)},
            SecurityProperties = new DataCacheSecurity(DataCacheSecurityMode.None, DataCacheProtectionLevel.None),
        };

        var dcf = new DataCacheFactory(dcfc);
        var dc = dcf.GetDefaultCache();

        const string key = "a";
        var value = new int [256 * 1024]; // 1MB

        for (int i = 0; i < 300; i++)
        {
            var putT = new Thread(() => dc.Put(key, value));
            putT.Start();               

            var getT = new Thread(() => dc.Get(key));
            getT.Start();
        }

当使用不同的 key 调用 Get() 或同步 DataCache 时，不会出现此问题。如果每次从 DataCacheFactory 调用时都获得 DataCache（DataCache 应该是线程安全的），或者超时时间延长，则不会产生任何影响，并且仍然会收到错误。 我觉得很奇怪MS会留下这样的bug。有人遇到过类似的问题吗？

Answer 1

我也看到了同样的行为，我的理解是这是设计使然。缓存包含两种并发模型：

• 乐观并发模型方法： Get、Put、...
• 悲观并发模型： > GetAndLock、PutAndLock、Unlock

如果您使用像 Get 这样的乐观并发模型方法，那么您必须准备好得到DataCacheErrorCode.RetryLater 并适当处理 - 我还使用重试方法。

您可以在 MSDN 中找到更多信息：并发模型

Answer 2

我们在代码中也看到了这个问题。我们通过重载 Get 方法来捕获期望来解决此问题，然后重试调用 N 次，然后再回退到对 SQL 的直接请求。

这是我们用来从缓存中获取数据的代码

    private static bool TryGetFromCache(string cacheKey, string region, out GetMappingValuesToCacheResult cacheResult, int counter = 0)
    {
    cacheResult = new GetMappingValuesToCacheResult();

    try
    {
        // use as instead of cast, as this will return null instead of exception caused by casting.
        if (_cache == null) return false;

        cacheResult = _cache.Get(cacheKey, region) as GetMappingValuesToCacheResult;

        return cacheResult != null;
    }
    catch (DataCacheException dataCacheException)
    {
        switch (dataCacheException.ErrorCode)
        {
            case DataCacheErrorCode.KeyDoesNotExist:
            case DataCacheErrorCode.RegionDoesNotExist:
                return false;
            case DataCacheErrorCode.Timeout:
            case DataCacheErrorCode.RetryLater:
                if (counter > 9) return false; // we tried 10 times, so we will give up.

                counter++;
                Thread.Sleep(100);
                return TryGetFromCache(cacheKey, region, out cacheResult, counter);
            default:
                EventLog.WriteEntry(EventViewerSource, "TryGetFromCache: DataCacheException caught:\n" +
                        dataCacheException.Message, EventLogEntryType.Error);

                return false;
        }
    }
}

然后，当我们需要从缓存中获取某些内容时，我们会执行以下操作：

TryGetFromCache(key, region, out cachedMapping)

这允许我们使用封装异常的 Try 方法。如果它返回 false，我们就知道缓存出了问题，我们可以直接访问 SQL。