从已在DeadlineHandler中使用sequence的EventStoreException中恢复

Question

timestamp                      | aggregate_id                         | seq | type
                               |                                      |     |
2020-11-30T15:14:51.345541552Z | b02a5364-ee34-431a-ab1a-6c59bb937845 | 0   | MyAggregate
2020-11-30T15:14:52.06794746Z  | b02a5364-ee34-431a-ab1a-6c59bb937845 | 1   | MyAggregate

异常详细信息：

java prettyprint-override">org.axonframework.eventsourcing.eventstore.EventStoreException: An event for aggregate [b02a5364-ee34-431a-ab1a-6c59bb937845] at sequence [1] was already inserted

java.sql.BatchUpdateException: Batch entry 0 INSERT INTO events 
(event_id, aggregate_id, sequence_number, type, timestamp, payload_type, payload_revision, payload, metadata) 
VALUES 
('d5be369e-5fd0-475e-b5b6-e12449a4ed04',
'b02a5364-ee34-431a-ab1a -6c59bb937845',
1,
'MyAggregate',
'2020-11-30T15:14:52.067871723Z',
'MyEvent',
NULL,
'{"payload":"payload"}',
'{"metaData":"metaData"}') 
was aborted: ERROR: duplicate key value violates unique constraint "uk_aggregate_identifier_sequence_number"
  Detail: Key (aggregate_id, sequence_number)=(b02a5364-ee34-431a-ab1a-6c59bb937845, 1) already exists.

如您所见，事件的时间戳几乎相同:
eventa:2020-11-30t15:14:52.006794746z与eventb:2020-11-30t15:14:52.067871723z

Answer 1

首先回答您的问题，验证propagatingerrorhandler没有帮助，因为TrackingEventProcessor不会重试deadlineMessage。它只适用于重试真实事件，而deadlineMessage不是这种情况，因为它不是事件。

对于您的问题，我们假设您的Saga有一个DeadlineHandler，并且该组件正在向您的聚合发送一个命令，同时另一个组件也在向同一个聚合发送一个命令。这样，聚合无法处理第二个命令。基于此，我们可以给你两点建议：

• 具有一致的路由策略，该策略由CommandBus的分布式实现使用。简而言之，它将为您提供以下内容:

具有相同路由键的两个命令将始终路由到同一段。

• 在CommandGateway上配置RetryScheduler。您可以在这里阅读更多关于它的信息。

RetryScheduler能够在命令执行失败时调度重试。