ASP.Net Web API không đọc tất cả các byte từ StreamContent

Question

Tôi có một ASP.Net Web API được thiết lập trên trang web của tôi được sử dụng để giao tiếp với một ứng dụng máy tính để bàn WPF. Tôi có một thiết lập hành động trên API để nhận tệp nhị phân từ ứng dụng khách. Tuy nhiên trong một số trường hợp (dường như ngẫu nhiên) khi tôi nhận được tất cả các byte từ yêu cầu, không phải tất cả các byte đều được đọc. Hy vọng rằng bạn có thể cho tôi một ý tưởng làm thế nào để làm điều này theo một cách mà sẽ làm việc tất cả các thời gian. Dưới đây là các mã:

Client Side:

public static SubmitTurnResult SubmitTurn(int turnId, Stream fileStream) 
{ 
    HttpClient client = CreateHttpClient(); 

    HttpContent content = new StreamContent(fileStream); 
    content.Headers.ContentDisposition = new ContentDispositionHeaderValue("attachment"); 
    content.Headers.ContentDisposition.FileName = "new-turn.Civ5Save"; 
    content.Headers.ContentType = new MediaTypeHeaderValue("application/octet-stream"); 
    content.Headers.ContentLength = fileStream.Length; 

    HttpResponseMessage response = client.PostAsync(
     string.Format("SubmitTurn?authKey={0}&turnId={1}", 
         LocalSettings.Instance.AuthenticationKey, 
         turnId 
         ), 
     content 
    ).Result; 

    response.EnsureSuccessStatusCode(); 

    return response.Content.ReadAsAsync<SubmitTurnResult>().Result; 
} 

SubmitTurnResult là một enum định nghĩa kết quả trên máy chủ, turnId là ID cho đơn vị tập tin này được gắn vào, và fileStream là một FileStream thực tế đọc các byte của đĩa.

Server Side:

[HttpGet, HttpPost] 
public SubmitTurnResult SubmitTurn(string authKey, int turnId) 
{ 

    try 
    { 
     bool worked = false; 
     int gameId = 0; 

     using (GmrEntities gmrDb = new GmrEntities()) 
     { 
      var player = gmrDb.Users.FirstOrDefault(u => u.AuthKey == authKey); 
      if (player != null) 
      { 
       var turn = player.Turns.FirstOrDefault(t => t.TurnID == turnId); 
       if (turn != null) 
       { 
        byte[] saveFileBytes = null; 

        using (MemoryStream tempStream = new MemoryStream()) 
        { 
         var task = this.Request.Content.CopyToAsync(tempStream); 
         task.Wait(); 

         saveFileBytes = tempStream.ToArray(); 
         tempStream.Close(); 
        } 

        if (saveFileBytes.Length != this.Request.Content.Headers.ContentLength.Value) 
        { 
         throw new Exception(string.Format("Byte array length ({0}) not equal to HTTP content-length header ({1}). This is not good!", 
            saveFileBytes.Length, this.Request.Content.Headers.ContentLength.Value)); 
        } 

        worked = GameManager.SubmitTurn(turn, saveFileBytes, gmrDb); 

        if (worked) 
        { 
         gameId = turn.Game.GameID; 

         gmrDb.SaveChanges(); 
        } 
       } 
      } 
     } 


     return SubmitTurnResult.OK; 
    } 
    catch (Exception exc) 
    { 
     DebugLogger.WriteExceptionWithComments(exc, string.Format("Diplomacy: Sumbitting turn for turnId: {0}", turnId)); 

     return SubmitTurnResult.UnexpectedError; 
    } 
} 

Answer 1

Như đã nêu trong bình luận trước đây của tôi, chúng tôi chạy vào hành vi này cùng với StreamContent, nhưng khi trình chiếu một phản hồi từ một Server 2003 dịch vụ Windows Web API. Nó không repro vào năm 2008. Trên thực tế, nó cũng repros trên Windows Server 2008 nếu tôi cấu hình máy ảo với một số lượng nhỏ RAM (712 MB), nhưng với 4 GB RAM nó không repro. Ngoài ra, chúng tôi thấy rằng điều này chỉ repros với một FileStream. Chuyển đổi FileStream thành MemoryStream bỏ qua vấn đề (với chi phí bộ nhớ của khóa học). Chúng tôi nhận thấy rằng khi luồng phản hồi kết thúc sớm, nó luôn nằm trên ranh giới 4096 byte và đạt đến giới hạn khoảng 3,5MB.

Dưới đây là cách khắc phục điều cố định đối với tôi, phù hợp với ví dụ mã của bạn:

public static SubmitTurnResult SubmitTurn(int turnId, Stream fileStream) 
{ 
    HttpClient client = CreateHttpClient(); 

    var memoryStream = new MemoryStream((int)fileStream.Length); 
    fileStream.CopyTo(memoryStream); 
    fileStream.Close(); 
    memoryStream.Seek(0, SeekOrigin.Begin); 
    HttpContent content = new StreamContent(memoryStream); 

Nếu muốn, bạn có điều kiện có thể làm MemoryStream sao chép chỉ khi Stream là một FileStream.