.Net MinimalApis响应返回值的详细过程_Asp.net

前言

本文主要讲 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 标头和以下内容一起返回

hello world

t（任何其他类型）返回值

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

行为	content-type
框架 json 序列化响应。	application/json

minimalapis 框架 json 序列化全局配置如下

    //通过调用 configurehttpjsonoptions 来全局配置应用的选项
    builder.services.configurehttpjsonoptions(options =>
    {
        options.serializeroptions.referencehandler = referencehandler.ignorecycles;//忽略循环引用
        options.serializeroptions.writeindented = true;
        options.serializeroptions.includefields = true;
        options.serializeroptions.defaultignorecondition = jsonignorecondition.whenwritingnull;
    });

返回 t

app.mapget("/testt", user () => new user() { name = "ruipeng", email = "xxx@163.com", age = 18 })
   .withsummary("测试类")
   .produces<user>();

返回值

{
  "name": "ruipeng",
  "email": "xxx@163.com",
  "age": 18
}

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

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

统一响应格式代码

public interface iresultmodel
{
    /// <summary>
    ///     是否成功
    /// </summary>
    bool? issuccess { get; }
    /// <summary>
    ///     错误信息
    /// </summary>
    string? message { get; }
    /// <summary>
    ///     业务码，用于业务中自定义
    /// </summary>
    int? statuscode { get; set; }
    /// <summary>
    ///     时间戳
    /// </summary>
    long? timestamp { get; }
}
/// <summary>
///     返回结果模型泛型接口
/// </summary>
/// <typeparam name="t"></typeparam>
public interface iresultmodel<out t> : iresultmodel
{
    /// <summary>
    ///     返回数据
    /// </summary>
    t? data { get; }
}

实现

public class resultmodel<t> : iresultmodel<t>
{
    public resultmodel()
    {
        timestamp = datetimeoffset.now.tounixtimeseconds();
    }
    /// <summary>
    ///     处理是否成功
    /// </summary>
    public bool? issuccess { get; set; }
    /// <summary>
    ///     错误信息
    /// </summary>
    public string? message { get; set; }
    /// <summary>
    ///     业务码
    /// </summary>
    public int? statuscode { get; set; }
    /// <summary>
    ///     时间戳
    /// </summary>
    public long? timestamp { get; }
    /// <summary>
    ///     返回数据
    /// </summary>
    public t? data { get; set; }
    /// <summary>
    ///     成功
    /// </summary>
    /// <param name="data"></param>
    public resultmodel<t> success(t? data = default)
    {
        this.issuccess = true;
        statuscode = 200;
        data = data;
        return this;
    }
    /// <summary>
    ///     失败
    /// </summary>
    /// <param name="msg">说明</param>
    /// <param name="code"></param>
    public resultmodel<t> failed(string? msg = "failed", int? code = 500)
    {
        issuccess = false;
        message = msg;
        statuscode = code;
        return this;
    }
}
/// <summary>
///     返回结果
/// </summary>
public static class resultmodel
{
    /// <summary>
    ///     数据已存在
    /// </summary>
    /// <returns></returns>
    public static iresultmodel<string> hasexists => failed("data already exists");
    /// <summary>
    ///     数据不存在
    /// </summary>
    public static iresultmodel<string> notexists => failed("data doesn't exist");
    /// <summary>
    ///     成功
    /// </summary>
    /// <param name="data">返回数据</param>
    /// <returns></returns>
    public static iresultmodel<t> success<t>(t? data = default)
    {
        return new resultmodel<t>().success(data);
    }
    /// <summary>
    ///     成功
    /// </summary>
    /// <param name="task">任务</param>
    /// <returns></returns>
    public static async task<iresultmodel<t>> successasync<t>(task<t>? task = default)
    {
        return task is not null && task != default ? new resultmodel<t>().success(await task) : new resultmodel<t>();
    }
    /// <summary>
    ///     成功
    /// </summary>
    /// <returns></returns>
    public static iresultmodel<string> success()
    {
        return success<string>();
    }
    /// <summary>
    ///     失败
    /// </summary>
    /// <param name="error">错误信息</param>
    /// <returns></returns>
    public static iresultmodel<t> failed<t>(string? error = null)
    {
        return new resultmodel<t>().failed(error ?? "failed");
    }
    /// <summary>
    ///     失败
    /// </summary>
    /// <returns></returns>
    public static iresultmodel<string> failed(string? error = null)
    {
        return failed<string>(error);
    }
    /// <summary>
    ///     根据布尔值返回结果
    /// </summary>
    /// <param name="success"></param>
    /// <returns></returns>
    public static iresultmodel<t> result<t>(bool success)
    {
        return success ? success<t>() : failed<t>();
    }
    /// <summary>
    ///     根据布尔值返回结果
    /// </summary>
    /// <param name="success"></param>
    /// <returns></returns>
    public static async task<iresultmodel> result(task<bool> success)
    {
        return await success ? success() : failed();
    }
    /// <summary>
    ///     根据布尔值返回结果
    /// </summary>
    /// <param name="success"></param>
    /// <returns></returns>
    public static iresultmodel<string> result(bool success)
    {
        return success ? success() : failed();
    }
    /// <summary>
    /// 时间戳起始日期
    /// </summary>
    public static readonly datetime timestampstart = new(1970, 1, 1, 0, 0, 0, 0);
}

定义接口

app.mapget("/testresultmodel", iresultmodel (int age) =>
{
    list<user> users = [new user() { name = "ruipeng", email = "xxx@163.com", age = 18 }];
    return users.firstordefault(_ => _.age > age) is user user ? resultmodel.success(user) : resultmodel.failed();
})
   .withsummary("测试自定义iresultmodel")
   .produces<iresultmodel<user>>();

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

返回值

{
  "issuccess": true,
  "statuscode": 200,
  "timestamp": 1711001093,
  "data": {
    "name": "ruipeng",
    "email": "xxx@163.com",
    "age": 18
  }

自定义类的自动包装实现

创建一个attribute

[attributeusage(attributetargets.method)]
public class enableresponsewrapperattribute : attribute { }

创建中间件自动包装

public class responsewrappermiddleware(requestdelegate next)
{
    public async task invokeasync(httpcontext context)
    {
        if (context.getendpoint()?.metadata.getmetadata<enableresponsewrapperattribute>() is not null)
        {
            // 存储原始响应体流
            var originalresponsebodystream = context.response.body;
            try
            {
                // 创建内存流以捕获响应
                using var memorystream = new memorystream();
                context.response.body = memorystream;
                // 调用管道中的下一个中间件
                await next(context);
                // 恢复原始响应体流并写入格式化结果
                context.response.body = originalresponsebodystream;
                // 重置内存流位置并读取响应内容
                memorystream.seek(0, seekorigin.begin);
                var readtoend = await new streamreader(memorystream).readtoendasync();
                var objresult = jsonserializer.deserialize<dynamic>(readtoend);
                var result = new resultmodel<object>
                {
                    data = objresult,
                    issuccess = true,
                    statuscode = context.response.statuscode
                };
                await context.response.writeasjsonasync(result as object);
            }
            finally
            {
                // 确保在出现异常时恢复原始响应体流
                context.response.body = originalresponsebodystream;
            }
        }
        else
        {
            await next(context);
        }
    }
}

应用中间件

app.usemiddleware<responsewrappermiddleware>();

创建测试接口

app.mapget("/testtestautowarpper", [enableresponsewrapper] user () => new user() { name = "ruipeng", email = "xxx@163.com", age = 18 }).withsummary("测试类")
   .produces<user>();

返回值

{
  "issuccess": true,
  "statuscode": 200,
  "timestamp": 1711005201,
  "data": {
    "name": "ruipeng",
    "email": "xxx@163.com",
    "age": 18
  }
}

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

iresult 返回值

行为	content-type
框架调用 iresult.executeasync	由 iresult 实现决定

在dotnet7 之后多了一个typedresults类来替代 results。
iresult 接口定义一个表示 http 终结点结果的协定。静态 results 类和静态 typedresults 用于创建表示不同类型的响应的各种 iresult 对象。

返回 typedresults（而不是 results）有以下优点：

typedresults 帮助程序返回强类型对象，这可以提高代码可读性、改进单元测试并减少运行时错误的可能性。
实现类型会自动为 openapi 提供响应类型元数据来描述终结点。
实现在microsoft.aspnetcore.http.httpresults

//return iresult
app.mapget("/iresult/testresult", iresult () => results.ok(new user() { name = "ruipeng", email = "xxx@163.com", age = 18 }));

没有调用扩展方法 produces

app.mapget("/iresult/testtypedresult", iresult () => typedresults.ok(new user() { name = "ruipeng", email = "xxx@163.com", age = 18 }));

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

返回多个 iresult 实现类型

app.mapget("/iresult/returnmultipletypes", results<ok<user>, notfound> (int age) =>
{
    list<user> users = [new user() { name = "ruipeng", email = "xxx@163.com", age = 18 }];
    return users.firstordefault(_ => _.age > age) is user user ? typedresults.ok(user) : typedresults.notfound();
});

图简单可以直接用 iresult 返回类型但是，由于 typedresults 帮助程序自动包含终结点的元数据，因此可以改为返回 results<ok<user>, notfound> 联合类型

iresult 自定义响应

添加 html 扩展

public static class resultsextensions
{
    public static iresult html(this iresultextensions resultextensions, string html)
    {
        argumentnullexception.throwifnull(resultextensions);
        return new htmlresult(html);
    }
}
class htmlresult(string html) : iresult
{
    private readonly string _html = html;
    public task executeasync(httpcontext httpcontext)
    {
        httpcontext.response.contenttype = mediatypenames.text.html;
        httpcontext.response.contentlength = encoding.utf8.getbytecount(_html);
        return httpcontext.response.writeasync(_html);
    }
}

app.mapget("/iresult/html", () => results.extensions.html(@$"<!doctype html>
<html>
    <head><title>minihtml</title></head>
    <body>
        <h1>hello world</h1>
        <p>the time on the server is {datetime.now:o}</p>
    </body>
</html>"));

返回结果

<!doctype html>
<html>
  <head>
    <title>minihtml</title>
  </head>
  <body>
    <h1>hello world</h1>
    <p>the time on the server is 2024-03-21t17:31:36.2931959+08:00</p>
  </body>
</html>

自定义 json 格式

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

var options = new jsonserializeroptions(jsonserializerdefaults.web)
{ writeindented = true };
app.mapget("/iresult/customjsonconfig", () =>
    typedresults.json(new user() { name = "ruipeng", email = "xxx@163.com", age = 18 }, options));

返回 problemdetail

app.mapget("/iresult/problemdetail", () =>
{
    var problemdetail = new problemdetails()
    {
        status = statuscodes.status500internalservererror,
        title = "内部错误"
    };
    return typedresults.problem(problemdetail);
});

返回值

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

在microsoft.aspnetcore.http.results的扩展下，typedresults 有非常多扩展的方法，比如处理文件，回调，流以及登录认证等，大家可以根据需求使用.

最后

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

到此这篇关于.net minimalapis响应返回值的文章就介绍到这了,更多相关.net minimalapis响应返回值内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！

.Net MinimalApis响应返回值的详细过程

2024年05月15日 • Asp.net •我要评论

前言