axon-查询处理
Query Handling
查询处理组件主要是对传入的查询消息作处理。查询处理组件作用于传入的查询消息。他们通常从Event listeners创建的视图模型中读取数据。查询处理组件通常不会引发新事件或发送Command。
Defining Query Handlers
在Axon框架中，一个对象可以通过@QueryHandler注解定义多个Query Handler方法。
默认情况下，@QueryHandler注解的方法支持以下参数：
- 第一个参数总是查询消息（Query Message）的payload。如果@QueryHandler注解显示的指定了Query handler能处理的查询的名称，那么他可以是Message或QueryMessage类型。默认情况下，Query名称是查询payload的全类名。
- 用@MetaDataValue注解的参数，将用注解上的键对元数据值进行解析。如果这个值是false（默认），则当元数据值不存在时会传递null。如果值是true，而元数据值不存时，这时解析器会发现错误，并阻止该方法的调用。
- 参数为MetaData的话，那么将注入一个EventMessage的整个MetaData
4.如果参数是UnitOfWork的话，那么将获取当前的UnitOfWork并注入进来。它允许查询处理程序注册要在工作单元的某个阶段执行的操作，或者获取对其注册的资源的访问权限。
5.如果参数是Message或者 QueryMessage 的话，他们会获取整个的数据，它们包括Meta Data元数据和payload.如果一个方法需要多个元数据字段，或者包装消息的其他属性，这很有用处。
您可以通过实现ParameterResolverFactory接口并创建一个名为/META-INF/service/org.axonframework.common.annotation.ParameterResolverFactory的文件来配置其他ParameterResolver，该文件包含实现类的全名。详情请 参考Advanced Customizations 。
在所有情况下，每个query handler实例最多调用一个事件处理程序方法。 Axon将使用以下规则搜索最匹配的调用方法：
- 在类层次结构（注：类的继承关系）的实际实例层次（由this.getClass（）返回）中，将评估所有注解的方法
2.如果找到一个或多个方法可以将所有参数解析为一个值，则选择并调用最匹配（注：像java的多继承接口同时继承一个类的同一个方法调用冲突,也就是子接口或者实现优先）的类型的方法
3.如果在这个级别的类层次结构中没有找到方法，那么超类的评估方法是相同的
4.当达到类层次结构的顶层时，还没有找到合适的query handler，该事件就被忽略掉。
// assume QueryB extends QueryA // and QueryC extends QueryB// and a single instance of SubHandler is registered
public class TopHandler {
@QueryHandler
public MyResult handle(QueryA query) {
}
@QueryHandler
public MyResult handle(QueryB query) {
}
@QueryHandler
public MyResult handle(QueryC query) {
}
}
public class SubHandler extends TopHandler {
@QueryHandler
public MyResult handleEx(QueryB query) {
}
}
在上面的例子中，将调用SubHandler的处理方法来查询QueryB和结果MyResult;调用TopHandler的处理程序方法来查询QueryA和QueryC，并得到MyResult。
注册查询处理
可以为相同的查询名称和响应类型注册多个查询处理程序。当分发查询时，客户端可以指示他是想要来一个还是来自所有的查询处理程序的结果。
配合spring使用
当使用Spring AutoConfiguration时，所有的singleton Spring bean都会被扫描以获得具有@QueryHandler注解的方法。对于找到的每个方法，都会在查询总线上注册一个新的查询处理程序。
使用API配置
也可以使用API配置来注册查询处理程序。为此，请使用Configurer类上的registerQueryHandler方法：
// Sample query handlerpublic class MyQueryHandler {
@QueryHandler
public String echo(String echo) {
return echo;
}
}
...
// To register your query handler
Configurer axonConfigurer = DefaultConfigurer.defaultConfiguration()
.registerQueryHandler(conf -> new MyQueryHandler);
