Outbox Pattern

Dual-write problemi

Bir komut iki yere yazmak ister: (1) iş verisi (PostgreSQL), (2) integration event (RabbitMQ). Bunlar ayrı sistemler olduğu için atomik değildir:

DB commit oldu, ardından RabbitMQ publish başarısız → event kayboldu, downstream tutarsız.
RabbitMQ publish oldu, ardından DB commit rollback → “olmayan” bir olay yayınlandı.

Çözüm: Event’i RabbitMQ’ya doğrudan yazmak yerine, aynı DB transaction’ında bir outbox tablosuna yaz. DB commit’i ile event kaydı atomik olur. Ayrı bir background servis outbox satırlarını okuyup RabbitMQ’ya teslim eder.

MassTransit EF Core Outbox kurulumu

Outbox, building block içinde değil host projede (DbContext’in olduğu yerde) kurulur — AddMassTransitRabbitMqEventBus bunu configureExtra callback’i ile kabul eder. Application/DependencyInjection.cs:

builder.Services.AddMassTransitRabbitMqEventBus(builder.Configuration, x =>
{
    x.AddEntityFrameworkOutbox<DiyanetCleanArchitectureDbContext>(o =>
    {
        o.UsePostgres();
        o.UseBusOutbox();                                  // publish → outbox_message (RabbitMQ'ya değil)
        o.QueryDelay = TimeSpan.FromSeconds(1);            // outbox tarama aralığı
        o.DuplicateDetectionWindow = TimeSpan.FromMinutes(30);
    });
})
.AddMassTransitSubscription<CacheInvalidationIntegrationEvent, CacheInvalidationIntegrationEventHandler>();

Ayar	Değer	Anlamı
`UsePostgres()`	—	Outbox/inbox tablolarını PostgreSQL üzerinde tutar.
`UseBusOutbox()`	—	`IPublishEndpoint.Publish` artık RabbitMQ’ya değil, aynı transaction’da `outbox_message`’a yazar.
`QueryDelay`	`1s`	`OutboxDeliveryService` her saniye pending satırları tarar ve kuyruğa publish eder.
`DuplicateDetectionWindow`	`30 dk`	Inbox tarafında aynı mesaj iki kez gelirse atlanır (consumer idempotency güvencesi).

`messaging` şeması tabloları

Tablolar iş aggregate’lerinden ayrı, ayrı bir şemada tutulur (MESSAGING_SCHEMA = "messaging"). OnModelCreating’de map edilir (DiyanetCleanArchitectureDbContext.cs):

public const string MESSAGING_SCHEMA = "messaging";

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    // MassTransit EF Core Outbox + Inbox tabloları — `messaging` şemasında.
    modelBuilder.AddInboxStateEntity(e   => e.ToTable("inbox_state",   MESSAGING_SCHEMA));
    modelBuilder.AddOutboxStateEntity(e  => e.ToTable("outbox_state",  MESSAGING_SCHEMA));
    modelBuilder.AddOutboxMessageEntity(e => e.ToTable("outbox_message", MESSAGING_SCHEMA));
    // ...
    base.OnModelCreating(modelBuilder);
}

Tablo	Rol
`messaging.outbox_message`	Gönderilmeyi bekleyen integration event’lerin gövdesi.
`messaging.outbox_state`	Outbox delivery ilerlemesi/lock state’i.
`messaging.inbox_state`	Consume edilen mesajların kaydı — duplicate detection bunun üzerinden çalışır.

Bu tablolar EF Core migration’larıyla oluşur. messaging şeması, business (public) şemasından ayrıdır; bkz. Veri Katmanı.

Aynı transaction garantisi & lazy publish

UseBusOutbox aktifken IPublishEndpoint MassTransit pipeline’ında outbox wrapper’la sarılır. IEventBus’ı DbContext ctor’unda inject ettiğimiz için DI graph döngüye girebilir — host startup’ta (örn. MigrationService bir scope açıp DbContext resolve ettiğinde) soft deadlock gözlemlenir. Bu yüzden MassTransitEventBus IPublishEndpoint’i lazy resolve eder:

public async Task PublishAsync(IntegrationEvent @event, CancellationToken ct = default)
{
    // Lazy resolve — publish anında. ctor injection zincirine IPublishEndpoint girmez,
    // deadlock kırılır. Bu an SaveChanges sırasıdır → DbContext zaten scope'ta, outbox'a yazılır.
    var publishEndpoint = serviceProvider.GetRequiredService<IPublishEndpoint>();
    await publishEndpoint.Publish(@event, @event.GetType(), context => { /* routing key */ }, ct);
}

Sonuç: SaveEntitiesAsync → SaveChanges → domain event dispatch → PublishAsync → outbox satırı aynı transaction’a yazılır. DB commit fail olursa outbox da yazılmaz → exactly-once’a yaklaşır; RabbitMQ down ise satırlar outbox’ta birikir ve broker toparlanınca teslim edilir.

Inbox ile duplicate detection

Tüketici tarafında inbox_state, DuplicateDetectionWindow boyunca işlenen mesaj kimliklerini tutar. Aynı Id’li mesaj (retry/redelivery sonucu) tekrar gelirse atlanır. Bu, IntegrationEvent’in Id’sini serileştirmede koruması (bkz. Integration Events) ile birlikte çalışır. Yine de handler’ı idempotent yazmak en güvenli yoldur.

İlgili

RabbitMQ Topology

Outbox’tan çıkan mesajın gittiği exchange/queue.

Integration Events

IntegrationEvent base ve idempotency.

Event Akışı

Command → SaveEntities → Outbox tam akışı.

Veri Katmanı

messaging şeması ve migration’lar.

Başlarken

Mimari

Domain Katmanı (DDD)

Application Katmanı (CQRS)

Veri Katmanı (EF Core)

Altyapı Servisleri

BuildingBlocks

Kimlik ve Yetki

Keycloak

Cache Mimarisi

Event-Driven Akış

API ve Frontend

Operasyon

Senaryo Playbook'ları

Referans

Dual-write problemi

MassTransit EF Core Outbox kurulumu

`messaging` şeması tabloları

Aynı transaction garantisi & lazy publish

Inbox ile duplicate detection

İlgili

RabbitMQ Topology

Integration Events

Event Akışı

Veri Katmanı

​Dual-write problemi

​MassTransit EF Core Outbox kurulumu

​messaging şeması tabloları

​Aynı transaction garantisi & lazy publish

​Inbox ile duplicate detection

​İlgili

RabbitMQ Topology

Integration Events

Event Akışı

Veri Katmanı

Dual-write problemi

MassTransit EF Core Outbox kurulumu

`messaging` şeması tabloları

Aynı transaction garantisi & lazy publish

Inbox ile duplicate detection

İlgili