자체 호스트 오 틴 서버를 중지 할 때 현재 요청을 완료하십시오.

Question

콘솔 앱의 일부로 OWIN 서버가 있습니다. 현재 주요 방법을 볼 수

class Program 
{ 
    public static ManualResetEventSlim StopSwitch = new ManualResetEventSlim(); 

    static void Main(string[] args) 
    { 
     Console.CancelKeyPress += (s, a) => 
     { 
      a.Cancel = true; 
      StopSwitch.Set(); 
     }; 

     using (WebApp.Start<Startup>("http://+:8080/")) 
     { 
      Console.WriteLine("Server is running..."); 
      Console.WriteLine("Press CTRL+C to stop it."); 
      StopSwitch.Wait(); 
      Console.WriteLine("Server is stopping..."); 
     } 

     Console.ReadKey(); 
     Console.WriteLine("Server stopped. Press any key to close app..."); 
    } 
} 

요청의 처리가 조금 이상 함과 동시에 사용자의 요청 처리 즉시 중지되고 응답이 전송되지 않습니다 응용 프로그램을 중지하려면 Ctrl + C를 누르면. 이 행동을 바꿀 수 있습니까? 나는 모든 새로운 요청을 거절하고 싶지만 현재 처리중인 요청이 완료 될 때까지 기다렸다가 그 후에 서버를 중지 할 때까지 기다린다.

나의 초기 아이디어는 현재 처리중인 요청을 추적하고 모든 것이 완료 될 때까지 작업을 연기 할 OWIN 미들웨어를 만드는 것입니다. 미들웨어는 또한 중지 단계에서 모든 요청을 단락시킵니다. 하지만이 솔루션은 나에게 좋지 않은 소리입니다.

Answer 1

나는 미들웨어와 제안 된 접근 방식으로 종료 :

public class ShutDownMiddleware 
{ 
    private readonly Func<IDictionary<string, object>, Task> next; 
    private static int requestCount = 0; 
    private static bool shutDownStateOn = false; 

    public static void ShutDown() 
    { 
     shutDownStateOn = true; 
    } 

    public static int GetRequestCount() 
    { 
     return requestCount; 
    } 

    public ShutDownMiddleware(Func<IDictionary<string, object>, Task> next) 
    { 
     this.next = next; 
    } 

    public async Task Invoke(IDictionary<string, object> environment) 
    { 
     if (shutDownStateOn) 
     { 
      environment["owin.ResponseStatusCode"] = HttpStatusCode.ServiceUnavailable; 
      return; 
     } 

     Interlocked.Increment(ref requestCount); 
     try 
     { 
      await next.Invoke(environment); 
     } 
     finally 
     { 
      Interlocked.Decrement(ref requestCount); 
     } 
    } 
} 

이 파이프 라인의 첫 번째 미들웨어로 등록 및 프로그램의 주요 방법 I는 다음과 같이 사용할 수 있습니다 :

public class Program 
{ 
    public static ManualResetEventSlim StopSwitch = new ManualResetEventSlim(); 

    static void Main(string[] args) 
    { 
     Console.CancelKeyPress += (s, a) => 
     { 
      a.Cancel = true; 
      StopSwitch.Set(); 
     }; 

     using (WebApp.Start<Startup>("http://+:8080/")) 
     { 
      Console.WriteLine("Server is running..."); 
      Console.WriteLine("Press CTRL+C to stop it."); 
      StopSwitch.Wait(); 
      Console.WriteLine("Server is stopping..."); 
      ShutDownMiddleware.ShutDown(); 
      while (ShutDownMiddleware.GetRequestCount() != 0) 
      { 
       Thread.Sleep(TimeSpan.FromSeconds(1)); 
      } 
     } 
    } 
} 

나는 또한 이것을 발견했다 : https://katanaproject.codeplex.com/workitem/281 그들은 비슷한 접근법에 대해 이야기하고있다.