细说Django的中间件-低调大师

细说Django的中间件

2017-09-21 555

分析Django的生命周期,我们知道所有的http请求都要经过Django的中间件.

假如现在有一个需求,所有到达服务端的url请求都在系统中记录一条日志,该怎么做呢?

Django的中间件的简介

Django的中间件类似于linux中的管道符

Django的中间件实质就是一个类,类之中有Django已经定义好了一些方法.

每个http请求都会执行中间件中的一个或多个方法

进入Django中的请求都会执行process_request方法;
Django返回的信息都会执行process_response方法.;

Django内部的中间件注册在settings.py文件

MIDDLEWARE = [
    'django.middleware.security.SecurityMiddleware',
    'django.contrib.sessions.middleware.SessionMiddleware',
    'django.middleware.common.CommonMiddleware',
    'django.middleware.csrf.CsrfViewMiddleware',
    'django.contrib.auth.middleware.AuthenticationMiddleware',
    'django.contrib.messages.middleware.MessageMiddleware',
    'django.middleware.clickjacking.XFrameOptionsMiddleware',
]

导入from django.middleware.csrf import CsrfViewMiddleware模块,查看其源码

class CsrfViewMiddleware(MiddlewareMixin)

可以看到CsrfViewMiddleware是继承MiddlewareMixin这个中间件的

再查看MiddlewareMixin的源码

    class MiddlewareMixin(object):
        def __init__(self, get_response=None):
            self.get_response = get_response
            super(MiddlewareMixin, self).__init__()
    
        def __call__(self, request):
            response = None
            if hasattr(self, 'process_request'):
                response = self.process_request(request)
            if not response:
                response = self.get_response(request)
            if hasattr(self, 'process_response'):
                response = self.process_response(request, response)
            return response

可以知道MiddlewareMixin是调用了其内部的__call__方法,__call__方法以反射的方式执行process_request和process_response方法.

中间件的应用

新建一个middleware项目,在项目的根目录中新建一个名为middleware的包,在这个package中,新建一个middleware.py文件.

    from django.utils.deprecation import MiddlewareMixin
    
    class middle_ware1(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware1.process_request")
    
        def process_response(self,request,response):
            print("middle_ware1.process_response")
            return response

在settings.py配置文件的第一行注册这个中间件

MIDDLEWARE = [
    'middleware.middleware.middle_ware1'
    'django.middleware.security.SecurityMiddleware',
    'django.contrib.sessions.middleware.SessionMiddleware',
    'django.middleware.common.CommonMiddleware',
    'django.middleware.csrf.CsrfViewMiddleware',
    'django.contrib.auth.middleware.AuthenticationMiddleware',
    'django.contrib.messages.middleware.MessageMiddleware',
    'django.middleware.clickjacking.XFrameOptionsMiddleware',
]

现在如果有http请求到达服务端,先执行中间件middle_ware1的process_request方法,再执行后面的中间件,然后到达视图函数.

定义一个视图函数index,配置好路由映射表

def index(request):

    print("index page")
    return HttpResponse("index")

启动程序,在浏览器中输入http://127.0.0.1:8000/index,会在服务端的后台打印:

middle_ware1.process_request
index page
middle_ware1.process_response

前端的页面为显示为:

index

通过这个我们知道,所有的请求都会经过middle_ware1这个中间件,先执行process_request方法,再执行视图函数本身

最后执行process_response方法,Django会把process_response方法的返回值返回给客户端.

现在再加一个定义一个middle_ware2的中间件

    from django.utils.deprecation import MiddlewareMixin
    
    class middle_ware2(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware2.process_request")
    
        def process_response(self,request,response):
            print("middle_ware2.process_response")
            return response

在settings.py配置文件中注册中间件

    MIDDLEWARE = [
        'middleware.middleware.middle_ware1',
        'middleware.middleware.middle_ware2',
        'django.middleware.security.SecurityMiddleware',
        'django.contrib.sessions.middleware.SessionMiddleware',
        'django.middleware.common.CommonMiddleware',
        'django.middleware.csrf.CsrfViewMiddleware',
        'django.contrib.auth.middleware.AuthenticationMiddleware',
        'django.contrib.messages.middleware.MessageMiddleware',
        'django.middleware.clickjacking.XFrameOptionsMiddleware',
    ]

重启程序,再次刷新网页,服务端打印信息

middle_ware1.process_request
middle_ware2.process_request
index page
middle_ware2.process_response
middle_ware1.process_response

中间件的依次执行为:

先执行middle_ware1的process_request方法,
再执行middle_ware2的类的process_request方法,
最后才执行Django的视图函数.
返回时,先执行middle_ware2的类中的process_response函数,
然后再执行middle_ware1的类中的process_response函数.

上面的例子中,process_response方法设置了return值.假如process_response没有return值,会怎么样呢??

把middle_ware1中间件的process_response方法中的return注释掉,再次刷新网页,在浏览器的网页上显示报错信息,如下:

A server error occurred.  Please contact the administrator.

http请求到达Django后,先经过自定义的中间件middle_ware1和middle_ware2,再经过Django内部定义的中间件到达视图函数

视图函数执行完成后,一定会返回一个HttpResponse或者render.

通过查看render的源码可知,render方法本质上也是调用了HttpResponse

    def render(request, template_name, context=None, content_type=None, status=None, using=None):
    
        content = loader.render_to_string(template_name, context, request, using=using)
        return HttpResponse(content, content_type, status)

视图函数的返回值HttpResponse先经过Django内部定义的中间件,再经过用户定义的中间件,最后返回给前端网页.

所以用户定义的中间件的process_response方法必须设定返回值,否则程序会报错.

同时,process_response方法中的形参response就是视图函数的返回值.
那么我们是否可以自己定义这个形参的返回值呢??

用户发过来的请求信息是固定的,因为所有的请求信息和返回信息都要经过中间件,中间件有可能会修改返回给用户的信息
,所以有可能会出现用户收到的返回值与视图函数的返回值不一样的情况.

例如,返回给用户的信息包含响应头和响应体,但是开发者在视图函数中没有设置响应头,所以Django会在返回的信息中自动加上响应头.

前面,process_response方法设置了返回值,process_request中没有设置返回值,如果为process_response设置一个返回值,结果会怎么样呢??

为中间件middle_ware1的process_request方法设置返回值

return HttpResponse("request message")

刷新浏览器,服务端打印信息:

middle_ware1.process_request
middle_ware1.process_response

客户端浏览器显示信息为:

request message

先执行process_request方法,因为process_request方法有返回值,程序不会再执行后面的中间件,而是直接执行process_response方法,然后返回信息给用户.

在实际应用中,process_request方法不能直接设定返回值.如果必须在设定返回值,必须在返回值前加入条件判断语句.

常用在设定网站的黑名单的时候可以为process_request方法设置返回值.

基于中间件实现的简单用户登录验证

比如,在一个博客系统中,所有的后台管理页面都必须有用户登录后才能打开,可以基于中间件来实现用户登录验证

定义中间件

    from django.utils.deprecation import MiddlewareMixin
    from django.shortcuts import HttpResponse,redirect
    
    class middle_ware1(MiddlewareMixin):
    
        def process_request(self,request):
            if request.path_info == "/login/":
                return None
    
            if not request.session.get("user_info"):
                return redirect("/login/")
    
        def process_response(self,request,response):
            print("middle_ware1.process_response")
            return response

在settings.py文件中注册中间件

    MIDDLEWARE = [
        'django.middleware.security.SecurityMiddleware',
        'django.contrib.sessions.middleware.SessionMiddleware',
        'django.middleware.common.CommonMiddleware',
        'django.middleware.csrf.CsrfViewMiddleware',
        'django.contrib.auth.middleware.AuthenticationMiddleware',
        'django.contrib.messages.middleware.MessageMiddleware',
        'django.middleware.clickjacking.XFrameOptionsMiddleware',
        'middleware.middleware.middle_ware1',
    ]

用户请求index网页,程序执行到process_request,会执行if not语句,然后重定向到login页面,使用户输入用户名和密码登录进入后台管理页面.

Django中间件常用方法

除了上面已经用过的process_request方法和porcess_response方法,Django的中间件还有以下几种方法.

process_view方法

定义两个中间件如下

    from django.utils.deprecation import MiddlewareMixin
    from django.shortcuts import HttpResponse,redirect
    
    class middle_ware1(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware1.process_request")
    
        def process_view(selfs,request,view_func,view_func_args,view_func_kwargs):
            print("middle_ware1.process_view")
    
        def process_response(self,request,response):
            print("middle_ware1.process_response")
            return response
    
    class middle_ware2(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware2.process_request")
    
        def process_view(self,request,view_func,view_func_args,view_func_kwargs):
            print("middle_ware2.process_view")
    
        def process_response(self,request,response):
            print("middle_ware2.process_response")
            return response

在settings.py中的注册中间件

MIDDLEWARE = [
    'django.middleware.security.SecurityMiddleware',
    'django.contrib.sessions.middleware.SessionMiddleware',
    'django.middleware.common.CommonMiddleware',
    'django.middleware.csrf.CsrfViewMiddleware',
    'django.contrib.auth.middleware.AuthenticationMiddleware',
    'django.contrib.messages.middleware.MessageMiddleware',
    'django.middleware.clickjacking.XFrameOptionsMiddleware',
    'middleware.middleware.middle_ware1',
    'middleware.middleware.middle_ware2',
]

视图函数

    def index(request):
    
        print("index page")
        return HttpResponse("index")

在浏览器中输入http://127.0.0.1:8000/index页面,在服务端打印信息

middle_ware1.process_request
middle_ware2.process_request
middle_ware1.process_view
middle_ware2.process_view
index page
middle_ware2.process_response
middle_ware1.process_response

在前端页面显示信息:

index

程序执行流程:

先执行所有中间件中的process_request方法-->进行路由匹配-->执行中间件中的的process_view方法

-->执行对应的视图函数-->执行中间件中的process_response方法

上面的例子里,process_view方法里没有设置return值.为process_view方法都设定return值,程序又会怎么执行呢??

为process_view方法设定返回值

    from django.utils.deprecation import MiddlewareMixin
    from django.shortcuts import HttpResponse,redirect
    
    class middle_ware1(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware1.process_request")
    
        def process_view(selfs,request,view_func,view_func_args,view_func_kwargs):
            return HttpResponse("middle_ware1.process_view")
    
        def process_response(self,request,response):
            print("middle_ware1.process_response")
            return response
    
    class middle_ware2(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware2.process_request")
    
        def process_view(self,request,view_func,view_func_args,view_func_kwargs):
            return HttpResponse("middle_ware2.process_view")
    
        def process_response(self,request,response):
            print("middle_ware2.process_response")

刷新浏览器,在服务端打印信息如下:

middle_ware1.process_request
middle_ware2.process_request
middle_ware2.process_response
middle_ware1.process_response

在客户端的浏览器页面显示信息如下:

iddle_ware1.process_view

可以看到视图函数index并没有执行,程序执行两个中间件的process_request方法后,其次执行process_view方法.

由于process_view方法设置了return值,所以程序中的视图函数并没有执行,而是执行了中间件中的process_response方法.

process_exception方法

修改中间件

    from django.utils.deprecation import MiddlewareMixin
    from django.shortcuts import HttpResponse,redirect
    
    class middle_ware1(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware1.process_request")
    
        def process_view(selfs,request,view_func,view_func_args,view_func_kwargs):
            print("middle_ware1.process_view")
    
        def process_exception(self,request,exvception):
            print("middleware1.process_exception")
    
        def process_response(self,request,response):
            print("middle_ware1.process_response")
            return response
    
    class middle_ware2(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware2.process_request")
    
        def process_view(self,request,view_func,view_func_args,view_func_kwargs):
            print("middle_ware2.process_view")
    
        def process_exception(self,request,exception):
            print("middleware2.process_exception")
    
        def process_response(self,request,response):
            print("middle_ware2.process_response")
            return response

刷新浏览器,服务端打印信息

middle_ware1.process_request
middle_ware2.process_request
middle_ware1.process_view
middle_ware2.process_view
hello,index page
middle_ware2.process_response
middle_ware1.process_response

根据服务端的打印信息可以看到,process_exception方法没有执行,为什么呢??

这是因为上面的代码没有bug.当代码运行错误,出现报错信息的时候,process_exception才会执行

那现在就模拟让程序出现错误,观察process_exception方法的执行情况

修改视图函数

    def index(request):
    
        print("index page")
        int("aaaa")
        return HttpResponse("index")

刷新浏览器,服务端后台打印信息

middle_ware1.process_request
middle_ware2.process_request
middle_ware1.process_view
middle_ware2.process_view
index page
middleware2.process_exception
middleware1.process_exception
Internal Server Error: /index
Traceback (most recent call last):
......
ValueError: invalid literal for int() with base 10: 'aaaa'
middle_ware2.process_response
middle_ware1.process_response

由服务端的报错信息可知,这次process_exception方法果然执行了.

由此我们知道,程序运行错误,中间件中的process_exception方法才会执行,而程序正常运行的时候,这个方法则不会执行

刚才的代码里,process_exception方法没有设置返回值,如果为process_exception方法设置返回值,程序的执行流程会是怎么的呢???

修改中间件,为两个中间件的process_exception方法都设置返回值

    from django.utils.deprecation import MiddlewareMixin
    from django.shortcuts import HttpResponse,redirect
    
    class middle_ware1(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware1.process_request")
    
        def process_view(selfs,request,view_func,view_func_args,view_func_kwargs):
            print("middle_ware1.process_view")
    
        def process_exception(self,request,exvception):
            print("middleware1.process_exception")
            return HttpResponse("bug1")
    
        def process_response(self,request,response):
            print("middle_ware1.process_response")
            return response
    
    class middle_ware2(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware2.process_request")
    
        def process_view(self,request,view_func,view_func_args,view_func_kwargs):
            print("middle_ware2.process_view")
    
        def process_exception(self,request,exception):
            print("middleware2.process_exception")
            return HttpResponse("bug2")
    
        def process_response(self,request,response):
            print("middle_ware2.process_response")
            return response

视图函数

    def index(request):
    
        print("index page")
        int("aaaa")
        return HttpResponse("index")

刷新页面,服务端打印信息

middle_ware1.process_request
middle_ware2.process_request
middle_ware1.process_view
middle_ware2.process_view
index page
middleware2.process_exception
middle_ware2.process_response
middle_ware1.process_response

而在浏览器的页面则显信息

bug2

程序的执行流程为:

客户端发出的http请求到达中间件,执行中间件中的process_request方法,然后再执行路由匹配,然后执行process_view方法,

然后执行相应的视图函数,最后执行process_response方法,返回信息给客户端浏览器.

如果执行视图函数时出现运行错误,中间件中的process_exception方法捕捉到异常就会执行,后续的process_exception方法就不会再执行了.

process_exception方法执行完毕,最后再执行所有的process_response方法.

process_template_response方法

process_template_response方法默认也不会被执行,

修改中间件

    from django.utils.deprecation import MiddlewareMixin
    from django.shortcuts import HttpResponse,redirect
    
    class middle_ware1(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware1.process_request")
    
        def process_view(selfs,request,view_func,view_func_args,view_func_kwargs):
            print("middle_ware1.process_view")
    
        def process_exception(self,request,exvception):
            print("middle_ware1.process_exception")
            return HttpResponse("bug1")
    
        def process_response(self,request,response):
            print("middle_ware1.process_response")
            return response
    
        def process_template_response(self,request,response):
            print("middle_ware1.process_template_response")
            return response
    
    class middle_ware2(MiddlewareMixin):
    
        def process_request(self,request):
            print("middle_ware2.process_request")
    
        def process_view(self,request,view_func,view_func_args,view_func_kwargs):
            print("middle_ware2.process_view")
    
        def process_exception(self,request,exception):
            print("middleware2.process_exception")
            return HttpResponse("bug2")
    
        def process_response(self,request,response):
            print("middle_ware2.process_response")
            return response
    
        def process_template_response(self,request,response):
            print("middle_ware2.process_template_response")
            return response

修改视图函数,使视图函数正常执行


    def index(request):
    
        print("index page")
        return HttpResponse("index")

刷新浏览器,服务端后台打印信息如下:

middle_ware1.process_request
middle_ware2.process_request
middle_ware1.process_view
middle_ware2.process_view
index page
middle_ware2.process_response
middle_ware1.process_response

可以看到,程序运行正常,process_template_response方法没有执行.

事实上,process_template_response方法的执行取决于视图函数的返回的信息,

视图函数如果使用render方法返回信息,中间件里的process_template_response方法就会被执行.

修改视图函数,定义一个类,返回其参数response

    class MyResponse(object):
        def __init__(self,response):
            self.response=response
    
        def render(self):
            return self.response
    
    def index(request):
    
        response=HttpResponse("index page")
        return MyResponse(response)

MyResponse类返回的是自定义的对象,这个对象里边调用了render方法.

index视图函数里,先调用了HttpResponse方法返回信息,再使用MyResponse类中的render方法来返回HttpResponse.

执行程序,服务端后台打印信息如下:

middle_ware1.process_request
middle_ware2.process_request
middle_ware1.process_view
middle_ware2.process_view
middle_ware2.process_template_response
middle_ware1.process_template_response
middle_ware2.process_response
middle_ware1.process_response

可以看到,process_template_response方法已经执行.

process_template_response的用处

如果要对返回的HttpResponse数据进行处理,可以把要处理的信息封装在一个类里
只要类里定义了render方法,process_template_response方法才会执行.

总结

中间件里本质上就是一个类,
对全局的http请求做处理的时候可以使用中间件
中间件中的方法不一定要全部使用,需要哪个用哪个
process_request方法不能有return,一定要使用return的时候,要配合条件判断语句执行
process_response方法一定要有return,否则程序会运行错误
process_view方法不能有return,否则视图函数不会执行
process_exception方法只有在程序出现运行错误的时候才会执行
process_exception方法设定return时,程序不会再执行后续中间件中的process_exception
process_template_response方法只有在视图函数中使用render方法返回信息的时候才会执行

微信关注我们

原文链接：https://yq.aliyun.com/articles/653786

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Nutanix企业云助力广播传媒的融合媒体发展之路

本文讲的是Nutanix企业云助力广播传媒的融合媒体发展之路【IT168 评论】平面媒体、广播电视和互联网多媒体不断丰富着人们的精神生活，但在移动互联迅猛发展的浪潮中，如何进行发展与转型，成为许多传统媒体不得不思考的问题。为了更好的迎接这些挑战，云南广播电视台广播传媒(以下简称“云南广电”)把握广播电视技术发展趋势，积极创新，在充分考虑未来融合媒体的发展后，颇具前瞻性地采用了Nutanix企业云超融合架构进行私有云建设，成为在全国的广播系统里走向超融合的第一家广电传媒单位。云南广电信息化转型背后的IT需求近年来，云南广电充分利用广播和电视的传播优势，在正确引导舆论上发挥了主流媒体的引领作用。目前，云南广播电视台共拥有9套13种广播节目、卫视频道(YNTV-1)和都市频道等10个电视频道(其中卫视频道覆盖全国7亿人口)、下辖两个网站、一座广播博物馆以及云南广电传媒集团，是一家集广播、电视、报纸、网络等形式的现代化综合性传媒。经过不断地突破创新，云南广电已经取得一些成绩：前云南人民广播电台率先启动广播类型化改革，历经4次改版，通过打造文化产品，提升了市场占有率;开办的金色热线四位一体节...

2017-09-22

588

什么是微服务？微服务(Microservices Architecture)是一种架构风格，一个大型复杂软件应用由一个或多个微服务组成。系统中的各个微服务可被独立部署，各个微服务之间是松耦合的。每个微服务仅关注于完成一件任务并很好地完成该任务。在所有情况下，每个任务代表着一个小的业务能力。单体架构(Monolithic Architecture )企业级的应用一般都会面临各种各样的业务需求，而常见的方式是把大量功能堆积到同一个单体架构中去。比如：常见的ERP、CRM等系统都以单体架构的方式运行，同时由于提供了大量的业务功能，随着功能的升级，整个研发、发布、定位问题，扩展，升级这样一个“怪物”系统会变得越来越困难。这种架构模式就是把应用整体打包部署，具体的样式依赖本身应用采用的语言，如果采用java语言，自然你会打包成war包，部署在Tomcat或者Jetty这样的应用服务器上，如果你使用spring boot还可以打包成jar包部署。其他还有Rails和Node.js应用以目录层次的形式打包上图：单体架构大部分企业通过SOA来解决上述问题，SOA的思路是把应用中相近的功能聚合到一起，...

2017-09-22

586

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。