对于具体Etag是什么,请求流程,实现原理,这里不进行介绍,能够参考下面连接:
http://www.oschina.net/questi...
https://zh.wikipedia.org/wiki...html
先从Tornado处理一个请求的调用顺序开始看(摘自文档:http://www.tornadoweb.cn/documentation): 程序为每个请求建立一个 RequestHandler 对象 程序调用 initialize() 函数,这个函数的参数是 Application 配置中的关键字 参数定义。(initialize 方法是 Tornado 1.1 中新添加的,旧版本中你须要 重写 __init__ 以达到一样的目的) initialize 方法通常只是把传入的参数存 到成员变量中,而不会产生一些输出或者调用像 send_error 之类的方法。 程序调用 prepare()。不管使用了哪一种 HTTP 方法,prepare 都会被调用到,所以 这个方法一般会被定义在一个基类中,而后在子类中重用。prepare能够产生输出 信息。若是它调用了finish(或send_error` 等函数),那么整个处理流程 就此结束。 程序调用某个 HTTP 方法:例如 get()、post()、put() 等。若是 URL 的正则表达式模式中有分组匹配,那么相关匹配会做为参数传入方法。 在一个请求结束的时候确定会进行Etag的处理,因此找到调用的 finish() 函数:
def finish(self, chunk=None): # Automatically support ETags and add the Content-Length header if # we have not flushed any content yet. if not self._headers_written: if (self._status_code == 200 and self.request.method in ("GET", "HEAD") and "Etag" not in self._headers): self.set_etag_header() if self.check_etag_header(): self._write_buffer = [] self.set_status(304) if self._status_code in (204, 304): assert not self._write_buffer, "Cannot send body with %s" % self._status_code self._clear_headers_for_304() elif "Content-Length" not in self._headers: content_length = sum(len(part) for part in self._write_buffer) self.set_header("Content-Length", content_length)
分析:
在调用 finish() 函数的时候,对HTTP请求进行判断,若是 状态码为200,请求的方法为 GET 或 HEAD,而且 Etag 不在HTTP头信息里面,则说明该请求是第一次发生。接下来,调用 set_etag_header() 函数,将 etag 写入到 header头信息中web
def set_etag_header(self): etag = self.compute_etag() if etag is not None: self.set_header("Etag", etag)
分析:
接着调用 compute_etag() 函数生成 etag,若是返回成功,则调用 set_header() 函数将 etag 写入header头信息的 “Etag” 字段。查看 compute_etag() 函数:正则表达式
def compute_etag(self): hasher = hashlib.sha1() for part in self._write_buffer: hasher.update(part) return '"%s"' % hasher.hexdigest()
分析:
这里经过 调用 hashlib库 生成相应的 etag,而后经过对于 self._write_buffer的循环,当服务端文件有改变的时候,调用hashlib中的 update() 函数更新生成的新的对象 hasher,从而返回最新的 etag
注:self._write_buffer在初始化的时候已经进行了定义 self._write_buffer = [ ], 若是某一个页面有改变,则会进行记录,从而来判断是否客户端请求的页面在服务端是否有改变,这里对于 etag 的生成函数 set_etag_header() 函数已经介绍完了,接着进行 check_etag_header() 校验函数的分析:函数
def check_etag_header(self): etags = re.findall( br'\*|(?:W/)?"[^"]*"', utf8(self.request.headers.get("If-None-Match", "")) ) if not computed_etag or not etags: return False match = False if etags[0] == b'*': match = True else: # Use a weak comparison when comparing entity-tags. def val(x): return x[2:] if x.startswith(b'W/') else x for etag in etags: if val(etag) == val(computed_etag): match = True break return match
分析:
首先服务端获取 客户端发送过来的 header头信息 中的 “If-None-Match” 字段,拿到该 etag,并经过正则表达式匹配,查看是否跟服务端保存的etag相同。若是 没有获取到header头信息中的 etag字段或跟服务端etag不匹配,则返回 False,否定返回 True。
以后,若是该 check_etag_header() 函数 返回True 的话, 则说明,该请求中包含有该 etag 而且该etag和服务端保存的相同,接下来t经过 self._write_buffer = [ ] 对这个字段进行清空处理(代表该请求的页面暂时没有任何修改), 而且返回 状态码304 给客户端。tornado
del self.request.headers['If-None-Match']
参考资料源码分析