• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:axon

axon

跨服务共享轴突查询

跨服务共享轴突查询
我正在运行三个不同的服务(A,B和C),所有服务都已连接到axonserver 4.3.3。除了它们之外,我还包含一个包含所有事件的api服务,以便可以在所有服务之间共享它。当事件被触发时(由服务A说),其他服务(B和C)正在监听该事件,并且它们会做出相应的反应。现在我也想共享查询,以便当一个服务(比如说A)想要属于另一个服务(比如说B)的某些信息时,它可以……继续阅读 »

axon

Axon如何在Saga中捕获异常

Axon如何在Saga中捕获异常
假设我要创建一个简单的请求批准系统,如果用户向其他用户请求某项内容,则应该创建该请求,这样我就有两个聚合用户,即Request 。创建请求后,它将触发 RequestSaga 发送 RequestUserCmd //Aggregate class @Aggregate class RequestAggregate { @AggregateIdentif……继续阅读 »

amqp

使用Axon 4从AMQP接收事件

使用Axon 4从AMQP接收事件
我试图通过Rabbitmq向基于axon4 spring boot的系统发送消息。收到消息,但未触发任何事件。我非常确定我缺少必不可少的部分,但是到目前为止我还无法弄清楚。 这是我的application.yml的相关部分 axon: amqp: exchange: axon.fanout transaction-mo……继续阅读 »

atomikos

带有Atomikos的Axon框架?如何运作?

带有Atomikos的Axon框架?如何运作?
我有一个问题,我必须在Spring-Boot中使用Atomikos和Axon框架(没有Axon Server)。我正在使用Oracle DB,并且正在使用多个线程(10)发送许多命令,在此之前,我为自己配置了JtaTransactionManager,但是在某些线程中,我遇到了这种异常:javax.transaction.xa。 XAException,从-……继续阅读 »

apache-kafka

Axon Config-@eventhandlers引发异常后,Kafka重试策略

Axon Config-@eventhandlers引发异常后,Kafka重试策略
我已经开始在项目中使用Axon 4.3.1(最新版本),并且遇到了问题。 @eventhandler引发异常后,在哪里可以配置kafka重试策略? OBS:我正在使用SubscribingEventProcessor类型作为事件处理器(两个项目)。我正在使用单独的项目!命令模型使用mongo并在Kafka上发布事件。查询模型使用来自Kafka(eventbu……继续阅读 »

axon

使用Axon跨不同的JVM的多个sagas(相同类型)

使用Axon跨不同的JVM的多个sagas(相同类型)
如何使用同一应用程序运行的多个JVM实际管理Sagas 此应用程序的每个JVM应该使用相同的数据库吗?否则,跟踪 token 将不会在同一应用程序中“共享”吗? 如何在运行Sagas的同一应用程序之间分配事件?一个saga类型或saga实例是否总是在同一个应用程序上处理(直到它关闭,所以另一个实例负责)? 还是每个JVM都接收事件,并且相同类型的每个传奇都会……继续阅读 »