1例发生错误后轴突粘连

Question

processor_name   |   segment owner| timestamp                      | token             | token_type
myapps.projection|       0    far |  2021-02-03T02:22:46.6003318Z  | {"globalIndex":32}|  org.axonframework.eventhandling.GlobalSequenceTrackingToken

当我的@eventHandler抛出错误时，就会发生这种情况。

说明：我有两个事件，具有相同的用户名，@EventHandler不能解决这个问题并抛出错误，因为用户名必须是唯一的。

令牌:31，有效负载：{“id”：“D6554811-EE5A-46D5-973D-1D61EE71C7FE”，“fullname”：“xasxsax”，“用户名”：“xasxsaxsa”，“email”：“[e-mail]”，“password”：“adminadmin”}

令牌:32，有效负载：{“id”：“b41efb71-14ee-4a5f-bdef-93b36e2e6a84”，“fullname”：“xasxsax”，“用户名”：“xasxsaxsa”，“email”：“[e-mail]”，“password”：“adminadmin”}

我的问题是，是否有任何最佳实践来处理错误，这样其他事件就可以很好地工作，而无需等待修复此单个事件？或者有什么解决办法可以解决这个问题？

Answer 1

假设您使用的是Axon4和默认的TrackingEventProcessor。这些事件形成一个流，因此您必须在处理下一个事件之前处理此事件；从@EventHandler抛出异常会告诉Axon您当前无法处理该事件。在这种特定的情况下，您可能只需要记录一个错误，而不是抛出，因为第二个事件根本没有意义--它要求创建已经存在的东西。

对于其他类型的失败事件，可能需要再次只记录错误并允许流继续，然后在修复了失败原因后重播事件。若要为单个聚合重播特定事件，可以执行如下操作：

@Autowired
EventStore eventStore;
    
@Test
public void testReplay() {
    
    String aggregateIdentifier = "1234";
    long startFrom = 0;
    String eventType = "org.sample.model.events.MyEvent";
    Class projectorClass = MyProjector.class;
    
    AnnotationEventHandlerAdapter eventHandlerAdapter = new AnnotationEventHandlerAdapter(projectorClass);
    DomainEventStream eventStream = eventStore.readEvents(aggregateIdentifier, startFrom);
    eventStream.asStream()
        .filter(event -> {
            // add any type of filtering based on the event here
            return event.getType() == eventType;
        })
        .forEach(event1 -> {
            try {
                eventHandlerAdapter.handle(event1);
            } catch (Exception e) {
                e.printStackTrace();
            }
        });
}

您可以在操作接口中公开此方法，以允许您的操作团队在分析后重播特定事件。