saga中的事件處理非常接近一個普通的事件監(jiān)聽器。上述的對于方法和參數(shù)解析的規(guī)則在這里是有效的容握。不過,有一個主要區(qū)別逢艘。雖然存在事件監(jiān)聽器只有單個實例處理所有傳入事件，但也存在一個saga有多個實例衙四，每個實例都對不同的事件感興趣。例如,關(guān)于Order的id為1的管理業(yè)務(wù)Saga對Order“2”的事件不感興趣患亿，反之亦然传蹈。
Axon不會將所有事件都發(fā)布給所有saga實例（這將是對資源的完全浪費），而是只發(fā)布與saga相關(guān)聯(lián)的屬性的事件步藕。這個通過使用AssociationValues完成惦界。一個AssociationValue由key和value組成。key代表標(biāo)識符使用的類型咙冗，例如“orderId”或“order”沾歪。value表示前面例子中相應(yīng)“1”或“2”值。
帶@SagaEventHandler注解的方法被評估的順序與帶@EventHandler的相同雾消。如果處理器方法的參數(shù)與傳入的事件匹配灾搏，那么方法就匹配，如果saga有一個定義在處理器方法上的association屬性立润。
@SagaEventHandler注解有兩個attribute,其中associationProperty是最重要的狂窑。這是傳入事件上property的名稱，應(yīng)該用來尋找相關(guān)的saga桑腮。association值的key是property的名稱泉哈。這個值是由property的getter方法返回的值。
例如,考慮一個帶”String getOrderId()”方法傳入事件,返回“123”破讨。如果一個帶@SagaEventHandler(associationProperty = orderId)注解的方法接受這個事件,這個事件被路由到所有已經(jīng)與帶一個鍵為orderId和值為“123”的AssociationValues關(guān)聯(lián)的saga旨巷。這可能是一個,多個,甚至沒有。
有時,想要關(guān)聯(lián)的屬性的名稱不是想要使用的關(guān)聯(lián)的名稱添忘。例如,你有一個銷售訂單相匹配購買訂單的saga采呐。你可以有一個包含“buyOrderId”和“sellOrderId”的事務(wù)對象。如果你想要的saga將“orderId”作為關(guān)聯(lián)的值搁骑，你可以定義一個不同的keyName 在@SagaEventHandler注解中斧吐。它將變成@SagaEventHandler(associationProperty="sellOrderId", keyName="orderId")又固。
管理關(guān)聯(lián)
當(dāng)一個saga事務(wù)管理跨多個域的概念，如訂單煤率、發(fā)貨,仰冠、發(fā)票拯钻，等等歉甚，saga需要與這些概念的實例關(guān)聯(lián)。一個關(guān)聯(lián)需要兩個參數(shù)：key贬养，識別關(guān)聯(lián)的類型(訂單昼捍、發(fā)貨等)和一個value识虚，該值表示該概念的標(biāo)識符。
在以下幾個方面完成用概念關(guān)聯(lián)到saga妒茬。第一担锤，當(dāng)新創(chuàng)建一個saga時將調(diào)用一個用@StartSaga注解的事件處理器時，它將自動與@SagaEventHandler方法中標(biāo)識的關(guān)聯(lián)乍钻。所有其他的關(guān)聯(lián)用SagaLifecycle.associateWith(String key, String/Number value)方法創(chuàng)建肛循。用SagaLifecycle.removeAssociationWith(String key, String/Number value)方法去移除一個特定的關(guān)聯(lián)。
想象一下為一個圍繞著訂單的事務(wù)而已經(jīng)被創(chuàng)建的一個saga银择。saga自動關(guān)聯(lián)訂單多糠，方法被@StartSaga注解。saga是負(fù)責(zé)創(chuàng)建該訂單的發(fā)票浩考，并告訴航運創(chuàng)建一個載貨量夹孔。一旦貨物到達和發(fā)票支付,交易完成后,saga被關(guān)閉。
這是一個saga的代碼：
public class OrderManagementSaga {
private boolean paid = false;
private boolean delivered = false;
@Inject
private transient CommandGateway commandGateway;
@StartSaga
@SagaEventHandler(associationProperty = "orderId")
public void handle(OrderCreatedEvent event) {
// client generated identifiers
ShippingId shipmentId = createShipmentId();
InvoiceId invoiceId = createInvoiceId();
// associate the Saga with these values, before sending the commands
associateWith("shipmentId", shipmentId);
associateWith("invoiceId", invoiceId);
// send the commands
commandGateway.send(new PrepareShippingCommand(...));
commandGateway.send(new CreateInvoiceCommand(...));
}
@SagaEventHandler(associationProperty = "shipmentId")
public void handle(ShippingArrivedEvent event) {
delivered = true;
if (paid) { end(); }
}
@SagaEventHandler(associationProperty = "invoiceId")
public void handle(InvoicePaidEvent event) {
paid = true;
if (delivered) { end(); }
}
// ...
}
通過允許客戶端生成標(biāo)識符怀挠，可以很容易地與一個概念相關(guān)聯(lián)析蝴，而不需要請求響應(yīng)類型命令害捕。在發(fā)布命令之前绿淋，我們將事件與這些概念關(guān)聯(lián)起來。通過這種方式尝盼，我們也保證捕捉到作為該命令的一部分生成的事件吞滞。一旦發(fā)票付清，貨物到達盾沫，saga也將結(jié)束裁赠。
