精准引流推广,靖江seo快速排名,青岛的网站建设公司,免费虚拟服务器Redis 有序集合和集合一样也是 string 类型元素的集合,且不允许重复的成员。 不同的是每个元素都会关联一个 double 类型的分数。redis 正是通过分数来为集合中的成员进行从小到大的排序。
有序集合的成员是唯一的,但分数(score)却可以重复。
集合是通过哈希表实现的#xf…Redis 有序集合和集合一样也是 string 类型元素的集合,且不允许重复的成员。 不同的是每个元素都会关联一个 double 类型的分数。redis 正是通过分数来为集合中的成员进行从小到大的排序。
有序集合的成员是唯一的,但分数(score)却可以重复。
集合是通过哈希表实现的所以添加删除查找的复杂度都是 O(1)。 集合中最大的成员数为 232 - 1 (4294967295, 每个集合可存储40多亿个成员)。
延迟队列的设计思想是将队列的延迟时间作为分数按照这个进行排序
安装依赖
Newtonsoft.Json 13.0.3
StackExchange.Redis 2.8.0 封装Redis
using StackExchange.Redis;
namespace LedayQueue.RedisHelper
{public class RedisConnection{private readonly ConnectionMultiplexer _connection;public IDatabase _database;public RedisConnection(){_connection ConnectionMultiplexer.Connect(localhost:6379);_database _connection.GetDatabase();}public async Task AddToQueueAsync(string task, TimeSpan delay){var executionTime DateTimeOffset.UtcNow.ToUnixTimeSeconds() delay.TotalSeconds;await _database.SortedSetAddAsync(delayedQueue, task, executionTime);}}
}
封装background service
using StackExchange.Redis;namespace LedayQueue.RedisHelper
{public class DelayedQueueProcessor : BackgroundService{private readonly RedisConnection _connection;private const string QueueKey delayedQueue;public DelayedQueueProcessor(RedisConnection redisConnection){_connection redisConnection;}protected override async Task ExecuteAsync(CancellationToken stoppingToken){while (!stoppingToken.IsCancellationRequested){var now DateTimeOffset.UtcNow.ToUnixTimeSeconds();var tasks await _connection._database.SortedSetRangeByScoreWithScoresAsync(QueueKey, 0, now);foreach (var task in tasks){// 处理任务var taskString task.Element.ToString();ProcessTask(taskString);// 从队列中移除任务await _connection._database.SortedSetRemoveAsync(QueueKey, task.Element);}await Task.Delay(TimeSpan.FromSeconds(1), stoppingToken); // 每秒检查一次}}private void ProcessTask(string content){Console.WriteLine(content);}}
}
注册
builder.Services.AddSingletonRedisConnection();
builder.Services.AddHostedServiceDelayedQueueProcessor();
源码
官网
