src/Library/NetPro.StackExchange.Redis/StackExchange.Redis.Extensions.Core/Implementations/RedisDatabase.Sort.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using StackExchange.Redis.Extensions.Core.Abstractions;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace StackExchange.Redis.Extensions.Core.Implementations
{
    public partial class RedisDatabase : IRedisDatabase
    {
        public Task<bool> SortedSetAddAsync<T>(
                                    string key,
                                    T value,
                                    double score,
                                    CommandFlags commandFlags = CommandFlags.None)
        {
            var entryBytes = Serializer.Serialize(value);

            return Database.SortedSetAddAsync(key, entryBytes, score, commandFlags);
        }

        public bool SortedSetAdd<T>(
                                    string key,
                                    T value,
                                    double score,
                                    CommandFlags commandFlags = CommandFlags.None)
        {
            var entryBytes = Serializer.Serialize(value);

            return Database.SortedSetAdd(key, entryBytes, score, commandFlags);
        }

        /// <summary>
        /// 通过索引区间返回有序集合成指定区间内的成员,默认从小到大
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="key"></param>
        /// <param name="start"></param>
        /// <param name="stop"></param>
        /// <param name="order"></param>
        /// <param name="flags"></param>
        /// <returns></returns>
        public async Task<IEnumerable<T>> SortedSetRangeByRankAsync<T>(
                                    string key,
                                     long start = 0, long stop = -1, Order order = Order.Ascending, CommandFlags flags = CommandFlags.None)
        {
            var items = await Database.SortedSetRangeByRankAsync(key, start, stop, order, flags: flags);

            return items.Select(item => item == RedisValue.Null ? default : Serializer.Deserialize<T>(item));
        }

        /// <summary>
        /// 通过索引区间返回有序集合成指定区间内的成员,默认从小到大
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="key"></param>
        /// <param name="start"></param>
        /// <param name="stop"></param>
        /// <param name="order"></param>
        /// <param name="flags"></param>
        /// <returns></returns>