مسارات العمل الموثوقة وحد الصندوق الصادر

package training.catalog;

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

record OutboxHint(long orderId) {}

@Service
class OrderApplication {
    private final OrderStore orders;
    private final OutboxStore outbox;
    private final ApplicationEventPublisher events;
    OrderApplication(OrderStore orders, OutboxStore outbox, ApplicationEventPublisher events) {
        this.orders=orders; this.outbox=outbox; this.events=events;
    }
    @Transactional
    public Receipt place(TrustedOrderCommand command) {
        Receipt receipt=orders.insertOrReplay(command);
        outbox.ensureOrderCreated(receipt, command.operationKey());
        events.publishEvent(new OutboxHint(receipt.orderId()));
        return receipt;
    }
}

يلزم أن يشترك المخزنان بالمعاملة ويفرضا الهوية؛ وليس التلميح المحلي السجل الدائم.

package training.catalog;

import org.springframework.stereotype.Component;
import org.springframework.transaction.event.TransactionPhase;
import org.springframework.transaction.event.TransactionalEventListener;

@Component
class OutboxWakeup {
    private final OutboxDispatcher dispatcher;
    OutboxWakeup(OutboxDispatcher dispatcher) { this.dispatcher=dispatcher; }
    @TransactionalEventListener(phase=TransactionPhase.AFTER_COMMIT)
    void committed(OutboxHint hint) { dispatcher.signal(); }
}

يبقى الماسح الدائم مطلوباً؛ ولم ينفذ حدث أو موزع، و signal قدرة مخصصة لا ضمان تسليم.

public class Main {

 public static void main(String[] args) throws Exception {
var seen=new java.util.HashSet<String>();
int applied=0;
for(String event:java.util.List.of("e1","e1","e2")) if(seen.add(event)) applied++;
System.out.println("first_pass "+applied);
seen.clear();
if(seen.add("e1")) applied++;
System.out.println("after_memory_loss "+applied);
 }
}

first_pass 2
after_memory_loss 3

يسمح مسح ذاكرة المنع بتكرار أثر في النموذج دون انهيار أوحفظ أوتسليم خارجي فعلي.