使用BookSleeve删除排序集

本文关键字：排序 删除 BookSleeve 使用 | 更新日期: 2023-09-27 18:32:28

我有大约 336 个键，我正在尝试删除这些键，这些键是 SortedSets，我在 Ubuntuserver 上使用 BookSleeve 作为 C3 客户端和 Redis 上的 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 对象的类中。

使用BookSleeve删除排序集

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

但是，如果您使用的是"using"，它应该可以正常工作 - 释放实现应确保它正确关闭。

所以基本上这会很糟糕：

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);

如果它与其中任何一个无关，一个完整的示例将真正有所帮助......

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

试试这个代码：

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);
}
相关文章：