ASP.NET Core中使用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