前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >用.Net Core控制台模拟一个ASP.Net Core的管道模型

用.Net Core控制台模拟一个ASP.Net Core的管道模型

作者头像
码农阿宇
发布2018-04-18 15:13:09
5770
发布2018-04-18 15:13:09
举报
文章被收录于专栏:码农阿宇

在我的上几篇文章中降到了asp.net core的管道模型,为了更清楚地理解asp.net core的管道,再网上学习了.Net Core控制台应用程序对其的模拟,以加深映像,同时,供大家学习参考。

首先,新建一控制台应用程序。注意是.Net Core的控制台应用程序。

然后新建一个Context类,以模拟ASP.net core中的context类,然后再Context类中添加一个Write方法。

代码语言:javascript
复制
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks.Dataflow;

namespace MyPipleLine
{
   public  class Context
    {
        public  void Write(string msg)
        {
            Console.WriteLine(msg);
        }
    }
}

然后新建一个RequestDelegate类,类中声明一个Requestdelegate的委托。

代码语言:javascript
复制
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;

namespace MyPipleLine
{
    public delegate Task RequestDelegate(Context context);
  
}

该RequestDelegate接收一个Context类型的值,返回的是Task类型。

然后,回到Pragrame.cs类中,

添加一个List,该List中保存了各个(中间件)。

代码语言:javascript
复制
  public static List<Func<RequestDelegate, RequestDelegate>> _list = new List<Func<RequestDelegate, RequestDelegate>>();

添加一个Use方法。

代码语言:javascript
复制
  public static void Use(Func<RequestDelegate, RequestDelegate> middleWare)
        {
            _list.Add(middleWare);
        }

再ASP.NET Core应用程序中,我们经常再Startup.cs中的Config中使用app.Use()方法,这里的Use()就是模仿该app.Use()的方法。我们知道,Use()的方法有一种是添加一个传入类型是RequestDelegate  传出也是RequestDelegate的委托。  该委托,就是我们常常被称为的中间件。

然后回到Main方法中。

代码语言:javascript
复制
  static void Main(string[] args)
        {
            Use(next =>                         //往Use中添加一个传入类型为RequestDelegate,传出类型也为RequestDelegate的lambda表达式,
            {
                return context =>
                {
                    context.Write("1");         //该委托中执行了context的中的方法。
                    return next.Invoke(context);  //并继续执行下一个
                };
            });
            Use(next =>
            {
                return context =>              //同上
                {
                    context.Write("2");
                    return next.Invoke(context);
                };
            });
            _list.Reverse();                        //把_list中的内容颠倒一下顺序,因为如果不颠倒下,后先执行最后加入的中间件,后执行最先加入中间件。
            RequestDelegate end = (context) =>      
            {
                context.Write("end");
                return Task.CompletedTask;
            };
            foreach (var middleware in _list)      
            {
                end = middleware.Invoke(end);     //把_list中的各个中间件“附加”到end委托上。
            }
            end.Invoke(new Context());           //调用end委托
            Console.ReadLine();
        }

我们查看一下运行结果:

这就是ASP.net core的管道模型的基本原理。

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2017-12-21 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
消息队列 TDMQ
消息队列 TDMQ (Tencent Distributed Message Queue)是腾讯基于 Apache Pulsar 自研的一个云原生消息中间件系列,其中包含兼容Pulsar、RabbitMQ、RocketMQ 等协议的消息队列子产品,得益于其底层计算与存储分离的架构,TDMQ 具备良好的弹性伸缩以及故障恢复能力。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档