.net core 操作redis list类型封装_redis listleftpushasync listleftpopasync

using StackExchange.Redis;
using CoreRedis.Models;
using Microsoft.Extensions.Options;
using CoreRedis.Config;

namespace CoreRedis.RedisDataType
{
    public class RedisList
    {
        private static readonly object Locker = new object();

        private ConnectionMultiplexer connectionMultiplexer;


        IDatabase db = null;

        public RedisList(IOptionsMonitor<RedisConfig> optionsMonitor)
        {
            connectionMultiplexer = ConnectionMultiplexer.Connect(optionsMonitor.CurrentValue.Value);

            db = connectionMultiplexer.GetDatabase();
        }

        //lpush 左侧插入元素
        public async Task<Task<long>> LPUSH(string key,string value)
        {
            return db.ListLeftPushAsync(key, value,When.NotExists);
        }

        //右侧插入元素
        public async Task<Task<long>> RPUSH(string key,string value)
        {
            return db.ListRightPushAsync(key, value,When.NotExists);
        }

        //从左侧弹出元素
        public async Task<Task<RedisValue>> LPOP(string key)
        {
            return db.ListLeftPopAsync(key);
        }


        //从左侧弹出多个元素
        public async Task<Task<RedisValue[]>> LPOPMUL(string key,long count)
        {
            return db.ListLeftPopAsync(key,count);
        }

        //len 获取列表长度
        public async Task<Task<long>> LLen(string key)
        {
            return db.ListLengthAsync(key);
        }

        //lindex 获取指定索引上的数据
        public async Task<Task<RedisValue>> LIndex(string key,long index)
        {
            return  db.ListGetByIndexAsync(key,index);
        }

        //lrange 获取一个索引范围的数据
        public async Task<Task<RedisValue[]>> LRange(string key,long start,long end)
        {
            return db.ListRangeAsync(key,start,end);
        }

        //lset 为指定索引设置新值
        public async Task LSet(string key,string value,long index)
        {
            await db.ListSetByIndexAsync(key,index,value);
        }

        //ltrim 裁剪
        public async Task<Task> LTrim(string key,long start,long stop)
        {
            return db.ListTrimAsync(key, start, stop);
        }


        //lrem 删除元素，0表示全部删除，-1 表示从左侧开始删除等于value的count个，1表示右侧
        public async Task<Task<long>> LRem(string key,long count,string value)
        {
            return db.ListRemoveAsync(key,value,count);
        }
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87