服务器之家

服务器之家 > 正文

ASP.NET Core使用GraphQL第二章之中间件

时间:2020-06-04 14:28     来源/作者:LamondLu

前言

在开始本文之前,对GraphQL不熟悉的朋友们,可以看下下面这篇文章:

前文:ASP.NET Core中使用GraphQL - 第一章 Hello World

看完上面的文章,下面话不多说了,来一起看看详细的介绍吧

中间件

如果你熟悉ASP.NET Core的中间件,你可能会注意到之前的博客中我们已经使用了一个中间件,

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
app.Run(async (context) =>
{
 var result = await new DocumentExecuter()
 .ExecuteAsync(doc =>
 {
 doc.Schema = schema;
 doc.Query = @"
 query {
  hello
 }
 ";
 }).ConfigureAwait(false);
 
 var json = new DocumentWriter(indent: true)
 .Write(result)
 await context.Response.WriteAsync(json);
});

这个中间件负责输出了当前查询的结果。

    中间件的定义:

    中间件是装载在应用程序管道中的组件,负责处理请求和响应,每一个中间件

        可以选择是否传递请求到应用程序管道中的下一个组件
        可以在应用程序管道中下一个组件运行前和运行后进行一些操作

    来源: Microsoft Documentation

实际上中间件是一个委托,或者更精确的说是一个请求委托(Request Delegate)。 正如他的名字一样,中间件会处理请求,并决定是否将他委托到应用程序管道中的下一个中间件中。在我们前面的例子中,我们使用IApplicationBuilder类的Run()方法配置了一个请求委托。

使用动态查询体替换硬编码查询体

在我们之前的例子中,中间件中的代码非常简单,它仅是返回了一个固定查询的结果。然而在现实场景中,查询应该是动态的,因此我们必须从请求中读取查询体。

在服务器端,每一个请求委托都可以接受一个HttpContext参数。如果一个查询体是通过POST请求发送到服务器的,你可以很容易的使用如下代码获取到请求体中的内容。

?
1
2
3
4
5
string body;
using (var streamReader = new StreamReader(httpContext.Request.Body))
{
 body = await streamReader.ReadToEndAsync();
}

在获取请求体内容之前,为了不引起任何问题,我们需要先检测一些当前请求

  •     是否是一个POST请求
  •     是否使用了特定的Url, 例如 /api/graphql

因此我们需要对代码进行调整。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
if(context.Request.Path.StartsWithSegments("/api/graphql")
 && string.Equals(context.Request.Method,
   "POST",
   StringComparison.OrdinalIgnoreCase))
{
 string body;
 using (var streamReader = new StreamReader(context.Request.Body))
 {
 body = await streamReader.ReadToEndAsync();
 }
 
....
....
....

一个请求体可以包含很多字段,这里我们约定传入graphql查询体字段名称是query。因此我们可以将请求体中的JSON字符串转换成一个包含Query属性的复杂类型。

这个复杂类型代码如下:

?
1
2
3
4
public class GraphQLRequest
{
 public string Query { get; set; }
}

下一步我们要做的就是,反序列化当前请求体的内容为一个GraphQLRequest类型的实例。这里我们需要使用Json.Net中的静态方法JsonConvert.DeserializeObjct来替换之前的硬编码的查询体。

?
1
2
3
4
5
6
7
var request = JsonConvert.DeserializeObject<GraphQLRequest>(body);
 
var result = await new DocumentExecuter().ExecuteAsync(doc =>
{
 doc.Schema = schema;
 doc.Query = request.Query;
}).ConfigureAwait(false);

在完成以上修改之后,Startup.cs文件的Run方法应该是这个样子的。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
app.Run(async (context) =>
{
 if (context.Request.Path.StartsWithSegments("/api/graphql")
 && string.Equals(context.Request.Method,
    "POST",
    StringComparison.OrdinalIgnoreCase))
 {
 string body;
 using (var streamReader = new StreamReader(context.Request.Body))
 {
  body = await streamReader.ReadToEndAsync();
 
  var request = JsonConvert.DeserializeObject<GraphQLRequest>(body);
  var schema = new Schema { Query = new HelloWorldQuery() };
 
  var result = await new DocumentExecuter()
  .ExecuteAsync(doc =>
  {
  doc.Schema = schema;
  doc.Query = request.Query;
  }).ConfigureAwait(false);
 
  var json = new DocumentWriter(indent: true)
  .Write(result);
  await context.Response.WriteAsync(json);
 }
 }
});

最终效果

现在我们可以使用POSTMAN来创建一个POST请求, 请求结果如下:

ASP.NET Core使用GraphQL第二章之中间件

结果正确返回了。

本篇源代码: https://github.com/lamondlu/GraphQL_Blogs/tree/master/Part%20II

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对服务器之家的支持。

原文链接:https://www.cnblogs.com/lwqlun/p/9910953.html

相关文章

热门资讯

歪歪漫画vip账号共享2020_yy漫画免费账号密码共享
歪歪漫画vip账号共享2020_yy漫画免费账号密码共享 2020-04-07
沙雕群名称大全2019精选 今年最火的微信群名沙雕有创意
沙雕群名称大全2019精选 今年最火的微信群名沙雕有创意 2019-07-07
玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分
玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分 2019-06-21
男生常说24816是什么意思?女生说13579是什么意思?
男生常说24816是什么意思?女生说13579是什么意思? 2019-09-17
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
返回顶部