Axon Saga 没有被创建答案

【问题标题】：Axon Saga not getting createdAxon Saga 没有被创建
【发布时间】：2021-03-04 18:14:44
【问题描述】：

我有一个使用 axon 框架的 spring boot 应用程序存储轴突表的数据库（saga_entry、domain_event_entry、association_value_entry ...）保存在 Postgres 中（不使用轴突服务器）

由于某种原因，这个特殊的 Saga 没有被创建（直到最近它过去一直正常工作）

@StartSaga()
@SagaEventHandler(associationProperty = JOB_ID)
public void onVersionRefreshJobCreatedEvent(VersionRefreshJobCreatedEvent event) {
    log.info("Version Refresh Job Created With job Id: {}", event.getJobId());
        ...
}

我启动了几个作业（每个作业都是聚合的实例），但所有这些作业都没有继续达到传奇

我检查了 domain_event_entry 表以查看事件（创建传奇的事件）是否正在发布

SELECT *
FROM domain_event_entry
WHERE payload_type = 'VersionRefreshJobCreatedEvent'
ORDER BY time_stamp DESC;

2785210 24023a4e-fa93-4c5d-a3fe-a267849f302e    43014637    43014638        VersionRefreshJobCreatedEvent   2021-03-04T18:19:01.787Z    83309b8c-4d75-4ed9-bd41-e5dfd824a28e    0   VersionRefreshAggregate
2784852 0f0e8e89-5a9a-4133-93e5-0f9ae155ee29    43009375    43009376        VersionRefreshJobCreatedEvent   2021-03-04T17:20:47.441Z    0cdd5b5f-be40-479a-a8a3-888bf7088188    0   VersionRefreshAggregate
2784851 064e538b-b561-4a31-a494-1916a6434233    43009351    43009352        VersionRefreshJobCreatedEvent   2021-03-04T17:20:42.196Z    3a371eb8-32aa-4664-8a82-16f375b9f4e9    0   VersionRefreshAggregate
2784711 e6c5da48-3145-4f16-aabf-c9eba442e04f    43007446    43007447        VersionRefreshJobCreatedEvent   2021-03-04T17:00:53.527Z    b381ef87-9ca9-4cc1-9b1a-f93321f3fee3    0   VersionRefreshAggregate
2784580 cd4fe64e-dd25-459e-ac57-d4d46c521e8c    43005436    43005437        VersionRefreshJobCreatedEvent   2021-03-04T16:42:08.501Z    08924458-e931-4fec-b5d0-b6b117ebdd3a    0   VersionRefreshAggregate
2784075 fbd3c2da-d0ee-49a0-b1c3-26ad7c99ae8a    42997780    42997781        VersionRefreshJobCreatedEvent   2021-03-04T15:23:36.404Z    08c0d2ce-9292-40a6-8add-81547be275d9    0   VersionRefreshAggregate

发现正在正常添加事件payload_type = VersionRefreshJobCreatedEvent 还有其他事件处理程序（读取模型的投影）正在侦听此事件并正常工作并被调用，这意味着事件正在正常发布

我查询了关联，看看 saga 是否正在创建事件，但由于某种原因没有响应该事件或其他事件

SELECT *
FROM association_value_entry
where association_key = 'jobId'
  AND saga_type = 'com.integration.core.versionrefresh.VersionRefreshSaga'
  AND association_value = '${aggId}';

发现没有为这些值创建关联

应用程序中的所有其他 sagas 也正常工作

我重新启动了应用程序的所有实例，但没有解决问题。

我在 postgres 数据库 中部署了一个新实例，传奇开始被创建并工作，问题似乎得到了解决（但是当重新连接到旧实例时它仍然无法正常工作）

旧实例的重启不可行，推出也是如此。

没有没有日志或应用程序中抛出异常（通过 axon 或 spring boot）进行调试

命令正在启动，聚合正在创建并引发相应的事件，但由于某种原因，未创建 saga，因此未启动事务

1- 我怎么知道为什么旧的 postgress 实例没有创建 sagas？ SagaEventProcessor 是否拒绝处理事件？

2- 怎么解决？

谢谢，

【问题讨论】：

我建议跟进 Yvonne 的回复。 TrackingEventProcessor 处理此 Saga 的事件的可能性确实很高，无论出于何种原因不处理新事件。要么令牌超前，要么令牌被隐藏在后台的另一个 Java 进程占用。

标签： java postgresql spring-boot axon

【解决方案1】：

我怀疑这种行为的原因是 Saga 处理器的令牌已经在事件流的头部，你能检查令牌存储表并找到对应的处理器吗？

SELECT * FROM token_entry WHERE processor_name = 'VersionRefreshSagaProcessor'

如果令牌存在并且位于事件存储的头部并且这是不需要的行为，您可以将令牌设置为尾部以处理事件存储中的所有事件。见https://docs.axoniq.io/reference-guide/axon-framework/events/event-processors#custom-tracking-token-position

【讨论】：