如何处理与 HttpClient 的并发冲突？

Question

在看到 DB 中的更改后，我不知道如何编辑该行。

• 我有一个 API 项目和一个 MVC 项目。我在我的 API 中使用 CRUD，并使用我的 MVC 和 HttpClient 调用它们
• 我有一个public byte[] RowVersion { get; set; } 属性，属性为[Timestamp]。
• 我有一个 clientFactory，我在其中执行 CreateClient() 以执行 PutAsync("api.example.com/{id}") 操作。
• 我的 putasync 操作上的 HttpResponseMessage variable 返回 StatusCode(409)，因为我的 API 成功检测到并发冲突。
• 我设法在更新并发之前显示错误消息；在新客户端 clientFactory.CreateClient() 的帮助下显示数据库（newsDb）中新更新的行，并将它们与输入（新闻）进行比较。
• 然后我设置news.RowVersion = newsDb.RowVersion 并重新显示视图（新闻）。

再次单击“保存”后，什么也没有发生 - 没有重定向，没有更改 - 并发错误仍然存​​在：

[HttpPost("edit/{id}")]
[ValidateAntiForgeryToken]
public async Task<IActionResult> EditNewsArticle(int id, [Bind("NewsId,Author,Title,Content,CreatedDate,HashTags,RowVersion")] News news)
{
    if (id != news.NewsId)
    {
        return NotFound();
    }

    if (ModelState.IsValid)
    {
        news.UpdatedDate = DateTime.Now;
        string json = JsonConvert.SerializeObject(news);
        HttpResponseMessage putTask = await clientFactory.CreateClient().PutAsync($"https://localhost:44331/api/News/{id}", new StringContent(json, Encoding.UTF8, "application/json"));

        if (putTask.IsSuccessStatusCode)
        {
            return RedirectToAction(nameof(Index));
        }
        else if (putTask.StatusCode == HttpStatusCode.Conflict)
        {
            string jsonDb = await clientFactory.CreateClient().GetStringAsync($"https://localhost:44331/api/News/{id}");
            News newsDb = JsonConvert.DeserializeObject<News>(jsonDb);

            if (newsDb is null)
            {
                ModelState.AddModelError(string.Empty, $"Unfortunately, the news item you edited has already been deleted by another user.");
            }

            if (newsDb.Title != news.Title)
            {
                ModelState.AddModelError("Title", $"Title in database: {newsDb.Title}");
            }
            if (newsDb.Author != news.Author)
            {
                ModelState.AddModelError("Author", $"Author in database: {newsDb.Author}");
            }
            if (newsDb.Content != news.Content)
            {
                ModelState.AddModelError("Content", $"Content in database: {newsDb.Content}");
            }
            if (newsDb.HashTags != news.HashTags)
            {
                ModelState.AddModelError("HashTags", $"HashTags in database: {newsDb.HashTags}");
            }

            ModelState.AddModelError(string.Empty,
            "Editing was canceled as the selected news item was changed by someone else in the meantime." +
            "The values ​​of the change are now shown below, which are derived from the database" + 
            "If you still want to edit the user, click Save again.");

            news.RowVersion = newsDb.RowVersion;
        }
        else
        {
            ModelState.AddModelError(string.Empty, "Unknown error. Contact a support.");
            return View(news);
        }
    }

    return View(news);
}

API 放置：

[HttpPut("{id}")]
public async Task<IActionResult> PutNews(int id, [FromBody] News news)
{
    if (id != news.NewsId)
    {
        return BadRequest();
    }

    context.Entry(news).State = EntityState.Modified;

    try
    {
        await context.SaveChangesAsync();
    }
    catch (DbUpdateConcurrencyException)
    {
        if (!NewsExists(id))
        {
            return NotFound();
        }
        else
        {
            return StatusCode(409);
        }
    }

    return CreatedAtAction("GetNews", new { id = news.NewsId }, news);
}

Answer 1

我发现了我的问题。我需要调用 ModelState.Clear();在反序列化 'jsonDb' 之后，还要从属性中的 Bind 中删除 RowVersion。