经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 程序设计 » ASP.net » 查看文章
.Net MinimalApis响应返回值
来源:cnblogs  作者:董瑞鹏  时间:2024/3/22 9:23:28  对本文有异议

前言

文本主要讲 MinimalApis 中的使用自定义IResultModel和系统自带IResult做响应返回值。
MinimalApis支持以下类型的返回值:

  • string - 这包括 Task<string>ValueTask<string>

  • T(任何其他类型)- 这包括 Task<T>ValueTask<T>

  • 基于 IResult - 这包括 Task<IResult>ValueTask<IResult>

    本文的完整源代码在文末

string 返回值

行为 Content-Type
框架将字符串直接写入响应。 text/plain

200 状态代码与 text/plain Content-Type 标头和以下内容一起返回

  1. Hello World

T(任何其他类型)返回值

我们上面说的自定义 IResultModel就是用这种模式处理的

行为 Content-Type
框架 JSON 序列化响应。 application/json

MinimalApis 框架 Json 序列化全局配置如下

  1. //通过调用 ConfigureHttpJsonOptions 来全局配置应用的选项
  2. builder.Services.ConfigureHttpJsonOptions(options =>
  3. {
  4. options.SerializerOptions.ReferenceHandler = ReferenceHandler.IgnoreCycles;//忽略循环引用
  5. options.SerializerOptions.WriteIndented = true;
  6. options.SerializerOptions.IncludeFields = true;
  7. options.SerializerOptions.DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull;
  8. });

返回 T

  1. app.MapGet("/TestT", User () => new User() { Name = "Ruipeng", Email = "xxx@163.com", Age = 18 })
  2. .WithSummary("测试类")
  3. .Produces<User>();

返回值

  1. {
  2. "name": "Ruipeng",
  3. "email": "xxx@163.com",
  4. "age": 18
  5. }

200 状态代码与 application/json Content-Type 标头和以下内容一起返回

这个 HttpCode状态码只能返回 200,且不支持多种返回形式,比较局限


统一响应格式代码

  1. public interface IResultModel
  2. {
  3. /// <summary>
  4. /// 是否成功
  5. /// </summary>
  6. bool? IsSuccess { get; }
  7. /// <summary>
  8. /// 错误信息
  9. /// </summary>
  10. string? Message { get; }
  11. /// <summary>
  12. /// 业务码,用于业务中自定义
  13. /// </summary>
  14. int? StatusCode { get; set; }
  15. /// <summary>
  16. /// 时间戳
  17. /// </summary>
  18. long? Timestamp { get; }
  19. }
  20. /// <summary>
  21. /// 返回结果模型泛型接口
  22. /// </summary>
  23. /// <typeparam name="T"></typeparam>
  24. public interface IResultModel<out T> : IResultModel
  25. {
  26. /// <summary>
  27. /// 返回数据
  28. /// </summary>
  29. T? Data { get; }
  30. }

实现

  1. public class ResultModel<T> : IResultModel<T>
  2. {
  3. public ResultModel()
  4. {
  5. Timestamp = DateTimeOffset.Now.ToUnixTimeSeconds();
  6. }
  7. /// <summary>
  8. /// 处理是否成功
  9. /// </summary>
  10. public bool? IsSuccess { get; set; }
  11. /// <summary>
  12. /// 错误信息
  13. /// </summary>
  14. public string? Message { get; set; }
  15. /// <summary>
  16. /// 业务码
  17. /// </summary>
  18. public int? StatusCode { get; set; }
  19. /// <summary>
  20. /// 时间戳
  21. /// </summary>
  22. public long? Timestamp { get; }
  23. /// <summary>
  24. /// 返回数据
  25. /// </summary>
  26. public T? Data { get; set; }
  27. /// <summary>
  28. /// 成功
  29. /// </summary>
  30. /// <param name="Data"></param>
  31. public ResultModel<T> Success(T? data = default)
  32. {
  33. this.IsSuccess = true;
  34. StatusCode = 200;
  35. Data = data;
  36. return this;
  37. }
  38. /// <summary>
  39. /// 失败
  40. /// </summary>
  41. /// <param name="msg">说明</param>
  42. /// <param name="code"></param>
  43. public ResultModel<T> Failed(string? msg = "failed", int? code = 500)
  44. {
  45. IsSuccess = false;
  46. Message = msg;
  47. StatusCode = code;
  48. return this;
  49. }
  50. }
  51. /// <summary>
  52. /// 返回结果
  53. /// </summary>
  54. public static class ResultModel
  55. {
  56. /// <summary>
  57. /// 数据已存在
  58. /// </summary>
  59. /// <returns></returns>
  60. public static IResultModel<string> HasExists => Failed("data already exists");
  61. /// <summary>
  62. /// 数据不存在
  63. /// </summary>
  64. public static IResultModel<string> NotExists => Failed("data doesn't exist");
  65. /// <summary>
  66. /// 成功
  67. /// </summary>
  68. /// <param name="data">返回数据</param>
  69. /// <returns></returns>
  70. public static IResultModel<T> Success<T>(T? data = default)
  71. {
  72. return new ResultModel<T>().Success(data);
  73. }
  74. /// <summary>
  75. /// 成功
  76. /// </summary>
  77. /// <param name="task">任务</param>
  78. /// <returns></returns>
  79. public static async Task<IResultModel<T>> SuccessAsync<T>(Task<T>? task = default)
  80. {
  81. return task is not null && task != default ? new ResultModel<T>().Success(await task) : new ResultModel<T>();
  82. }
  83. /// <summary>
  84. /// 成功
  85. /// </summary>
  86. /// <returns></returns>
  87. public static IResultModel<string> Success()
  88. {
  89. return Success<string>();
  90. }
  91. /// <summary>
  92. /// 失败
  93. /// </summary>
  94. /// <param name="error">错误信息</param>
  95. /// <returns></returns>
  96. public static IResultModel<T> Failed<T>(string? error = null)
  97. {
  98. return new ResultModel<T>().Failed(error ?? "failed");
  99. }
  100. /// <summary>
  101. /// 失败
  102. /// </summary>
  103. /// <returns></returns>
  104. public static IResultModel<string> Failed(string? error = null)
  105. {
  106. return Failed<string>(error);
  107. }
  108. /// <summary>
  109. /// 根据布尔值返回结果
  110. /// </summary>
  111. /// <param name="success"></param>
  112. /// <returns></returns>
  113. public static IResultModel<T> Result<T>(bool success)
  114. {
  115. return success ? Success<T>() : Failed<T>();
  116. }
  117. /// <summary>
  118. /// 根据布尔值返回结果
  119. /// </summary>
  120. /// <param name="success"></param>
  121. /// <returns></returns>
  122. public static async Task<IResultModel> Result(Task<bool> success)
  123. {
  124. return await success ? Success() : Failed();
  125. }
  126. /// <summary>
  127. /// 根据布尔值返回结果
  128. /// </summary>
  129. /// <param name="success"></param>
  130. /// <returns></returns>
  131. public static IResultModel<string> Result(bool success)
  132. {
  133. return success ? Success() : Failed();
  134. }
  135. /// <summary>
  136. /// 时间戳起始日期
  137. /// </summary>
  138. public static readonly DateTime TimestampStart = new(1970, 1, 1, 0, 0, 0, 0);
  139. }

定义接口

  1. app.MapGet("/TestResultModel", IResultModel (int age) =>
  2. {
  3. List<User> users = [new User() { Name = "Ruipeng", Email = "xxx@163.com", Age = 18 }];
  4. return users.FirstOrDefault(_ => _.Age > age) is User user ? ResultModel.Success(user) : ResultModel.Failed();
  5. })
  6. .WithSummary("测试自定义IResultModel")
  7. .Produces<IResultModel<User>>();

封装了一个静态类来简化自定义类的创建,支持多个返回类型

返回值

  1. {
  2. "isSuccess": true,
  3. "statusCode": 200,
  4. "timestamp": 1711001093,
  5. "data": {
  6. "name": "Ruipeng",
  7. "email": "xxx@163.com",
  8. "age": 18
  9. }

自定义类的自动包装实现

创建一个Attribute

  1. [AttributeUsage(AttributeTargets.Method)]
  2. public class EnableResponseWrapperAttribute : Attribute { }

创建中间件自动包装

  1. public class ResponseWrapperMiddleware(RequestDelegate next)
  2. {
  3. public async Task InvokeAsync(HttpContext context)
  4. {
  5. if (context.GetEndpoint()?.Metadata.GetMetadata<EnableResponseWrapperAttribute>() is not null)
  6. {
  7. // 存储原始响应体流
  8. var originalResponseBodyStream = context.Response.Body;
  9. try
  10. {
  11. // 创建内存流以捕获响应
  12. using var memoryStream = new MemoryStream();
  13. context.Response.Body = memoryStream;
  14. // 调用管道中的下一个中间件
  15. await next(context);
  16. // 恢复原始响应体流并写入格式化结果
  17. context.Response.Body = originalResponseBodyStream;
  18. // 重置内存流位置并读取响应内容
  19. memoryStream.Seek(0, SeekOrigin.Begin);
  20. var readToEnd = await new StreamReader(memoryStream).ReadToEndAsync();
  21. var objResult = JsonSerializer.Deserialize<dynamic>(readToEnd);
  22. var result = new ResultModel<object>
  23. {
  24. Data = objResult,
  25. IsSuccess = true,
  26. StatusCode = context.Response.StatusCode
  27. };
  28. await context.Response.WriteAsJsonAsync(result as object);
  29. }
  30. finally
  31. {
  32. // 确保在出现异常时恢复原始响应体流
  33. context.Response.Body = originalResponseBodyStream;
  34. }
  35. }
  36. else
  37. {
  38. await next(context);
  39. }
  40. }
  41. }

应用中间件

  1. app.UseMiddleware<ResponseWrapperMiddleware>();

创建测试接口

  1. app.MapGet("/TestTestAutoWarpper", [EnableResponseWrapper] User () => new User() { Name = "Ruipeng", Email = "xxx@163.com", Age = 18 }).WithSummary("测试类")
  2. .Produces<User>();

返回值

  1. {
  2. "isSuccess": true,
  3. "statusCode": 200,
  4. "timestamp": 1711005201,
  5. "data": {
  6. "name": "Ruipeng",
  7. "email": "xxx@163.com",
  8. "age": 18
  9. }
  10. }

为了方便测试在MinimalApis 的接口上如果添加了EnableResponseWrapperAttribute则通过中间件自动包装返回值

IResult 返回值

行为 Content-Type
框架调用 IResult.ExecuteAsync 由 IResult 实现决定

dotNet7 之后多了一个TypedResults类来替代 Results
IResult 接口定义一个表示 HTTP 终结点结果的协定。 静态 Results 类和静态 TypedResults 用于创建表示不同类型的响应的各种 IResult 对象。

返回 TypedResults(而不是 Results)有以下优点:

  • TypedResults 帮助程序返回强类型对象,这可以提高代码可读性、改进单元测试并减少运行时错误的可能性。
  • 实现类型会自动为 OpenAPI 提供响应类型元数据来描述终结点。
    实现在Microsoft.AspNetCore.Http.HttpResults
  1. //Return IResult
  2. app.MapGet("/IResult/TestResult", IResult () => Results.Ok(new User() { Name = "Ruipeng", Email = "xxx@163.com", Age = 18 }));

没有调用扩展方法 Produces

  1. app.MapGet("/IResult/TestTypedResult", IResult () => TypedResults.Ok(new User() { Name = "Ruipeng", Email = "xxx@163.com", Age = 18 }));

可以看到 TypedResults 默认就会添加路由终结点的元数据描述

返回多个 IResult 实现类型

  1. app.MapGet("/IResult/ReturnMultipleTypes", Results<Ok<User>, NotFound> (int age) =>
  2. {
  3. List<User> users = [new User() { Name = "Ruipeng", Email = "xxx@163.com", Age = 18 }];
  4. return users.FirstOrDefault(_ => _.Age > age) is User user ? TypedResults.Ok(user) : TypedResults.NotFound();
  5. });

图简单可以直接用 IResult 返回类型 但是,由于 TypedResults 帮助程序自动包含终结点的元数据,因此可以改为返回 Results<Ok<User>, NotFound> 联合类型

IResult 自定义响应

添加 Html 扩展

  1. public static class ResultsExtensions
  2. {
  3. public static IResult Html(this IResultExtensions resultExtensions, string html)
  4. {
  5. ArgumentNullException.ThrowIfNull(resultExtensions);
  6. return new HtmlResult(html);
  7. }
  8. }
  9. class HtmlResult(string html) : IResult
  10. {
  11. private readonly string _html = html;
  12. public Task ExecuteAsync(HttpContext httpContext)
  13. {
  14. httpContext.Response.ContentType = MediaTypeNames.Text.Html;
  15. httpContext.Response.ContentLength = Encoding.UTF8.GetByteCount(_html);
  16. return httpContext.Response.WriteAsync(_html);
  17. }
  18. }
  1. app.MapGet("/IResult/Html", () => Results.Extensions.Html(@$"<!doctype html>
  2. <html>
  3. <head><title>miniHTML</title></head>
  4. <body>
  5. <h1>Hello World</h1>
  6. <p>The time on the server is {DateTime.Now:O}</p>
  7. </body>
  8. </html>"));

返回结果

  1. <!DOCTYPE html>
  2. <html>
  3. <head>
  4. <title>miniHTML</title>
  5. </head>
  6. <body>
  7. <h1>Hello World</h1>
  8. <p>The time on the server is 2024-03-21T17:31:36.2931959+08:00</p>
  9. </body>
  10. </html>

自定义 Json 格式

上面写了ConfigureHttpJsonOptions方法来配置全局请求的 Json 格式,下面则是针对单个路由终结点请求,方便一些个性化接口的处理

  1. var options = new JsonSerializerOptions(JsonSerializerDefaults.Web)
  2. { WriteIndented = true };
  3. app.MapGet("/IResult/CustomJsonConfig", () =>
  4. TypedResults.Json(new User() { Name = "Ruipeng", Email = "xxx@163.com", Age = 18 }, options));

返回 ProblemDetail

  1. app.MapGet("/IResult/ProblemDetail", () =>
  2. {
  3. var problemDetail = new ProblemDetails()
  4. {
  5. Status = StatusCodes.Status500InternalServerError,
  6. Title = "内部错误"
  7. };
  8. return TypedResults.Problem(problemDetail);
  9. });

返回值

  1. {
  2. "type": "https://tools.ietf.org/html/rfc9110#section-15.6.1",
  3. "title": "内部错误",
  4. "status": 500
  5. }

Microsoft.AspNetCore.Http.Results的扩展下,TypedResults 有非常多扩展的方法,比如处理文件,回调,流以及登录认证等,大家可以根据需求使用.

最后

用那种方式还是取决于项目的实际情况,如果你的系统是业务码httpStateCode要求分离的形式那建议用上面自定义统一响应的形式,要是没这方面的需求那dotNet自带的TypedResults使用起来就更合适。

官网文档 如何在最小 API 应用中创建响应

以下是本文的完整 源代码

希望本文对你有帮助!

原文链接:https://www.cnblogs.com/ruipeng/p/18088161

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号