在 webapi 中处理多个类似的请求

Question

在我的 WebApi 控制器中，我有以下（伪）代码接收来自Instagrams real-time API 的更新通知：

[HttpPost]
public void Post(InstagramUpdate instagramUpdate)
{
    var subscriptionId = instagramUpdate.SubscriptionId;
    var lastUpdate = GetLastUpdate(subscriptionId);

    // To avoid breaking my Instagram request limit, do not fetch new images too often.
    if (lastUpdate.AddSeconds(5) < DateTime.UtcNow)
    {
        // More than 5 seconds ago since last update for this subscription. Get new images
        GetNewImagesFromInstagram(subscriptionId);
        UpdateLastUpdate(subscriptionId, DateTime.UtcNow);
    }
}

如果我几乎同时收到同一订阅的两个更新通知，这将不会很好，因为 lastUpdate 直到处理第一个请求之后才会更新。

解决这个问题的最佳方法是什么？我正在考虑使用某种缓存，但我不确定如何。这类事情有一些最佳实践吗？我猜这是一个常见的问题：“收到通知，如果最近没有做某事，就做一些事情......”

Answer 1

感谢this answer 我采用了以下方法，使用MemoryCache

[HttpPost]
public void Post(IEnumerable<InstagramUpdate> instagramUpdates)
{
    foreach (var instagramUpdate in instagramUpdates)
    {
        if (WaitingToProcessSubscriptionUpdate(instagramUpdate.Subscription_id))
        {
            // Ongoing request, do nothing
        }
        else
        {
            // Process update
        }
    }
}

private bool WaitingToProcessSubscriptionUpdate(string subscriptionId)
{
    // Check in the in memory cache if this subscription is in queue to be processed. Add it otherwise
    var queuedRequest = _cache.AddOrGetExisting(subscriptionId, string.Empty, new CacheItemPolicy
    {
        // Automatically expire this item after 1 minute (if update failed for example)
        AbsoluteExpiration = DateTime.Now.AddMinutes(1)
    });

    return queuedRequest != null;
}

Answer 2

恐怕这是个糟糕的主意，但是……也许值得给这个方法加锁？喜欢

 private List<int> subscriptions = new List<int>();

然后

 int subscriptinId = 1;//add calculation here
            int subscriptionIdIndex = subscriptions.IndexOf(subscriptinId);

            lock (subscriptions[subscriptionIdIndex])
            {
                //your method code
            }

请随意批评这种方法）