使用 BookSleeve 移除 SortedSet

Question

我尝试删除大约 336 个键，它们是 SortedSet，我在 Ubuntuserver 上使用 BookSleeve 作为 C3 客户端和 Redis。 下面的代码有效，但如果我删除 Console.WriteLine，它不会随机删除大约 100 个键。它不会引发任何错误，当我在 redis 服务器端打开 Montior 时，我看不到为那些没有从 c# 端删除的人发送 ZREM 声明。 为什么它可以与存在的 Console.Writeline 一起使用，而不是在它被注释掉的时候让我感到困惑。有什么想法吗？

public virtual void RemoveKey(string item, string id)
{
   for (int i = 1; i <= item.Length; i++)
   {
      Console.WriteLine(PrefixKey + item.Substring(0, i));
      _redisClient.SortedSets.Remove(_database, 
             PrefixKey + item.Substring(0, i), id);
   }
}

我有课

 public class RedisRepository
    {
        protected static RedisConnection _redisClient;
        protected int _database;
        protected bool disposed;

        public RedisRepository(int database)
        {
            string server = ConfigurationManager.AppSettings["redis.server"];
            int port = Convert.ToInt32(ConfigurationManager.AppSettings["redis.port"]);
            string password = ConfigurationManager.AppSettings["redis.password"];
            _redisClient = new RedisConnection(server, port, -1, password);
            _database = database;
            _redisClient.Open();
        }
     ~RedisRepository()
        {
            this.Dispose(false);
        }

        public void Dispose()
        {
            this.Dispose(true);
            GC.SuppressFinalize(this);

        }

        protected virtual void Dispose(bool disposing)
        {
            if (!disposed)
            {
                if (disposing)
                {
                    _redisClient.CloseAsync(false);
                    _redisClient.Dispose();
                }

                // Dispose unmanaged resources here.
            }

            disposed = true;
        }
}

我已将上面的 RedisRpository 类继承到另一个使用其 _redisClient 对象的类中。

Answer 1

如果没有看到 _redisClient 的生命周期，这有点难以回答。特别是 RedisConnection 的所有操作都是异步的。如果您正在运行一个启动操作然后立即存在的测试：有些东西可能仍在套接字上等待。如果 redis 检测到套接字关闭，它会立即终止该连接（它甚至不会先耗尽套接字，因此忽略挂起的操作）。如果您的进程终止，套接字将突然关闭。

但是，如果您使用“using”，它应该可以正常工作 - dispose 实现应该确保它正确关闭。

所以基本上这会很糟糕：

static void Main() {
    var conn = OpenConnection();
    // lots of operations
}

但这应该没问题：

static void Main() {
    using(var conn = OpenConnection()) {
         // lots of operations
    }
}

或者，您可以跟踪最后一次操作并简单地等待：

Task last = null;
for(...) {
     last = conn.SomeOperation(...);
}
if(last != null) conn.Wait(last);

如果它与其中任何一个都不相关，那么一个完整的例子真的会有所帮助......

Answer 2

也许您必须等到异步删除完成。

试试这个代码：

public virtual void RemoveKey(string item, string id)
{
   Task[] removeTasks = new Task[item.Length];
   for (int i = 1; i <= item.Length; i++)
   {
      Console.WriteLine(PrefixKey + item.Substring(0, i));
      removeTasks[i-1] = _redisClient.SortedSets.Remove(_database, 
             PrefixKey + item.Substring(0, i), id);
   }

   _redisClient.WaitAll(removeTasks);
}