C#开发中如何处理分布式缓存和缓存策略

Install-Package StackExchange.Redis

using StackExchange.Redis;

public class RedisCacheService
{
    private readonly ConnectionMultiplexer _redis;
    private readonly IDatabase _database;

    public RedisCacheService()
    {
        _redis = ConnectionMultiplexer.Connect("localhost");
        _database = _redis.GetDatabase();
    }
}

public void SetCache(string key, string value, TimeSpan? expiry = null)
{
    _database.StringSet(key, value, expiry);
}

public string GetCache(string key)
{
    return _database.StringGet(key);
}

public void UpdateData(string key, string value)
{
    // 更新数据库中的数据
    _database.StringSet(key, value);
    
    // 主动更新缓存中的数据
    SetCache(key, value);
}

public void PublishDataUpdateEvent(string key)
{
    // 发布数据更新事件
    _redis.GetSubscriber().Publish("data_update", key);
}

public void SubscribeDataUpdateEvent()
{
    // 订阅数据更新事件
    _redis.GetSubscriber().Subscribe("data_update", (channel, key) =>
    {
        // 根据key重新获取最新数据并更新缓存
        string value = GetDataFromDatabase(key);
        SetCache(key, value);
    });
}