RedisCacheContext 修改

main
陈伟 2 months ago
parent 5e5b8e6e8c
commit b637b09423

@ -16,7 +16,10 @@ namespace Infrastructure.Cache
{ {
_conn = ConnectionMultiplexer.Connect(options.Value.RedisConf.Conn); _conn = ConnectionMultiplexer.Connect(options.Value.RedisConf.Conn);
iDatabase = _conn.GetDatabase(options.Value.RedisConf.Database); 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<T>(string key) public override T Get<T>(string key)
@ -174,6 +177,7 @@ namespace Infrastructure.Cache
{ {
return server.Keys(pattern: new RedisValue(pattern)); return server.Keys(pattern: new RedisValue(pattern));
} }
/// <summary> /// <summary>
/// HSET - 异步设置哈希表中的多个字段。 /// HSET - 异步设置哈希表中的多个字段。
/// </summary> /// </summary>
@ -184,6 +188,7 @@ namespace Infrastructure.Cache
{ {
iDatabase.HashSetAsync(key, hashFields, CommandFlags.None); iDatabase.HashSetAsync(key, hashFields, CommandFlags.None);
} }
/// <summary> /// <summary>
/// HGETALL - 异步获取哈希表中的所有字段和值。 /// HGETALL - 异步获取哈希表中的所有字段和值。
/// </summary> /// </summary>
@ -192,8 +197,9 @@ namespace Infrastructure.Cache
/// <returns></returns> /// <returns></returns>
public Task<HashEntry[]> HashGetAllAsync(RedisKey key, CommandFlags flags = CommandFlags.None) public Task<HashEntry[]> HashGetAllAsync(RedisKey key, CommandFlags flags = CommandFlags.None)
{ {
return iDatabase.HashGetAllAsync(key, CommandFlags.None); return iDatabase.HashGetAllAsync(key, CommandFlags.None);
} }
/// <summary> /// <summary>
/// Returns all the members of the set value stored at key /// Returns all the members of the set value stored at key
/// </summary> /// </summary>
@ -204,10 +210,12 @@ namespace Infrastructure.Cache
{ {
return iDatabase.SetMembersAsync(key, CommandFlags.None); return iDatabase.SetMembersAsync(key, CommandFlags.None);
} }
public Task<bool> SetAddAsync(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None) public Task<bool> SetAddAsync(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None)
{ {
return iDatabase.SetAddAsync(key, value, CommandFlags.None); return iDatabase.SetAddAsync(key, value, CommandFlags.None);
} }
public Task<bool> SetRemoveAsync(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None) public Task<bool> SetRemoveAsync(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None)
{ {
return iDatabase.SetRemoveAsync(key, value, CommandFlags.None); return iDatabase.SetRemoveAsync(key, value, CommandFlags.None);

Loading…
Cancel
Save