آموزش مدیریت همزمانی – Concurrency در EF Core

در برنامه‌هایی که چند کاربر به‌صورت همزمان داده‌ها را مشاهده یا ویرایش می‌کنند، نیاز به یک سیستم مطمئن برای جلوگیری از بروز تعارض – Conflict بین عملیات کاربران وجود دارد. این مسئله در EF Core از طریق مدیریت همزمانی یا Concurrency Handling کنترل می‌شود. در این آموزش به‌صورت کامل با مفاهیم تئوری و عملی مدیریت همزمانی آشنا خواهید شد. و روش‌های مختلف جلوگیری و حل Conflictها در EF Core را بررسی می‌کنیم. با ما همراه باشید با آموزش مدیریت همزمانی – Concurrency در EF Core و Asp.Net Core.

انواع همزمانی در EF Core

• همزمانی – Optimistic Concurrency : در این مدل، فرض بر این است که Conflict به‌ندرت رخ می‌دهد. کاربران می‌توانند به‌صورت همزمان داده‌ها را بخوانند و هنگام ذخیره، بررسی می‌شود که آیا داده‌ها تغییر کرده‌اند یا خیر.
• همزمانی Pessimistic Concurrency : در این مدل، رکوردها قبل از ویرایش قفل می‌شوند. در EF Core به‌صورت مستقیم پشتیبانی نمی‌شود اما با استفاده از دستورات SQL و Transactionها قابل پیاده‌سازی است.

Concurrency Conflict چیست؟

فرض کنید دو کاربر به‌صورت همزمان اطلاعات یک مشتری را ویرایش می‌کنند. اگر هر دو تغییرات را ذخیره کنند، بدون مدیریت همزمانی یکی از تغییرات از بین خواهد رفت. این وضعیت را Concurrency Conflict می‌نامند.

استفاده از [ConcurrencyCheck] و [Timestamp]

برای کنترل همزمانی می‌توان از Data Annotationهایی مانند [ConcurrencyCheck] یا [Timestamp] استفاده کرد. معمولاً از نوع byte[] برای Timestamp استفاده می‌شود که به‌صورت rowversion در SQL Server ذخیره می‌گردد.

public class Customer
{
public int Id { get; set; }
public string Name { get; set; }
[Timestamp]
public byte[] RowVersion { get; set; }
}

پیکربندی با Fluent API

در Fluent API نیز می‌توان فیلد همزمانی را به‌صورت زیر تعریف کرد:

modelBuilder.Entity<Customer>()
.Property(c => c.RowVersion)
.IsRowVersion();

مدیریت DbUpdateConcurrencyException

در صورت بروز Conflict، EF Core یک استثناء به نام DbUpdateConcurrencyException پرتاب می‌کند. برای مدیریت آن:

try
{
await context.SaveChangesAsync();
}
catch (DbUpdateConcurrencyException ex)
{
foreach (var entry in ex.Entries)
{
var databaseValues = await entry.GetDatabaseValuesAsync();
// مقایسه مقدار فعلی با مقدار دیتابیس و انتخاب بهترین راه‌حل
}
}

روش‌های متداول برای حل Conflict

• روش Client Wins: داده‌های سمت کاربر حفظ شود.
• روش Store Wins: داده‌های دیتابیس حفظ شود.
• روش Merge: ترکیب مقادیر و ذخیره‌سازی مجدد.

نمونه کد

public async Task<IActionResult> Edit(int id, [Bind("Id,Name,BankName,RowVersion")] Banker banker)
{
if(id!=banker.Id)
return NotFound();
if(!ModelState.IsValid)
return View(banker);
//اطلاعات ردیابی بانکر را بیار تا فیلد مورد نظر خود را مقدار دهی کنم
_context.Entry(banker).Property(a=>a.RowVersion).OriginalValue=banker.RowVersion;
try
{
_context.Update(banker);
await _context.SaveChangesAsync();
return RedirectToAction(nameof(Index));
}
catch (DbUpdateConcurrencyException ex)
{
foreach (var entry in ex.Entries)
{
var DbValue = await entry.GetDatabaseValuesAsync();
if (DbValue == null) {
TempData["ErrorMessage"] = "recorde morede nazar hazfe shode ast";
return RedirectToAction(nameof(Index));
}
var DatabaseValues = (Banker)DbValue.ToObject();
var CurrentValues = (Banker)entry.CurrentValues.ToObject();
var OriginalValues = (Banker)entry.OriginalValues.ToObject();
//Store Wins
//entry.OriginalValues.SetValues(DatabaseValues);
//entry.CurrentValues.SetValues(DatabaseValues);
//TempData["ErrorMessage"] = "ghable shoma in record viraiesh shode ast etelate shoma zakhire nashod";
//Client Wins
//entry.OriginalValues.SetValues(DatabaseValues);
//TempData["ErrorMessage"] = "در زمان ویرایش شما رگورد ویرایش شده بود ولی اطلاعات شما چایگزین شد";
}
await _context.SaveChangesAsync();
return RedirectToAction(nameof(Index));
}
}

آشتایی با متد های مرسوم Conflict

مدیریت همزمانی در EF Core یکی از مباحث مهم برای تضمین سلامت داده‌ها در برنامه‌های چندکاربره است. با استفاده از RowVersion، Attributeهای EF Core و مدیریت درست Conflictها می‌توان سیستم قابل اعتمادی برای ویرایش داده‌ها ایجاد کرد.