🏢 معماری چند-مستأجره با EF Core (قسمت ۲):

"Tenants": [
    { "Id": "tenant-1", "ConnectionString": "Host=tenant1.db;Database=db1" },
    { "Id": "tenant-2", "ConnectionString": "Host=tenant2.db;Database=db2" }
]

public sealed class TenantProvider
{
    // ... (Properties for HttpContextAccessor and TenantSettings)

    public TenantProvider(
        IHttpContextAccessor httpContextAccessor,
        IOptions<TenantSettings> tenantsOptions)
    {
        // ...
        _tenantSettings = tenantsOptions.Value;
    }

    public string TenantId => /* ... gets tenantId from header ... */;

    public string GetConnectionString()
    {
        return _tenantSettings.Tenants
            .Single(t => t.Id == TenantId).ConnectionString;
    }
}

builder.Services.AddDbContext<OrdersDbContext>((serviceProvider, options) =>
{
    // TenantProvider رو از DI میگیریم
    var tenantProvider = serviceProvider.GetRequiredService<TenantProvider>();

    // Connection String مخصوص مستأجر فعلی رو میگیریم
    var connectionString = tenantProvider.GetConnectionString();

    // و DbContext رو با اون کانفیگ می‌کنیم
    options.UseSqlServer(connectionString);
});

🤔 حرف حساب و تجربه شمابا این دو روش

🔖 هشتگ‌ها:
#CSharp #ASPNETCore #DotNet #MultiTenancy #EntityFrameworkCore #SoftwareArchitecture #Backend

🔐 ذخیره‌سازی امن اسرار برنامه در محیط توسعه در ASP.NET Core

متغیرهای محیطی (Environment variables) 🌍

⚠️ هشدار

ابزار Secret Manager 🕵️‍♂️

⚠️ هشدار

نحوه کار ابزار Secret Manager 🪄

فعال کردن ذخیره‌سازی اسرار
از طریق CLI: ❯

تنظیم یک سرّ ✍️

دسترسی به یک سرّ 📖

var builder = WebApplication.CreateBuilder(args);
var movieApiKey = builder.Configuration["Movies:ServiceApiKey"];
var app = builder.Build();

app.MapGet("/", () => movieApiKey);

app.Run();

public class IndexModel : PageModel
{
    private readonly IConfiguration _config;

    public IndexModel(IConfiguration config)
    {
        _config = config;
    }

    public void OnGet()
    {
        var moviesApiKey = _config["Movies:ServiceApiKey"];
        // ...
    }
}

مپ کردن اسرار به یک POCO 🔗

{
  "Movies:ConnectionString": "Server=(localdb)\\mssqllocaldb;Database=Movie-1;Trusted_Connection=True;MultipleActiveResultSets=true",
  "Movies:ServiceApiKey": "12345"
}

var moviesConfig = 
    Configuration.GetSection("Movies").Get<MovieSettings>();
var _moviesApiKey = moviesConfig.ServiceApiKey;

public class MovieSettings
{
    public string ConnectionString { get; set; }
    public string ServiceApiKey { get; set; }
}

جایگزینی رشته با اسرار 🛠️

using System.Data.SqlClient;

var builder = WebApplication.CreateBuilder(args);

var conStrBuilder = new SqlConnectionStringBuilder(
        builder.Configuration.GetConnectionString("Movies"));
conStrBuilder.Password = builder.Configuration["DbPassword"];
var connection = conStrBuilder.ConnectionString;

var app = builder.Build();
app.MapGet("/", () => connection);
app.Run();

📑 دستورات CLI

Install-Package Microsoft.Extensions.Configuration
Install-Package Microsoft.Extensions.Configuration.UserSecrets

dotnet add package Microsoft.Extensions.Configuration
dotnet add package Microsoft.Extensions.Configuration.UserSecrets

using Microsoft.Extensions.Configuration;

class Program
{
    static void Main(string[] args)
    {
        IConfigurationRoot config = new ConfigurationBuilder()
            .AddUserSecrets<Program>()
            .Build();

        Console.WriteLine(config["AppSecret"]);
    }
}

#programming_memes
#fun

🚀 چرا Connection String رو مستقیم تو appsettings.json نگذاریم؟

dotnet add package Azure.Extensions.AspNetCore.Configuration.Secrets
dotnet add package Azure.Identity

<PropertyGroup>
  <UserSecretsId>{GUID}</UserSecretsId>
</PropertyGroup>

dotnet user-secrets set "DbConnection" "Server=.;Database=Test;User Id=sa;Password=1234"

az group create --name "MyGroup" --location "westeurope"
az keyvault create --name "myvault123" --resource-group "MyGroup" --location "westeurope"

az keyvault secret set --vault-name "myvault123" --name "DbConnection" --value "Server=sql.example.com;Database=Prod;..."

builder.Configuration.AddAzureKeyVault(
    new Uri($"https://{builder.Configuration["KeyVaultName"]}.vault.azure.net/"),
    new ClientCertificateCredential(
        builder.Configuration["AzureADDirectoryId"],
        builder.Configuration["AzureADApplicationId"],
        x509Certificate));

builder.Configuration.AddAzureKeyVault(
    new Uri($"https://{builder.Configuration["KeyVaultName"]}.vault.azure.net/"),
    new DefaultAzureCredential());

📌 بهترین نکات امنیتی

🔖 هشتگ‌ها:
#CSharp #ASPNetCore #Azure #KeyVault #CodeSafety #MicrosoftAzure #ConnectionString

📌الگوی Saga چی هست و چرا بهش نیاز داریم؟
[Saga distributed transactions pattern]

📍زمینه و مشکل (Context and problem)

⚖️تراکنش‌ها باید به اصول ACID پایبند باشند:

🏗چالش‌ها در معماری‌های مایکروسرویس
(Challenges in microservices architectures)

💡راهکار (Solution)

🔑 مفاهیم کلیدی در الگوی Saga
(Key concepts in the Saga pattern)

تراکنش‌های قابل جبران (Compensable Transactions):

تراکنش محوری (Pivot Transaction):

تراکنش‌های قابل تکرار (Retryable Transactions):

رویکردهای پیاده‌سازی Saga
(Saga implementation approaches)

1️⃣ Choreography

2️⃣ Orchestration

🛠مشکلات و ملاحظات
(Problems and considerations)

⚠️ناهنجاری‌های داده‌ای در Saga
(Potential data anomalies in sagas)

🛡راهکارهای جلوگیری از ناهنجاری‌ها
(Strategies to address data anomalies)

📌زمان استفاده از این الگو
(When to use this pattern)

🔖 هشتگ‌ها:
#Microservices #SagaPattern #SoftwareArchitecture

استفاده از چند EF Core DbContext در یک برنامه

📌 چرا از چندین DbContext استفاده کنیم؟

⚙️ ایجاد چندین DbContext در یک برنامه

public class CatalogDbContext : DbContext
{
    public DbSet<Product> Products { get; set; }
    public DbSet<Category> Categories { get; set; }
}

public class OrderDbContext : DbContext
{
    public DbSet<Order> Orders { get; set; }
    public DbSet<LineItem> LineItems { get; set; }
}

services.AddDbContext<CatalogDbContext>(options =>
    options.UseSqlServer("CONNECTION_STRING"));

services.AddDbContext<OrderDbContext>(options =>
    options.UseSqlServer("CONNECTION_STRING"));

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.HasDefaultSchema("catalog");
}

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.HasDefaultSchema("order");
}

⚠️ محدودیت‌ها در استفاده از چندین DbContext

services.AddDbContext<CatalogDbContext>(options =>
    options.UseSqlServer(
        "CONNECTION_STRING",
        o => o.MigrationsHistoryTable(
            tableName: HistoryRepository.DefaultTableName,
            schema: "catalog")));

✅ مزایای استفاده از چندین DbContext

🔖هشتگ‌ها:
#DotNet #EFCore #CSharp #DbContext #ModularMonolith #EntityFramework #DatabaseDesign

💡 نکته عملکردی C#/.NET – آرایه‌های Inline 🔥

✅ چند مزیت آرایه‌های Inline:

🔖هشتگ‌ها:
#csharp #dotnet #programming #softwareengineering #softwaredevelopment

📨 معماری رویدادمحور (Event-Driven Architecture) در NET. با RabbitMQ

📌 سناریوی ما

🐳 اجرای RabbitMQ با Docker

docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:4-management

🛠 مفاهیم پایه RabbitMQ

💡 نکته: در RabbitMQ، تولیدکنندگان هرگز مستقیماً به یک صف ارسال نمی‌کنند، بلکه به یک Exchange ارسال می‌کنند. Exchange تعیین می‌کند که پیام به کدام صف یا صف‌ها برود.

var factory = new ConnectionFactory() { HostName = "localhost" };
using var connection = await factory.CreateConnectionAsync();
using var channel = await connection.CreateChannelAsync();

await channel.QueueDeclareAsync(
    queue: "orders",
    durable: true,
    exclusive: false,
    autoDelete: false,
    arguments: null);

var orderPlaced = new OrderPlaced
{
    OrderId = Guid.NewGuid(),
    Total = 99.99,
    CreatedAt = DateTime.UtcNow
};
var message = JsonSerializer.Serialize(orderPlaced);
var body = Encoding.UTF8.GetBytes(message);

await channel.BasicPublishAsync(
    exchange: string.Empty,
    routingKey: "orders",
    mandatory: true,
    basicProperties: new BasicProperties { Persistent = true },
    body: body);

Console.WriteLine($"Sent: {message}");

📌 نکات مهم:

var factory = new ConnectionFactory() { HostName = "localhost" };
using var connection = await factory.CreateConnectionAsync();
using var channel = await connection.CreateChannelAsync();

await channel.QueueDeclareAsync(
    queue: "orders",
    durable: true,
    exclusive: false,
    autoDelete: false,
    arguments: null);

var consumer = new AsyncEventingBasicConsumer(channel);
consumer.ReceivedAsync += async (sender, eventArgs) =>
{
    byte[] body = eventArgs.Body.ToArray();
    string message = Encoding.UTF8.GetString(body);
    var orderPlaced = JsonSerializer.Deserialize<OrderPlaced>(message);

    Console.WriteLine($"Received: OrderPlaced - {orderPlaced.OrderId}");

    await ((AsyncEventingBasicConsumer)sender)
        .Channel.BasicAckAsync(eventArgs.DeliveryTag, multiple: false);
};
await channel.BasicConsumeAsync("orders", autoAck: false, consumer);

Console.WriteLine("Waiting for messages...");

📌 نکات مهم:

await channel.ExchangeDeclareAsync(
    exchange: "orders",
    durable: true,
    autoDelete: false,
    type: ExchangeType.Fanout);

await channel.BasicPublishAsync(
    exchange: "orders",
    routingKey: string.Empty,
    mandatory: true,
    basicProperties: new BasicProperties { Persistent = true },
    body: body);

await channel.ExchangeDeclareAsync(
    exchange: "orders",
    durable: true,
    autoDelete: false,
    type: ExchangeType.Fanout);

await channel.QueueDeclareAsync(
    queue: "orders-consumer-1",
    durable: true,
    exclusive: false,
    autoDelete: false,
    arguments: null);

await channel.QueueBindAsync("orders-consumer-1", "orders", string.Empty);

🏷 هشتگ‌ها:
#RabbitMQ #DotNet #EventDrivenArchitecture #MessageBroker

🚀 جادوی async/await در #C:

1️⃣ داستان سرآشپز صبور (آنالوژی) 👨‍🍳

2️⃣ کلمات کلیدی جادویی: async, await, Task ✨

3️⃣ مثال عملی: دانلود کردن یک فایل

// ❌ این متد نخ اصلی رو برای ۵ ثانیه قفل می‌کنه!
public void DownloadFile()
{
    Thread.Sleep(5000); // شبیه‌سازی یک عملیات زمان‌بر و مسدودکننده
    Console.WriteLine("Download complete.");
}

// ✅ این متد نخ اصلی رو آزاد می‌کنه و برنامه پاسخگو باقی می‌مونه
public async Task DownloadFileAsync()
{
    // await کنترل رو به بیرون برمی‌گردونه و منتظر می‌مونه
    await Task.Delay(5000); // شبیه‌سازی یک عملیات غیرهمزمان
    Console.WriteLine("Download complete.");
}

🔖 هشتگ‌ها:
#CSharp #Programming #Developer #DotNet #Async #Await #Concurrency

کتابخانه جدید کشینگ 🆕
HybridCache در ASP.NET Core

HybridCache چیست؟ 🤔

1️⃣ کشینگ دو سطحی (L1/L2)

2️⃣ محافظت در برابر cache stampede
(زمانی که درخواست‌های زیادی به یکباره به کش خالی برخورد می‌کنند)

3️⃣ نامعتبرسازی کش بر اساس تگ

4️⃣ سریال‌سازی قابل پیکربندی

5️⃣ معیارها و مانیتورینگ

نصب HybridCache 📦

builder.Services.AddHybridCache(options =>
{
    // حداکثر اندازه آیتم‌های کش شده
    options.MaximumPayloadBytes = 1024 * 1024 * 10; // 10MB
    options.MaximumKeyLength = 512;
    
    // تایم‌اوت‌های پیش‌فرض
    options.DefaultEntryOptions = new HybridCacheEntryOptions
    {
        Expiration = TimeSpan.FromMinutes(30),
        LocalCacheExpiration = TimeSpan.FromMinutes(30)
    };
});

builder.Services.AddHybridCache()
    .AddSerializer<CustomType, CustomSerializer>();

استفاده از HybridCache 👨‍💻

گرفتن یا ایجاد ورودی‌های کش 🔎

app.MapGet("/products/{id}", async (
    int id,
    HybridCache cache,
    ProductDbContext db,
    CancellationToken ct) =>
{
    var product = await cache.GetOrCreateAsync(
        $"product-{id}",
        async token =>
        {
            return await db.Products
                .Include(p => p.Category)
                .FirstOrDefaultAsync(p => p.Id == id, token);
        },
        cancellationToken: ct
    );
    
    return product is null ? Results.NotFound() : Results.Ok(product);
});

تنظیم مستقیم ورودی‌های کش ✍️

app.MapPut("/products/{id}", async (int id, Product product, HybridCache cache) =>
{
    // ابتدا دیتابیس را به‌روزرسانی کنید
    await UpdateProductInDatabase(product);
    
    // سپس کش را با انقضای سفارشی به‌روزرسانی کنید
    var options = new HybridCacheEntryOptions
    {
        Expiration = TimeSpan.FromHours(1),
        LocalCacheExpiration = TimeSpan.FromMinutes(30)
    };
    
    await cache.SetAsync(
        $"product-{id}",
        product,
        options
    );
    
    return Results.NoContent();
});

استفاده از تگ‌های کش 🏷

app.MapGet("/categories/{id}/products", async (...) =>
{
    var tags = [$"category-{id}", "products"];
    
    var products = await cache.GetOrCreateAsync(
        $"products-by-category-{id}",
        async token => { /* ... fetch products ... */ },
        tags: tags,
        cancellationToken: ct
    );
    
    return Results.Ok(products);
});

// Endpoint برای نامعتبر کردن تمام محصولات در یک دسته‌بندی
app.MapPost("/categories/{id}/invalidate", async (id, cache, ct) =>
{
    await cache.RemoveByTagAsync($"category-{id}", ct);
    return Results.NoContent();
});

📍تگ‌ها برای موارد زیر مفید هستند:

حذف ورودی‌های تکی 🗑

app.MapDelete("/products/{id}", async (int id, HybridCache cache) =>
{
    // ابتدا از دیتابیس حذف کنید
    await DeleteProductFromDatabase(id);
    
    // سپس از کش حذف کنید
    await cache.RemoveAsync($"product-{id}");
    
    return Results.NoContent();
});

افزودن Redis به عنوان کش L2 🔥

// افزودن Redis
builder.Services.AddStackExchangeRedisCache(options =>
{
    options.Configuration = "your-redis-connection-string";
});
// افزودن HybridCache - به طور خودکار از Redis به عنوان L2 استفاده خواهد کرد
builder.Services.AddHybridCache();

خلاصه 📝

🔖 هشتگ‌ها:
#CSharp #Programming #Developer #DotNet #HybridCache