Domain Olayları — Hesap Açılmadı, Hoş Geldin E-postası Neden Gitti?

Bir kulübün kayıt görevlisi her yeni üyede posta odasını ve hediye masasını tek tek arıyor. Bir gün kayıt son anda iptal oluyor, ama hediye çoktan yola çıkmış. Başka bir kulüpte görevli yalnızca panoya bir not asıyor: “yeni üye katıldı”.

Asıl iş herkesi tanımasın

Hesap servisi e-postayı, puanı ve risk kontrolünü kendisi çağırırsa, her yeni yan iş onu değiştirir. Servis, ilgisi olmayan servisleri tanımak zorunda kalır.

Bir domain olayı?Terimin tanımını açdomain olayıDomain'de olmuş bir şeyi geçmiş zamanla anlatan nesne: AccountOpened. Kimin dinleyeceğini bilmez.Sözlükte gör → bunu ayırır. Aggregate?Terimin tanımını açaggregateBirlikte tutarlı kalması gereken ve tek bir kök nesne üzerinden değiştirilen nesne kümesi. Dışarıdan yalnızca köke erişilir; başka aggregate'lara id ile referans verilir.Sözlükte gör → “AccountOpened” olayını kaydeder; e-posta ve puan bu olayı dinler. Hesap servisi artık onların varlığını bilmez.

Kodu ayırmak, hatayı ayırmak değil

Spring’in @TransactionalEventListener?Terimin tanımını aç@TransactionalEventListenerBir olayı transaction'ın belli bir aşamasında, varsayılan olarak commit'ten sonra işleyen Spring dinleyicisi.Sözlükte gör →’ı olayı commit’ten sonra işler. Commit başarısız olursa dinleyici hiç çalışmaz; açılmayan hesaba e-posta gitmez.

Dinleyicideki hata da artık asıl işi geri almaz. Hesap açık kalır, puan sonra yeniden denenir.

Kendin gör

1. Varsayılanla oynat. Servis her şeyi kendisi çağırıyor, puan servisi çöktü: hesap açılmadı, e-posta yine de gitti.
2. “@EventListener, aynı transaction” seç. Servis artık kimseyi tanımıyor; ama sonuç aynı.
3. “Commit başarısız” seç. Hesap yok, e-posta ve puan gitti.
4. “AFTER_COMMIT” seç ve iki hatayı da dene. Commit başarısızsa kimseye bir şey gitmez; puan servisi çökse de hesap açılır.

Tuzaklar

Kesin teslim beklemek. Commit sonrası dinleyici çalışırken uygulama çökerse olay kaybolabilir. Kaybolmaması gereken olaylar aynı transaction’da bir outbox?Terimin tanımını açoutboxOlayı, iş verisiyle aynı yerel transaction içinde bir tabloya yazıp ayrı bir süreçle kuyruğa taşıma deseni. İki kaynağa yazma (dual write) problemini çözer.Sözlükte gör → tablosuna da yazılır.

Commit sonrası veritabanına yazmak. O anda asıl transaction bitmiştir. Dinleyici yazacaksa yeni bir transaction açmalıdır (REQUIRES_NEW).

Her şeyi olaya taşımak. Asıl işle birlikte olması ya da hiç olmaması gereken bir iş (örneğin ledger satırı) olaya bırakılmaz; aynı transaction içinde yapılır.

1
@Entity
2
@Table(name = "accounts")
3
public class Account extends AbstractAggregateRoot<Account> {
4

5
    @Id
6
    private UUID id;
7

8
    @Column(name = "customer_id", nullable = false)
9
    private UUID customerId;
10

11
    @Column(nullable = false, unique = true)
12
    private String iban;
13

14
    protected Account() {
15
    }
16

17
    public static Account open(UUID customerId, String iban) {
18
        Account account = new Account();
19
        account.id = UUID.randomUUID();
20
        account.customerId = customerId;
21
        account.iban = iban;
22
        // A fact, in the past tense; the account does not know who listens.
23
        account.registerEvent(new AccountOpened(account.id, customerId, iban));
24
        return account;
25
    }
26

27
    public UUID id() {
28
        return id;
29
    }
30
}

1
public record AccountOpened(UUID accountId, UUID customerId, String iban) {
2
}

1
@Service
2
class OpenAccountService {
3

4
    private final AccountRepository accounts;
5
    private final IbanGenerator ibans;
6

7
    OpenAccountService(AccountRepository accounts, IbanGenerator ibans) {
8
        this.accounts = accounts;
9
        this.ibans = ibans;
10
    }
11

12
    @Transactional
13
    public UUID open(UUID customerId) {
14
        Account account = Account.open(customerId, ibans.next());
15
        accounts.save(account); // publishes AccountOpened to the listeners
16
        return account.id();
17
    }
18
}

1
@Component
2
class WelcomeMail {
3

4
    private final Mailer mailer;
5

6
    WelcomeMail(Mailer mailer) {
7
        this.mailer = mailer;
8
    }
9

10
    // Runs only after the account row is committed; a rolled-back opening sends nothing.
11
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
12
    void on(AccountOpened event) {
13
        mailer.sendWelcome(event.customerId(), event.iban());
14
    }
15
}

1
@Component
2
class WelcomePoints {
3

4
    private final PointsClient points;
5

6
    WelcomePoints(PointsClient points) {
7
        this.points = points;
8
    }
9

10
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
11
    @Transactional(propagation = Propagation.REQUIRES_NEW)
12
    void on(AccountOpened event) {
13
        // A failure here is logged and retried; the account stays open.
14
        points.grantWelcome(event.customerId());
15
    }
16
}

Kendini sına