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

前言

在开始本文之前，对graphql不熟悉的朋友们，可以看下下面这篇文章：

前文：asp.net core中使用graphql - 第一章 hello world

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

中间件

如果你熟悉asp.net core的中间件，你可能会注意到之前的博客中我们已经使用了一个中间件，

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请求发送到服务器的，你可以很容易的使用如下代码获取到请求体中的内容。

string body; 
using (var streamreader = new streamreader(httpcontext.request.body)) 
{
 body = await streamreader.readtoendasync();
}

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

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

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

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属性的复杂类型。

这个复杂类型代码如下：

public class graphqlrequest
{
 public string query { get; set; }
}

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

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方法应该是这个样子的。

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请求, 请求结果如下：

结果正确返回了。

本篇源代码： https://github.com/lamondlu/graphql_blogs/tree/master/part%20ii

总结

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