java跨服务共享axon查询
我有三种不同的服务(A、B和C)正在运行,它们都连接到axonserver 4.3.3。除此之外,我还提供了一个包含所有事件的api服务,以便在所有服务之间共享。当一个事件被触发(比如服务A)时,它被其他服务(B&C)监听,它们会做出相应的反应
现在我还想共享查询,这样当一个服务(假设a)想要一些属于另一个服务(假设B)的信息时,它可以直接触发相应的查询,由服务B监听并返回信息
- axon中是否允许它(即,在服务之间共享查询,就像我们对事件所做的那样)李>
- 如果允许,它是否遵循axon最佳实践李>
- 如果不允许/不遵循最佳实践,什么是替代解决方案李>
UPDATE
我只是简单地将查询添加到公共api服务中,并从服务A启动它,如下所示:
- 当我使用
queryGateway.query( findCourierByIdQuery, responseType)
时:我得到了queryhandler not found exception - 当我使用
queryGateway.subscriptionQuery( findCourierByIdQuery, initialResponseType, updateResponseType)
时:我什么都没有 - 当我使用
queryGateway.scatterGather( findCourierByIdQuery, responseType, timeout, timeUnit)
:我得到一个空流
当我从服务B本身启动FindCourierBydQuery时,queryhandler被调用,我得到了正确的响应
我的观察是,只有当查询是从同一个组件(在本例中是服务B)触发时,查询处理程序才会被调用,如果我从其他组件(服务A)触发查询,则不会被调用
请注意,所有服务都在不同的主机和端口上独立运行,但都连接到同一台axonserver,查询句柄写在服务B中
所以基本上实现是这样的:
- FindCourierBydQuery是在公共api服务中定义的李>
- 服务A和B具有公共api服务的依赖性李>
- 服务A执行FindCourierBydQuery的查询李>
- 服务B具有FindCourierBydQuery查询处理程序实现李>
# 1 楼答案
在我看来这完全没问题
Axon使用三种类型的消息:命令、事件和查询。它们代表您服务的API。 下游服务(在您的案例B&C中)可以发送命令、订阅事件或发送(并订阅)上游服务的查询(在您的案例A中)。简单地说,B&;C依赖于A。如果可能的话,重要的是使这种依赖单向(唯一的B依赖于A,但不是相反)
通常,您希望在下游服务(B&C)的边缘有一个
anti-corruption layer component
。它可以将上游服务(A)的事件转换为自己的命令,也可以将自己的事件转换为上游服务(A)的命令。这是一个传奇或常规事件处理程序(处理器)如果您对查询感兴趣,那么
anti-corruption layer component
将使用查询网关从上游服务(a)发出(订阅)查询,并希望以自动化的方式将响应转换为命令,类似于我提到的Saga/事件处理程序。通常,这种对查询API的集成不是完全自动化的:从查询到命令的转换涉及用户。在这种情况下,服务B(下游)使用(服务A的)查询响应来呈现视图,用户可以从中发出下一个命令(服务B)在下游系统中安装反腐败层组件将使您的服务具有自治性
最好的, 伊万