请求上下文分析,wtforms(了解)

发布时间 2023-04-08 16:19:47作者: 小王应该在学习!

请求上下文分析,wtforms(了解)

1.1 导出项目的依赖

# -下载语句:pip freeze
# 使用第三方模块,更精确的导出依赖 pipreqs
	第一步:安装 pip3 install pipreqs
     第二步:使用命令,导出项目依赖   pipreqs ./ 
    	-win由于编码问题会出错:使用这个语句解决:pipreqs ./ --encoding=utf8
        -mac,linx没有问题
        
    第三步:就会在项目根路径下生成:requirements.txt

1.2 函数和方法

# 只要会自动传值,就是方法,函数,有几个值就要传几个值,否则报错

# 函数就是普通的函数,有几个参数传几个参数
# 方法:有绑定给对象的方法,绑定给类的方法,绑定给谁就由谁来调用,把自身传入
类的绑定方法,对象可以调用,会自动把类传入
对象绑定的方法,类可以调用吗?类可以调用,但是它就变成了普通函数,有几个值就传几个值
 MethodType检查一个对象,是不是方法
 FunctionType检查一个对象,是不是函数
 isinstance 判断一个对象,是不是一个类的对象
 issubclass 判断一个类,是不是另一个类的子类
from types import MethodType,FunctionType

class Foo(object):
    def fetch(self):
        pass

    @classmethod
    def test(cls):
        pass

    @staticmethod
    def test1():
        pass

a=Foo()
print(isinstance(a,Foo))
print(isinstance('a',Foo))

class Foo2(Foo):
    pass
class Foo3():
    pass
print(issubclass(Foo2,Foo))
print(issubclass(Foo3,Foo))

image

1.3 threading.local对象

# local对象
# 并发编程中,多个线程操作一个变量时,会出现并发安全的问题,就需要加锁来解决
使用local对象,多线程并发操作时,不需要加锁,不会出现数据错乱threading.local
 在Java中也有ThreadLocal这个东西,面试经常问到


# 本质原理
多个线程修改同一个数据,复制多份给每个线程用,为每个线程开辟一块空间进行数据存储,每个线程操作自己的那部分数据

# 使用:
1)导入:
from threading import Thread, get_ident
from threading import local
2)创建对象
# 特殊对象
jm = local()
3)函数使用
def task(arg):
    # 对象.val = 1/2/3/4/5
    jm.value = arg
    time.sleep(0.1)
    print(f'第:{get_ident()}条线程的值为:{jm.value}')
4)线程
for i in range(10):
    t = Thread(target=task, args=(i,))
    t.start()

1.4 偏函数

#python内置一个偏函数,可以把函数包裹一下,提前传参


from functools import partial

def add(a,b,c):
    return a+b+c

# print(add(4,5,6))

add=partial(add,8)

print(add(7,9))
# 借助于偏函数,羡慕提前吧第一个参数传入,后面再传剩下的两个参数

1.5 flask 整个生命执行流程(1.1.4版本为例)

# 请求来了---》app()----->Flask.__call__--->self.wsgi_app(environ, start_response)
    def wsgi_app(self, environ, start_response):
        # environ:http请求拆成了字典
        # ctx对象:RequestContext类的对象,对象里有:当次的requets对象,app对象,session对象
        ctx = self.request_context(environ)
        error = None
        try:
            try:
                #ctx RequestContext类 push方法
                ctx.push()
                # 匹配成路由后,执行视图函数
                response = self.full_dispatch_request()
            except Exception as e:
                error = e
                response = self.handle_exception(e)
            except:
                error = sys.exc_info()[1]
                raise
            return response(environ, start_response)
        finally:
            if self.should_ignore_error(error):
                error = None
            ctx.auto_pop(error)
            
            
            
            
            
  # RequestContext :ctx.push
 def push(self):
		# _request_ctx_stack = LocalStack() ---》push(ctx对象)--》ctx:request,session,app
        _request_ctx_stack.push(self)
		#session相关的
        if self.session is None:
            session_interface = self.app.session_interface
            self.session = session_interface.open_session(self.app, self.request)

            if self.session is None:
                self.session = session_interface.make_null_session(self.app)
		# 路由匹配相关的
        if self.url_adapter is not None:
            self.match_request()
                        
# LocalStack()  push --->obj 是ctx对象
    def push(self, obj):
        #self._local  _local 就是咱们刚刚自己写的Local的对象---》LocalStack的init初始化的_local---》self._local = Local()---》Local对象可以根据线程协程区分数据 
        rv = getattr(self._local, "stack", None)
        # 一开始没有值
        if rv is None:
            rv = []
            self._local.stack = rv  # self._local.stack 根据不同线程用的是自己的数据
        rv.append(obj)  # self._local.stack.append(obj)
        # {'线程id号':{stack:[ctx]},'线程id号2':{stack:[ctx]}}
        return rv
    
    
    
 # 再往后执行,就会进入到路由匹配,执行视图函数
	# request = LocalProxy(partial(_lookup_req_object, "request"))
    # LocalProxy 代理类---》method---》代理类去当前线程的stack取出ctx,取出当时放进去的request
	视图函数中:print(request.method)
    
    
# print(request) 执行LocalProxy类的__str__方法
# request.method 执行LocalProxy类的__getattr__
    def __getattr__(self, name): #name 是method
        # self._get_current_object() 就是当次请求的request
        return getattr(self._get_current_object(), name)
    
    
 # LocalProxy类的方法_get_current_object
   def _get_current_object(self):
        if not hasattr(self.__local, "__release_local__"):
            return self.__local()
        try:
            return getattr(self.__local, self.__name__)
        except AttributeError:
            raise RuntimeError("no object bound to %s" % self.__name__)
            
            
            
 # self.__local 是在 LocalProxy 类实例化的时候传入的local

# 在这里实例化的:request = LocalProxy(partial(_lookup_req_object, "request"))
# local 是 partial(_lookup_req_object, "request")

#_lookup_req_object ,name=request
def _lookup_req_object(name):
    top = _request_ctx_stack.top  # 取出了ctx,是当前线程的ctx
    if top is None:
        raise RuntimeError(_request_ctx_err_msg)
    return getattr(top, name)  #从ctx中反射出request,当次请求的request
请求上下文执行流程(ctx):
-0 flask项目一启动,有6个全局变量
    -_request_ctx_stack:LocalStack对象
    -_app_ctx_stack :LocalStack对象
    -request : LocalProxy对象
    -session : LocalProxy对象
-1 请求来了 app.__call__()---->内部执行:self.wsgi_app(environ, start_response)
-2 wsgi_app()
    -2.1 执行:ctx = self.request_context(environ):返回一个RequestContext对象,并且封装了request(当次请求的request对象),session,flash,当前app对象
    -2.2 执行: ctx.push():RequestContext对象的push方法
        -2.2.1 push方法中中间位置有:_request_ctx_stack.push(self),self是ctx对象
        -2.2.2 去_request_ctx_stack对象的类中找push方法(LocalStack中找push方法)
        -2.2.3 push方法源码:
        def push(self, obj):
            #通过反射找self._local,在init实例化的时候生成的:self._local = Local()
            #Local(),flask封装的支持线程和协程的local对象
            # 一开始取不到stack,返回None
            rv = getattr(self._local, "stack", None)
            if rv is None:
                #走到这,self._local.stack=[],rv=self._local.stack
                self._local.stack = rv = []
                # 把ctx放到了列表中
                #self._local={'线程id1':{'stack':[ctx,]},'线程id2':{'stack':[ctx,]},'线程id3':{'stack':[ctx,]}}
                rv.append(obj)
                return rv
-3 如果在视图函数中使用request对象,比如:print(request)
    -3.1 会调用request对象的__str__方法,request类是:LocalProxy
    -3.2 LocalProxy中的__str__方法:lambda x: str(x._get_current_object())
        -3.2.1 内部执行self._get_current_object()
        -3.2.2 _get_current_object()方法的源码如下:
        def _get_current_object(self):
            if not hasattr(self.__local, "__release_local__"):
                #self.__local()  在init的时候,实例化的,在init中:object.__setattr__(self, "_LocalProxy__local", local)
                # 用了隐藏属性
                #self.__local 实例化该类的时候传入的local(偏函数的内存地址:partial(_lookup_req_object, "request"))
                #加括号返回,就会执行偏函数,也就是执行_lookup_req_object,不需要传参数了
                #这个地方的返回值就是request对象(当此请求的request,没有乱)
                return self.__local()
            try:
                return getattr(self.__local, self.__name__)
            except AttributeError:
                raise RuntimeError("no object bound to %s" % self.__name__)
                -3.2.3 _lookup_req_object函数源码如下:
                def _lookup_req_object(name):
                    #name是'request'字符串
                    #top方法是把第二步中放入的ctx取出来,因为都在一个线程内,当前取到的就是当次请求的ctx对象
                    top = _request_ctx_stack.top
                    if top is None:
                        raise RuntimeError(_request_ctx_err_msg)
                        #通过反射,去ctx中把request对象返回
                        return getattr(top, name)
                -3.2.4 所以:print(request) 实质上是在打印当此请求的request对象的__str__
-4 如果在视图函数中使用request对象,比如:print(request.method):实质上是取到当次请求的reuquest对象的method属性
		
-5 最终,请求结束执行: ctx.auto_pop(error),把ctx移除掉
其他的东西:
		-session:
			-请求来了opensession
				-ctx.push()---->也就是RequestContext类的push方法的最后的地方:
					if self.session is None:
						#self是ctx,ctx中有个app就是flask对象,   self.app.session_interface也就是它:SecureCookieSessionInterface()
						session_interface = self.app.session_interface
						self.session = session_interface.open_session(self.app, self.request)
						if self.session is None:
							#经过上面还是None的话,生成了个空session
							self.session = session_interface.make_null_session(self.app)
			-请求走了savesession
				-response = self.full_dispatch_request() 方法内部:执行了before_first_request,before_request,视图函数,after_request,savesession
				-self.full_dispatch_request()---->执行:self.finalize_request(rv)-----》self.process_response(response)----》最后:self.session_interface.save_session(self, ctx.session, response)
		-请求扩展相关
			before_first_request,before_request,after_request依次执行
		-flask有一个请求上下文,一个应用上下文
			-ctx:
				-是:RequestContext对象:封装了request和session
				-调用了:_request_ctx_stack.push(self)就是把:ctx放到了那个位置
			-app_ctx:
				-是:AppContext(self) 对象:封装了当前的app和g
				-调用 _app_ctx_stack.push(self) 就是把:app_ctx放到了那个位置
	-g是个什么?
		专门用来存储用户信息的g对象,g的全称的为global 
		g对象在一次请求中的所有的代码的地方,都是可以使用的 
		
		
	-代理模式
		-request和session就是代理对象,用的就是代理模式

wtforms(了解)

#django中forms组件
1.生成前端模板
2.校验数据
3.渲染错误信息

# flask中使用了第三方的wtforms,实现像django中forms一样的功能
1.导入,定义一个类,继承forms
2.模板中for循环生成模板
3.在视图函数中,用form校验数据

py文件

from flask import Flask, render_template, redirect, request

from wtforms import Form
from wtforms.fields import simple
from wtforms import validators
from wtforms import widgets

app = Flask(__name__, template_folder='templates')
app.debug = True


class LoginForm(Form):
    # 字段(内部包含正则表达式)
    name = simple.StringField(
        label='用户名',
        validators=[
            validators.DataRequired(message='用户名不能为空.'),
            validators.Length(min=6, max=18, message='用户名长度必须大于%(min)d且小于%(max)d')
        ],
        widget=widgets.TextInput(),  # 页面上显示的插件
        render_kw={'class': 'form-control'}

    )
    # 字段(内部包含正则表达式)
    pwd = simple.PasswordField(
        label='密码',
        validators=[
            validators.DataRequired(message='密码不能为空.'),
            validators.Length(min=8, message='用户名长度必须大于%(min)d'),
            validators.Regexp(regex="^(?=.*[a-z])(?=.*[A-Z])(?=.*\d)(?=.*[$@$!%*?&])[A-Za-z\d$@$!%*?&]{8,}",
                              message='密码至少8个字符,至少1个大写字母,1个小写字母,1个数字和1个特殊字符')

        ],
        widget=widgets.PasswordInput(),
        render_kw={'class': 'form-control'}
    )


@app.route('/login', methods=['GET', 'POST'])
def login():
    if request.method == 'GET':
        form = LoginForm()
        return render_template('login.html', form=form)
    else:
        form = LoginForm(formdata=request.form)
        if form.validate():
            print('用户提交数据通过格式验证,提交的值为:', form.data)
        else:
            print(form.errors)
        return render_template('login.html', form=form)


if __name__ == '__main__':
    app.run()

html文件

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<h1>登录</h1>
<form method="post" novalidate>
    <p>{{form.name.label}}: {{form.name}} {{form.name.errors[0] }}</p>

    <p>{{form.pwd.label}} {{form.pwd}} {{form.pwd.errors[0] }}</p>
    <input type="submit" value="提交">
</form>
</body>
</html>

image