// 麻省理工学院许可证 // // 版权所有 (c) 2021-2023 zuohuaijun,大名科技(天津)有限公司 联系电话/微信:18020030720 QQ:515096995 // // 特此免费授予获得本软件的任何人以处理本软件的权利,但须遵守以下条件:在所有副本或重要部分的软件中必须包括上述版权声明和本许可声明。 // // 软件按“原样”提供,不提供任何形式的明示或暗示的保证,包括但不限于对适销性、适用性和非侵权的保证。 // 在任何情况下,作者或版权持有人均不对任何索赔、损害或其他责任负责,无论是因合同、侵权或其他方式引起的,与软件或其使用或其他交易有关。 using NewLife.Caching.Queues; namespace Admin.NET.Core; /// /// Redis 消息队列 /// public static class RedisQueue { private static ICache _cache = App.GetService(); /// /// 获取可信队列,需要确认 /// /// /// /// public static RedisReliableQueue GetRedisReliableQueue(string topic) { var queue = (_cache as FullRedis).GetReliableQueue(topic); return queue; } /// /// 可信队列回滚 /// /// /// /// public static int RollbackAllAck(string topic, int retryInterval = 60) { var queue = GetRedisReliableQueue(topic); queue.RetryInterval = retryInterval; return queue.RollbackAllAck(); } /// /// 发送一个数据列表到可信队列 /// /// /// /// /// public static int AddReliableQueueList(string topic, List value) { var queue = (_cache as FullRedis).GetReliableQueue(topic); var count = queue.Count; var result = queue.Add(value.ToArray()); return result - count; } /// /// 发送一条数据到可信队列 /// /// /// /// /// public static int AddReliableQueue(string topic, T value) { var queue = (_cache as FullRedis).GetReliableQueue(topic); var count = queue.Count; var result = queue.Add(value); return result - count; } /// /// 获取延迟队列 /// /// /// /// public static RedisDelayQueue GetDelayQueue(string topic) { var queue = (_cache as FullRedis).GetDelayQueue(topic); return queue; } /// /// 发送一条数据到延迟队列 /// /// /// /// 延迟时间。单位秒 /// /// public static int AddDelayQueue(string topic, T value, int delay) { var queue = GetDelayQueue(topic); return queue.Add(value, delay); } /// /// 发送数据列表到延迟队列 /// /// /// /// /// 延迟时间。单位秒 /// public static int AddDelayQueue(string topic, List value, int delay) { var queue = GetDelayQueue(topic); queue.Delay = delay; return queue.Add(value.ToArray()); } /// /// 在可信队列获取一条数据 /// /// /// /// public static T ReliableTakeOne(string topic) { var queue = GetRedisReliableQueue(topic); return queue.TakeOne(1); } /// /// 异步在可信队列获取一条数据 /// /// /// /// public static async Task ReliableTakeOneAsync(string topic) { var queue = GetRedisReliableQueue(topic); return await queue.TakeOneAsync(1); } /// /// 在可信队列获取多条数据 /// /// /// /// /// public static List ReliableTake(string topic, int count) { var queue = GetRedisReliableQueue(topic); return queue.Take(count).ToList(); } }