From b637b094233664e2f363c7a8d006d3ca43d2699e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E4=BC=9F?= <421281095@qq.com> Date: Thu, 17 Jul 2025 10:57:15 +0800 Subject: [PATCH] =?UTF-8?q?RedisCacheContext=20=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Infrastructure/Cache/RedisCacheContext.cs | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/Infrastructure/Cache/RedisCacheContext.cs b/Infrastructure/Cache/RedisCacheContext.cs index 1374eec..5c2033e 100644 --- a/Infrastructure/Cache/RedisCacheContext.cs +++ b/Infrastructure/Cache/RedisCacheContext.cs @@ -16,7 +16,10 @@ namespace Infrastructure.Cache { _conn = ConnectionMultiplexer.Connect(options.Value.RedisConf.Conn); iDatabase = _conn.GetDatabase(options.Value.RedisConf.Database); - server = _conn.GetServer("175.27.168.120:6050"); + // 175.27.168.120:6050,password=HopetryRedis1406 + var Conn = options.Value.RedisConf.Conn; + var hostAndPort = Conn.Substring(0, Conn.IndexOf(",", StringComparison.Ordinal)); + server = _conn.GetServer(hostAndPort); } public override T Get(string key) @@ -174,6 +177,7 @@ namespace Infrastructure.Cache { return server.Keys(pattern: new RedisValue(pattern)); } + /// /// HSET - 异步设置哈希表中的多个字段。 /// @@ -184,6 +188,7 @@ namespace Infrastructure.Cache { iDatabase.HashSetAsync(key, hashFields, CommandFlags.None); } + /// /// HGETALL - 异步获取哈希表中的所有字段和值。 /// @@ -192,8 +197,9 @@ namespace Infrastructure.Cache /// public Task HashGetAllAsync(RedisKey key, CommandFlags flags = CommandFlags.None) { - return iDatabase.HashGetAllAsync(key, CommandFlags.None); + return iDatabase.HashGetAllAsync(key, CommandFlags.None); } + /// /// Returns all the members of the set value stored at key /// @@ -204,10 +210,12 @@ namespace Infrastructure.Cache { return iDatabase.SetMembersAsync(key, CommandFlags.None); } + public Task SetAddAsync(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None) { return iDatabase.SetAddAsync(key, value, CommandFlags.None); } + public Task SetRemoveAsync(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None) { return iDatabase.SetRemoveAsync(key, value, CommandFlags.None);