public class FlashSale

{

public int Id { get; set; }

/// <summary>

/// 秒杀活动的名称

/// </summary>

public string Name { get; set; } = null!;

/// <summary>

/// 要秒杀的商品Id

/// </summary>

public int ProductId { get; set; }

/// <summary>

/// 本次秒杀活动计划售出商品的数量 必须大于等于1

/// </summary>

public int ProductCount { get; set; }

/// <summary>

/// 每个参与活动的用户最多能抢购的数量 大于等于1 且小于等于 ProductCount

/// </summary>

public int EachUserCanBuy { get; set; }

/// <summary>

/// 活动开始的时间

/// </summary>

public DateTimeOffset StartAt { get; set; }

/// <summary>

/// 活动结束的时间

/// </summary>

public DateTimeOffset EndAt { get; set; }

}

using System.Text.Json;

using Microsoft.Extensions.Caching.Distributed;

namespace FlashSale.Extensions

{

/// <summary>

/// 本扩展是对Microsoft.Extensions.Caching.StackExchangeRedis包

/// 中一些方法的扩展

/// 注意：本方法仅仅是扩展，如果要做缓存与数据库数据最终一致性，用锁防止流量打到数据的操作，请在各自的service中做

/// </summary>

public static class DistributedCacheExtensions

{

/// <summary>

/// 该方法是对IDistributedCache中setStringAsync的扩展

/// </summary>

/// <typeparam name="T"></typeparam>

/// <param name="cache">IDistributedCache</param>

/// <param name="recordKey">缓存的key</param>

/// <param name="record">缓存的value</param>

/// <param name="absoluteExpirationRelativeToNow">过期时间，可以为null，当为null的时候默认

/// 添加5分钟 + 2分钟内随机的时间。即 过期时间大于等于5分钟小于等于7分钟</param>

/// <param name="slidingExpireTIme">滑动过期时间 可以为null. 注意SlidingExpiration指的是 在这段时间 如果该key没有被访问，则会被删除</param>

/// <returns></returns>

public static async Task SetRecordAsync<T>(

this IDistributedCache cache,

string recordKey,

T record,

TimeSpan? absoluteExpirationRelativeToNow = null,

TimeSpan? slidingExpireTIme = null

)

{

var cacheOptions = new DistributedCacheEntryOptions()

{

AbsoluteExpirationRelativeToNow = absoluteExpirationRelativeToNow ?? TimeSpan.FromSeconds(5 * 60 + new Random().Next(1, 2 * 60)),

SlidingExpiration = slidingExpireTIme

};

var jsonData = JsonSerializer.Serialize(record);

await cache.SetStringAsync(recordKey, jsonData, cacheOptions);

}

/// <summary>

/// 通过缓存的key查找缓存的内容

/// </summary>

/// <typeparam name="T"></typeparam>

/// <param name="cache">IDistributedCache</param>

/// <param name="recordKey">缓存的key</param>

/// <returns></returns>

public static async Task<T?> GetRecordAsync<T>(this IDistributedCache cache, string recordKey)

{

var jsonData = await cache.GetStringAsync(recordKey);

return jsonData is null ? default(T) : JsonSerializer.Deserialize<T>(jsonData);

}

}

}

 1 using FlashSale.Extensions;

 2 using FlashSale.Interfaces;

 3 using Microsoft.Extensions.Caching.Distributed;

 4 using StackExchange.Redis;

 5 namespace FlashSale.ImplementServices

 6 {

 7 public class FlashSaleService : IFlashSaleService

 8 {

 9 private readonly IDistributedCache _distributedCache;

10 private readonly IDatabase _redisDatabase;

11

12 public FlashSaleService(IDistributedCache distributedCache,

13 IConnectionMultiplexer connectionMultiplexer)

14 {

15 _distributedCache = distributedCache;

16 _redisDatabase = connectionMultiplexer.GetDatabase(); // 本次设计：缓存和秒杀的业务逻辑用同一个数据库，即第0个redis数据库

17 }

18

19 /// <inheritdoc />

20 public async Task<Models.FlashSale?> GetFlashSaleAsync(string flashSaleId)

21 {

22 // 注意：在生产环境中，会发生缓存失效而需要去读取数据库的情况，此时，会发生大量读的请求的流量

23 // 为了不让这么多读的请求流量打到数据库，我们需要加锁，只有获取到锁的请求，才有资格去数据库读取数据

24 // 读取到数据之后，把数据刷入缓存，那些获取不到锁的用户直接返回当前请求的用户过多，请稍后重试

25 // 数据刷入缓存后，用户会刷新页面，此时从缓存中读取数据即可

26 return await _distributedCache.GetRecordAsync<Models.FlashSale>($"flashSale:{flashSaleId}");

27 }

28

29 /// <inheritdoc />

30 public async Task Execute(string flashSaleId)

31 {

32

33 var flashSale = await _distributedCache.GetRecordAsync<Models.FlashSale>($"flashSale:{flashSaleId}");

34 if (flashSale is null)

35 {

36 return;

37 }

38

39 var dateTimeNow = DateTimeOffset.Now;

40 if ( dateTimeNow < flashSale.StartAt)

41 {

42 Console.WriteLine("活动还没有开始");

43 return;

44 }

45

46 if (dateTimeNow > flashSale.EndAt)

47 {

48 Console.WriteLine("活动已经结束了");

49 return;

50 }

51

52 // 要进入秒杀活动的逻辑环节

53 // 这个key 初始化的时候会设置为0 incr操作是原子性

54 if (await _redisDatabase.StringIncrementAsync($"flashSale:{ flashSaleId }:{ flashSale.ProductId}") > flashSale.ProductCount)

55 {

56 // 没抢到

57 Console.WriteLine("抢光了");

58

59 }

60 else

61 {

62 // 抢到了

63 Console.WriteLine("恭喜您，抢到了");

64 }

65

66 }

67 }

68 }