caching - 在c#异步中使用Redis缓存后CPU使用率高

Question

我正在使用https://github.com/StackExchange/StackExchange.Redis 。 (StackExchange.Redis.StrongName.1.2.1)

我有一个像这样的异步函数，它会导致 CPU 达到 100%，并在处理 400 个请求后 4-5 分钟后开始出现超时错误

 public async Task<T> GetOrSetAsync<T>(string cacheKey, Func<Task<T>> getItemCallback) where T : class
         {
             T item = null;
             IDatabase cache = Connection.GetDatabase();
             var cacheValue = await cache.StringGetAsync(cacheKey);
            if (cacheValue.IsNull)
            {
                item = await getItemCallback();
                await cache.StringSetAsync(cacheKey, JsonConvert.SerializeObject(item));
            }
            else
            {
                item = await Task.Factory.StartNew(() => JsonConvert.DeserializeObject<T>(cacheValue));
            }
             return item;
         }

如果我停止使用 Redis 缓存并从数据库返回直接值，我能够在 2 分 20 秒内执行 1300 个请求的负载。 CPU高仍然能够完成负载。

 public async Task<T> GetOrSetAsync<T>(string cacheKey, Func<Task<T>> getItemCallback) where T : class
         {
            return await getItemCallback();
         }

如果我只是修改下面的函数来获取数据库而不执行任何操作。它会导致CPU立即达到100%，并在2分钟内发出200个请求后卡住，这是因为CPU过高。

 public async Task<T> GetOrSetAsync<T>(string cacheKey, Func<Task<T>> getItemCallback) where T : class
         {
           IDatabase cache = Connection.GetDatabase();
            return await getItemCallback();
         }

但问题是为什么 CPU 使用率仅随着添加

IDatabase 缓存 = Connection.GetDatabase(); ？

Answer 1

您的“连接”属性是如何实现的？是否会在每次调用时创建与 Redis 的新连接？如果是这样的话，就不建议这样做了。您应该在调用之间共享一个连接。

private static Lazy<ConnectionMultiplexer> lazyConnection = new Lazy<ConnectionMultiplexer>(() =>
{
    return ConnectionMultiplexer.Connect("<your connection string here>");
});

public static ConnectionMultiplexer Connection
{
    get
    {
        return lazyConnection.Value;
    }
}