# pluto-redis

**Repository Path**: dotnetydd/pluto-redis

## Basic Information

- **Project Name**: pluto-redis
- **Description**: dotnet core redis
- **Primary Language**: Unknown
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2021-03-30
- **Last Updated**: 2021-04-12

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

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


## 使用方式
```csharp
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"},
                };
            });
```
- 创建实例
```csharp
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
```csharp
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) 
```

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

// 解锁
client.UnLock("admin_lock",token)
```
- 发布订阅
```csharp
var client = _serviceProvider.GetService<IPlutoRedisClient>();
// 发布
client.Publish<User>("demo",()=>JsonSerializer.Serialize(new { a="12321"}));

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