WebApiThrottle - C＃Web APIを使用している場合、APIレート制限を超えて5分間のAPIリクエストをブロックする - C＃Web API

Question

Web APIのAPIレート制限のために本当に素敵なライブラリWebApiThrottleがあります。
Wikiページで説明したように、私はAPIコールの認証トークンヘッダーに基づいてAPIを制限することができます。
しかし、このapiレート制限を超えると、次の5分間はどのようにAPiコールをブロックできますか？また、5分以内に要求があった場合、レート制限を超過した時間がリセットされることはありません。

コードを確認しましたが、この機能が見つかりませんでした。誰かが示唆することができれば他の方法ですか？

Answer 1

当分の間、私はこのforkのWebApiThrottleを使用していますし、この溶液に、手動でDLLを追加します。 @adamriyadiはこの機能を実装しました。それがNuGetパッケージに来るのを待っています。

---

更新：その後、私はHttpRuntime.Cacheを使用して期間を遮断すると制限API率のために私自身の実装と一緒に行きました。したがって、追加のライブラリを追加する必要はありません。

public class ThrottleAttribute : ActionFilterAttribute 
    { 
     private int _API_RATEQUOTA = 60; 

     // per x minute value 
     private int _API_TIMELIMIT = 1; 

     private int _API_BLOCKDURATION = 5; 

     private readonly object syncLock = new object(); 

     public override void OnActionExecuting(HttpActionContext actionContext) 
     { 
      // Extract access_token or id or ip address to uniquely identify an API call 
      var access_token = AuthHelper.GetAuthToken(actionContext.Request); 

      if (access_token != null) 
      { 

       string throttleBaseKey = GetThrottleBaseKey(access_token); 
       string throttleCounterKey = GetThrottleCounterKey(access_token); 

       lock (syncLock) 
       { 
        //add a listner for new api request count 
        if (HttpRuntime.Cache[throttleBaseKey] == null) 
        { 
         // add api unique key.. this cache will get expire after _API_TIMELIMIT 
         HttpRuntime.Cache.Add(throttleBaseKey, 
          DateTime.UtcNow, 
          null, 
          DateTime.Now.AddMinutes(_API_TIMELIMIT), 
          Cache.NoSlidingExpiration, 
          CacheItemPriority.High, 
          null); 

         // add count as value for that api.. this cache will get expire after _API_TIMELIMIT 
         HttpRuntime.Cache.Add(throttleCounterKey, 
          1, 
          null, 
          DateTime.Now.AddMinutes(_API_TIMELIMIT), 
          Cache.NoSlidingExpiration, 
          CacheItemPriority.High, 
          null); 
        } 
        else 
        { 
         //listener exists for api request count 
         var current_requests = (int)HttpRuntime.Cache[throttleCounterKey]; 

         if (current_requests < _API_RATEQUOTA) 
         { 
          // increase api count 
          HttpRuntime.Cache.Insert(throttleCounterKey, 
          current_requests + 1, 
          null, 
          DateTime.Now.AddMinutes(_API_TIMELIMIT), 
          Cache.NoSlidingExpiration, 
          CacheItemPriority.High, 
          null); 
         } 

         //hit rate limit, wait for another 5 minutes (_API_BLOCKDURATION) 
         else 
         { 
          HttpRuntime.Cache.Insert(throttleBaseKey, 
          DateTime.UtcNow, 
          null, 
          DateTime.Now.AddMinutes(_API_BLOCKDURATION), 
          Cache.NoSlidingExpiration, 
          CacheItemPriority.High, 
          null); 

          HttpRuntime.Cache.Insert(throttleCounterKey, 
          current_requests + 1, 
          null, 
          DateTime.Now.AddMinutes(_API_BLOCKDURATION), 
          Cache.NoSlidingExpiration, 
          CacheItemPriority.High, 
          null); 

          Forbidden(actionContext); 
         } 
        } 
       } 
      } 
      else 
      { 
       BadRequest(actionContext); 
      } 

      base.OnActionExecuting(actionContext); 
     } 

     private string GetThrottleBaseKey(string app_id) 
     { 
      return Identifier.THROTTLE_BASE_IDENTIFIER + app_id; 
     } 

     private string GetThrottleCounterKey(string app_id) 
     { 
      return Identifier.THROTTLE_COUNTER_IDENTIFIER + app_id; 
     } 

     private void BadRequest(HttpActionContext actionContext) 
     { 
      actionContext.Response = actionContext.Request.CreateResponse(HttpStatusCode.BadRequest); 
     } 

     private void Forbidden(HttpActionContext actionContext) 
     { 
      actionContext.Response = actionContext.Request.CreateResponse(HttpStatusCode.Forbidden, "Application Rate Limit Exceeded"); 
     } 

    } 

    public static class Identifier 
    { 
     public static readonly string THROTTLE_BASE_IDENTIFIER = "LA_THROTTLE_BASE_"; 
     public static readonly string THROTTLE_COUNTER_IDENTIFIER = "LA_THROTTLE_COUNT_"; 
    } 

今[ThrottleAttribute]

に必要なAPIを飾ります