3. 请求执行
ExecutionGraphQlService
是调用 GraphQL Java 执行的主要 Spring 抽象
请求。底层传输(如 HTTP)委托给ExecutionGraphQlService
处理请求。
主要实现DefaultExecutionGraphQlService
配置了GraphQlSource
要访问graphql.GraphQL
实例。
3.1.GraphQLSource
GraphQlSource
是一个合约,用于公开graphql.GraphQL
instance 来使用该
包含用于构建该实例的构建器 API。默认构建器可通过GraphQlSource.schemaResourceBuilder()
.
Boot Starter 会创建此构建器的实例并进一步初始化它
要从可配置位置加载 Schema 文件,
公开要应用到的属性GraphQlSource.Builder
,以检测RuntimeWiringConfigurer
beans、用于 GraphQL 指标的插桩 bean、
和DataFetcherExceptionResolver
和SubscriptionExceptionResolver
bean 来解决异常。对于进一步的自定义,您还可以
声明一个GraphQlSourceBuilderCustomizer
bean,例如:
@Configuration(proxyBeanMethods = false)
class GraphQlConfig {
@Bean
public GraphQlSourceBuilderCustomizer sourceBuilderCustomizer() {
return (builder) ->
builder.configureGraphQl(graphQlBuilder ->
graphQlBuilder.executionIdProvider(new CustomExecutionIdProvider()));
}
}
3.1.1. Schema 资源
GraphQlSource.Builder
可以配置一个或多个Resource
实例为
解析并合并在一起。这意味着 schema 文件几乎可以从任何
位置。
默认情况下,Boot Starters会查找带有扩展名的 schema 文件
位置下的 “.graphqls” 或 “.gqls”classpath:graphql/**
,这通常是src/main/resources/graphql
.您还可以使用文件系统位置或任何位置
由 Spring 提供支持Resource
层次结构,包括自定义实现
从远程位置、存储或内存加载架构文件。
用classpath*:graphql/**/ 在多个 Classpath 中查找 schema 文件
位置,例如跨多个模块。 |
3.1.2. Schema 创建
默认情况下,GraphQlSource.Builder
使用 GraphQL JavaSchemaGenerator
要创建graphql.schema.GraphQLSchema
.这适用于典型用途,但如果您需要使用
不同的生成器,例如对于联合,您可以注册一个schemaFactory
回调:
GraphQlSource.Builder builder = ...
builder.schemaResources(..)
.configureRuntimeWiring(..)
.schemaFactory((typeDefinitionRegistry, runtimeWiring) -> {
// create GraphQLSchema
})
GraphQlSource 部分解释了如何使用 Spring Boot 进行配置。
有关 Apollo Federation 的示例,请参见 federation-jvm-spring-example。
3.1.3. 模式遍历
您可以注册一个graphql.schema.GraphQLTypeVisitor
通过builder.schemaResources(..).typeVisitors(..)
如果要在
它已创建,并且可能会将更改应用于GraphQLCodeRegistry
.请记住,
但是,此类访客无法更改架构。如果需要更改架构,请参阅 架构转换。
3.1.4. Schema 转换
您可以注册一个graphql.schema.GraphQLTypeVisitor
通过builder.schemaResources(..).typeVisitorsToTransformSchema(..)
如果要遍历
并在创建架构后对其进行转换,然后对架构进行更改。注意事项
这通常比 Schema Traversal 更昂贵
首选遍历而不是转换,除非您需要进行架构更改。
3.1.5.RuntimeWiringConfigurer
您可以使用RuntimeWiringConfigurer
要注册:
-
自定义标量类型。
-
处理代码的指令。
-
TypeResolver
,如果您需要覆盖违约TypeResolver
对于类型。 -
DataFetcher
对于字段,尽管大多数应用程序将简单地配置AnnotatedControllerConfigurer
,它检测带注释的DataFetcher
handler 方法。 Boot Starter 会添加AnnotatedControllerConfigurer
默认情况下。
GraphQL Java 服务器应用程序仅将 Jackson 用于与数据映射之间的序列化。 客户端输入被解析为 Map。服务器输出将根据字段选择集组装到地图中。 这意味着您不能依赖 Jackson 序列化/反序列化 Comments。 相反,您可以使用自定义标量类型。 |
Boot Starter 检测 bean 类型的RuntimeWiringConfigurer
和
将它们注册到GraphQlSource.Builder
.这意味着在大多数情况下,您将拥有
类似于 this 的配置:
@Configuration
public class GraphQlConfig {
@Bean
public RuntimeWiringConfigurer runtimeWiringConfigurer(BookRepository repository) {
GraphQLScalarType scalarType = ... ;
SchemaDirectiveWiring directiveWiring = ... ;
DataFetcher dataFetcher = QuerydslDataFetcher.builder(repository).single();
return wiringBuilder -> wiringBuilder
.scalar(scalarType)
.directiveWiring(directiveWiring)
.type("Query", builder -> builder.dataFetcher("book", dataFetcher));
}
}
如果您需要添加WiringFactory
,例如,进行注册时要考虑到
schema definitions 中,实现替代configure
方法,该方法同时接受RuntimeWiring.Builder
和一个输出List<WiringFactory>
.这允许您添加任何
然后按顺序调用的工厂数。
3.1.6. 默认TypeResolver
GraphQlSource.Builder
寄存 器ClassNameTypeResolver
作为默认值TypeResolver
用于尚未进行此类注册的 GraphQL 接口和联合
通过RuntimeWiringConfigurer
.目的
一个TypeResolver
在 GraphQL 中,Java 用于确定值的 GraphQL 对象类型
从DataFetcher
对于 GraphQL Interface (图形QL 接口) 或 Union (联合) 字段。
ClassNameTypeResolver
尝试将值的简单类名与 GraphQL 匹配
Object 类型,如果不成功,它还会导航其超类型,包括
基类和接口,寻找匹配项。ClassNameTypeResolver
提供了一个
选项配置名称提取函数以及Class
更改为 GraphQL 对象类型
名称映射应该有助于涵盖更多极端情况:
GraphQlSource.Builder builder = ...
ClassNameTypeResolver classNameTypeResolver = new ClassNameTypeResolver();
classNameTypeResolver.setClassNameExtractor((klass) -> {
// Implement Custom ClassName Extractor here
});
builder.defaultTypeResolver(classNameTypeResolver);
GraphQlSource 部分解释了如何使用 Spring Boot 进行配置。
3.1.7.作缓存
GraphQL Java 必须在执行作之前对其进行解析和验证。这可能会影响
性能显着。为避免需要重新分析和验证,应用程序可以
配置PreparsedDocumentProvider
缓存和重用 Document 实例。GraphQL Java 文档提供了有关以下内容的更多详细信息
查询缓存PreparsedDocumentProvider
.
在 Spring GraphQL 中,你可以注册一个PreparsedDocumentProvider
通过GraphQlSource.Builder#configureGraphQl
:
.
// Typically, accessed through Spring Boot's GraphQlSourceBuilderCustomizer
GraphQlSource.Builder builder = ...
// Create provider
PreparsedDocumentProvider provider = ...
builder.schemaResources(..)
.configureRuntimeWiring(..)
.configureGraphQl(graphQLBuilder -> graphQLBuilder.preparsedDocumentProvider(provider))
GraphQlSource 部分解释了如何使用 Spring Boot 进行配置。
3.1.8. 指令
GraphQL 语言支持“描述替代运行时执行和 GraphQL 文档中的类型验证行为”。指令类似于 Java,但在 GraphQL 文档中的类型、字段、片段和作上声明。
GraphQL Java 提供了SchemaDirectiveWiring
Contract 帮助应用程序检测
和 handle 指令。有关更多详细信息,请参阅
GraphQL Java 文档。
在 Spring GraphQL 中,你可以注册一个SchemaDirectiveWiring
通过RuntimeWiringConfigurer
.Boot Starter 检测到
这样的 bean,所以你可能会有这样的东西:
@Configuration
public class GraphQlConfig {
@Bean
public RuntimeWiringConfigurer runtimeWiringConfigurer() {
return builder -> builder.directiveWiring(new MySchemaDirectiveWiring());
}
}
有关指令支持的示例,请查看 Graphql Java 库的扩展验证。 |
3.2. 反应式DataFetcher
默认的GraphQlSource
builder 启用对DataFetcher
返回Mono
或Flux
,这会将它们调整为CompletableFuture
哪里Flux
值被聚合
并转换为 List,除非请求是 GraphQL 订阅请求,
在这种情况下,返回值仍然是 Reactive StreamsPublisher
用于流媒体
GraphQL 响应。
反应式DataFetcher
可以依赖对从
传输层,例如从 WebFlux 请求处理,请参阅 WebFlux 上下文。
3.3. 上下文传播
Spring for GraphQL 支持通过 GraphQL Java 透明地从 HTTP 传播上下文,并传递到DataFetcher
和其他组件
调用。这包括ThreadLocal
来自 Spring MVC 请求处理的上下文
thread 和 ReactorContext
从 WebFlux 处理管道。
3.3.1. WebMvc
一个DataFetcher
和 GraphQL Java 调用的其他组件可能并不总是在
与 Spring MVC 处理程序相同的线程,例如,如果WebGraphQlInterceptor
或DataFetcher
切换到
不同的线程。
Spring for GraphQL 支持传播ThreadLocal
来自 Servlet 容器的值
thread 设置为线程 aDataFetcher
和其他组件,以
执行时间。为此,应用程序需要实现io.micrometer.context.ThreadLocalAccessor
对于ThreadLocal
感兴趣的值:
public class RequestAttributesAccessor implements ThreadLocalAccessor<RequestAttributes> {
@Override
public Object key() {
return RequestAttributesAccessor.class.getName();
}
@Override
public RequestAttributes getValue() {
return RequestContextHolder.getRequestAttributes();
}
@Override
public void setValue(RequestAttributes attributes) {
RequestContextHolder.setRequestAttributes(attributes);
}
@Override
public void reset() {
RequestContextHolder.resetRequestAttributes();
}
}
您可以注册一个ThreadLocalAccessor
在启动时使用全局ContextRegistry
实例,可通过io.micrometer.context.ContextRegistry#getInstance()
.您也可以注册它
自动通过java.util.ServiceLoader
机制。
3.3.2. WebFlux 浏览器
一个反应性的DataFetcher
可以依赖对 Reactor 上下文的访问,该
源自 WebFlux 请求处理链。这包括 Reactor 上下文
由 WebGraphQlInterceptor 组件添加。
3.4. 异常解决
GraphQL Java 应用程序可以注册DataFetcherExceptionHandler
来决定如何
表示 GraphQL 响应的 “errors” 部分中数据层的异常。
Spring for GraphQL 具有内置的DataFetcherExceptionHandler
配置以供使用
默认情况下GraphQLSource
架构工人。它允许应用程序注册
一个或多个 SpringDataFetcherExceptionResolver
按顺序调用的组件
直到解决Exception
添加到(可能为空的)列表graphql.GraphQLError
对象。
DataFetcherExceptionResolver
是一个异步合约。对于大多数实现,它
就足以扩展DataFetcherExceptionResolverAdapter
并覆盖
它的resolveToSingleError
或resolveToMultipleErrors
方法
同步解决异常。
一个GraphQLError
可以通过以下方式分配给类别graphql.ErrorClassification
.
在 Spring GraphQL 中,您还可以通过ErrorType
它有以下常见
应用程序可用于对错误进行分类的分类:
-
BAD_REQUEST
-
UNAUTHORIZED
-
FORBIDDEN
-
NOT_FOUND
-
INTERNAL_ERROR
如果异常仍未解决,则默认情况下,它被归类为INTERNAL_ERROR
替换为包含类别名称和executionId
从DataFetchingEnvironment
.该消息故意不透明以避免泄漏
实现细节。应用程序可以使用DataFetcherExceptionResolver
自定义
错误详细信息。
未解决的异常将记录在 ERROR 级别,并且executionId
关联
发送到客户端的错误。已解决的异常记录在 DEBUG 级别。
3.4.1. 请求异常
GraphQL Java 引擎在解析请求时可能会遇到验证或其他错误
这反过来又会阻止请求执行。在这种情况下,响应包含
“data” 键替换为null
以及一个或多个请求级 “错误” 是全局的,即 not
具有字段路径。
DataFetcherExceptionResolver
无法处理此类全局错误,因为它们是引发的
在执行开始之前和任何DataFetcher
被调用。应用程序可以使用
传输级拦截器来检查和转换ExecutionResult
.
请参阅下面的示例WebGraphQlInterceptor
.
3.5. 批量加载
给定一个Book
及其Author
,我们可以创建一个DataFetcher
一本书和另一本书
对于它的作者。这允许选择有作者或无作者的书籍,但这意味着书籍
和 authors 不会一起加载,这在查询多个
books 作为每本书的作者是单独加载的。这称为 N+1 选择
问题。
3.5.1.DataLoader
GraphQL Java 提供了一个DataLoader
用于批量加载相关实体的机制。
您可以在 GraphQL Java 文档中找到完整的详细信息。下面是一个
工作原理摘要:
-
注册
DataLoader
在DataLoaderRegistry
,它可以加载给定唯一键的实体。 -
DataFetcher
的 can accessDataLoader
的 ID 值,并使用它们按 ID 加载实体。 -
一个
DataLoader
通过返回 future 来延迟加载,以便可以批量完成。 -
DataLoader
维护加载实体的每个请求缓存,该缓存可以进一步 提高效率。
3.5.2.BatchLoaderRegistry
GraphQL Java 中的完整批处理加载机制需要实现以下之一
几个BatchLoader
接口,然后将它们包装并注册为DataLoader
s
,名称位于DataLoaderRegistry
.
Spring GraphQL 中的 API 略有不同。对于注册,只有一个
中央BatchLoaderRegistry
公开工厂方法和构建器以创建和
注册任意数量的批量加载函数:
@Configuration
public class MyConfig {
public MyConfig(BatchLoaderRegistry registry) {
registry.forTypePair(Long.class, Author.class).registerMappedBatchLoader((authorIds, env) -> {
// return Mono<Map<Long, Author>
});
// more registrations ...
}
}
Boot Starter 声明了一个BatchLoaderRegistry
你可以注入的 bean
您的配置,如上所示,或按顺序放入任何组件(如控制器)
注册批量加载函数。反过来,BatchLoaderRegistry
被注入DefaultExecutionGraphQlService
确保DataLoader
每个请求的注册数。
默认情况下,DataLoader
name 基于目标实体的类名。
这允许@SchemaMapping
方法声明具有泛型类型的 DataLoader 参数,以及
无需指定名称。但是,可以通过BatchLoaderRegistry
builder(如有必要)以及其他DataLoaderOptions
.
配置默认DataLoaderOptions
全局,以用作任何
registration,您可以覆盖 Boot 的BatchLoaderRegistry
bean 并使用构造函数
为DefaultBatchLoaderRegistry
接受Supplier<DataLoaderOptions>
.
在许多情况下,在加载相关实体时,您可以使用 @BatchMapping 控制器方法,这是一种快捷方式
for 并替换需要使用BatchLoaderRegistry
和DataLoader
径直。
BatchLoaderRegistry
还提供其他重要的好处。它支持访问
一样GraphQLContext
from batch loading functions 和 from@BatchMapping
方法
以及确保对它们的上下文传播。这就是预期应用的原因
以使用它。可以执行你自己的DataLoader
registrations 直接注册,但
此类注册将放弃上述好处。
3.5.3. 测试批量加载
首先BatchLoaderRegistry
在DataLoaderRegistry
:
BatchLoaderRegistry batchLoaderRegistry = new DefaultBatchLoaderRegistry();
// perform registrations...
DataLoaderRegistry dataLoaderRegistry = DataLoaderRegistry.newRegistry().build();
batchLoaderRegistry.registerDataLoaders(dataLoaderRegistry, graphQLContext);
现在您可以访问和测试个人DataLoader
如下所示:
DataLoader<Long, Book> loader = dataLoaderRegistry.getDataLoader(Book.class.getName());
loader.load(1L);
loader.loadMany(Arrays.asList(2L, 3L));
List<Book> books = loader.dispatchAndJoin(); // actual loading
assertThat(books).hasSize(3);
assertThat(books.get(0).getName()).isEqualTo("...");
// ...