Axon框架发送Command至Aggregate时EventHandler先于CommandHandler触发问题
问题原因
- 子实体路由匹配失败
你给GiftCard的@AggregateMember配置了routingKey = "transactionId",但你发送的ReimburseCardCommand仅包含cardId和transactionValue两个字段,没有携带对应transactionId属性,Axon无法匹配到对应的GiftCardTransaction子实体,最终路由到了父GiftCard类中定义的ReimburseCardCommand处理器。 - 事件提前触发的问题
你在GiftCard的CardIssuedEvent事件溯源处理器中,主动调用了apply(new CardReimbursedEvent(...)),这个操作会在创建GiftCard聚合、处理IssueCardCommand的阶段就触发CardReimbursedEvent的事件处理逻辑,早于你后续发送的ReimburseCardCommand的执行时间,也就是你观察到的EventHandler先于CommandHandler执行的根因。 - 父聚合重复定义了命令处理器
父GiftCard类已经定义了ReimburseCardCommand的@CommandHandler方法,Axon匹配到该处理器后不会再向下路由到子实体的同名命令处理器。
解决步骤
- 修改
ReimburseCardCommand类,新增transactionId字段,同时保留原有cardId字段(cardId用于路由到父GiftCard聚合,transactionId用于路由到对应子实体)。 - 删除
GiftCard类中定义的public void handle(ReimburseCardCommand cmd)命令处理器。 - 删除
GiftCard的CardIssuedEvent事件溯源处理器中多余的apply(new CardReimbursedEvent(...))代码,避免非预期的事件提前触发。
调整后重新发送携带正确cardId和对应transactionId的ReimburseCardCommand,即可命中GiftCardTransaction子实体的命令处理器。
内容的提问来源于stack exchange,提问作者Yong D
相关产品推荐
相关产品推荐

