Axon Saga 未创建

如何解决Axon Saga 未创建

我有一个使用 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());
        ...
}

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

我检查了 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正在正常添加还有其他事件处理程序（读取模型的投影）正在侦听此事件并正常工作并被调用，这意味着事件正在正常发布

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

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

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

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

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

我部署了一个新实例postgres 数据库，saga 开始创建和工作，问题似乎解决了（但是当重新连接到旧实例时它仍然不起作用）

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

应用程序中没有日志或异常被抛出（通过轴突或弹簧启动）进行调试

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

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

2- 如何解决？

谢谢，

解决方法

我怀疑这种行为的原因是Saga Processor的token已经在事件流的头部了，能不能查一下tokenstore表，找到对应的处理器？

SELECT * FROM token_entry WHERE processor_name = 'VersionRefreshSagaProcessor'

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

如何解决Axon Saga 未创建

解决方法

相关推荐