‫بررسی قابلیت بازآزمایی توکار (Configurable Retry Logic) در Microsoft.Data.SqlClient

چکیده: خطاهای گذرا (Transient Faults)، نظیر قطع ناگهانی ارتباط، تاخیرهای موقت شبکه و تغییر وضعیت سرور در محیط‌های ابری، از اجتناب‌ناپذیرترین چالش‌های معماری مدرن نرم‌افزار هستند. سال‌ها توسعه‌دهندگان پلتفرم دات‌نت (.NET) برای مقابله با این خطاها به پکیج‌های ثالث نظیر Polly متکی بودند. با معرفی فضای نام Microsoft.Data.SqlClient و اضافه شدن قابلیت بازآزمایی پیکربندی‌پذیر (Configurable Retry Logic)، این مسئولیت به طور توکار و در لایه درایور پایگاه‌داده تعبیه شده‌است. این مقاله به بررسی چرایی مهاجرت از درایور سنتی System.Data.SqlClient به Microsoft.Data.SqlClient، نحوه پیاده‌سازی مکانیزم‌های بازآزمایی برای SqlConnection و SqlCommand، تفاوت‌های کلیدی آن با Polly، و ملاحظات حساس معماری پیرامون تراکنش‌ها و پایستگی (Idempotency) می‌پردازد.

• جابه‌جایی گره‌ها در خوشه‌های ابری (Failover)
• پر شدن لحظه‌ای پهنای باند شبکه
• بن‌بست‌های لحظه‌ای (Deadlocks) یا تخلیه نشست‌ها (Connection Throttling)

using System;
using System.Threading.Tasks;
using Microsoft.Data.SqlClient;

public class DatabaseConnectionFactory
{
    private readonly string _connectionString;
    private readonly SqlRetryLogicBaseProvider _retryProvider;

    public DatabaseConnectionFactory(string connectionString)
    {
        _connectionString = connectionString;

        // تعریف پارامترهای منطق بازآزمایی
        var retryOptions = new SqlRetryLogicOption
        {
            NumberOfTries = 5,                         // یک بار تلاش اولیه + ۴ بار بازآزمایی
            DeltaTime = TimeSpan.FromSeconds(1),        // وقفه پایه برای پس‌روی نمایی
            MaxTimeInterval = TimeSpan.FromSeconds(20),  // حداکثر سقف مجاز برای هر وقفه
            TransientErrors = null                      // null به معنای استفاده از لیست خطاهای گذرای پیش‌فرض درایور است
        };

        // ایجاد ارائه‌دهنده بازآزمایی نمایی با جیتر (Jitter) داخلی
        _retryProvider = SqlConfigurableRetryFactory.CreateExponentialRetryProvider(retryOptions);
    }

    public async Task<SqlConnection> CreateOpenConnectionAsync()
    {
        var connection = new SqlConnection(_connectionString)
        {
            RetryLogicProvider = _retryProvider
        };

        // در صورت بروز خطای گذرا، به صورت خودکار بازآزمایی انجام می‌شود
        await connection.OpenAsync();
        return connection;
    }
}

نکته:MaxTimeInterval سقف هر وقفه منفرد را مشخص می‌کند، نه کل زمان سپری‌شده در تمامی دفعات تلاش.

var commandRetryOptions = new SqlRetryLogicOption
{
    NumberOfTries = 3,
    DeltaTime = TimeSpan.FromMilliseconds(500),
    MaxTimeInterval = TimeSpan.FromSeconds(5),
    // اعمال بازآزمایی صرفاً روی کوئری‌های فاقد اثر جانبی (Idempotent)
    AuthorizedSqlCondition = cmd => 
        cmd is SqlCommand sqlCmd && 
        sqlCmd.CommandText.TrimStart().StartsWith("SELECT", StringComparison.OrdinalIgnoreCase)
};

var commandRetryProvider = SqlConfigurableRetryFactory.CreateExponentialRetryProvider(commandRetryOptions);

using var command = new SqlCommand("SELECT * FROM Products WHERE CategoryId = @id", connection)
{
    RetryLogicProvider = commandRetryProvider
};
command.Parameters.AddWithValue("@id", 10);

راه حل: در فرآیندهای تراکنشی، باید کل بلوک تراکنش (BeginTransaction تا Commit) از نقطه شروع مجدداً تکرار شود، نه اینکه دستورِ شکست‌خورده به تنهایی درون تراکنش معیوب Retry گردد.

options.UseSqlServer(connectionString, sqlOptions =>
{
    sqlOptions.EnableRetryOnFailure(
        maxRetryCount: 5,
        maxRetryDelay: TimeSpan.FromSeconds(10),
        errorNumbersToAdd: null);
});