Pluto.Redis 1.1.0

pluto-redis

dotnet core redis 常用操作，基于StackExchange.Redis

使用方式

services.AddPlutoRedis(o =>
            {
                o.DefaultDbNumber = 0; 
                o.InstanceName = "test";
                o.Password = "pluto1002";
                o.MasterName = "redis-master"; // sentinel 模式的redis master名称
                o.IsSentinelModel = true;
                o.AllowAdmin = true;
                o.KeepAlive = 180;
                o.RedisAddress=new Dictionary<int, string>
                { 
                    // sentinel 或者普通模式 redis的地址
                    {26379,"127.0.0.1"},
                    {26380,"127.0.0.1"},
                    {26381,"127.0.0.1"},
                };
            });

• 创建实例

var client = _serviceProvider.GetService<IPlutoRedisClient>();
var res= client.Set("demo", "123123qweqwew",3600);
// 使用自己的序列化工具
var res= client.Set("demo", ()=>JsonSerializer.Serialize<Demo>(new Demo { Name="123"}),3600);

 var str = aaa.Get("demo");
 var model = aaa.Get<Demo>("demo2", (str) => JsonSerializer.Deserialize<Demo>(str));

• 获取db

var client = _serviceProvider.GetService<IPlutoRedisClient>();
var res= client.GetDatabase(3);
// 使用db的扩展方法
res.Set("asdasd","mkmkmkmk",200) // 和client中的基本方法一致。
res.Set("asdasd",()=>JsonSerializer.Serialize<Demo>(new Demo { Name="123"}),200) 

• 分布式锁

// 获取锁
var client = _serviceProvider.GetService<IPlutoRedisClient>();
client.Lock("admin_lock",token,100) // return bool 

// 解锁
client.UnLock("admin_lock",token)

• 发布订阅

var client = _serviceProvider.GetService<IPlutoRedisClient>();
// 发布
client.Publish<User>("demo",()=>JsonSerializer.Serialize(new { a="12321"}));

// 订阅
client.Subscribe("demo",Action<channel,string> callback);