1. Day 10 - 用户注册和登录
    2. 阅读: 64240
    3. 用户管理是绝大部分Web网站都需要解决的问题。用户管理涉及到用户注册和登录。
    4. 用户注册相对简单,我们可以先通过API把用户注册这个功能实现了:
    5. _RE_EMAIL = re.compile(r'^[a-z0-9\.\-\_]+\@[a-z0-9\-\_]+(\.[a-z0-9\-\_]+){1,4}$')
    6. _RE_SHA1 = re.compile(r'^[0-9a-f]{40}$')
    7. @post('/api/users')
    8. def api_register_user(*, email, name, passwd):
    9. if not name or not name.strip():
    10. raise APIValueError('name')
    11. if not email or not _RE_EMAIL.match(email):
    12. raise APIValueError('email')
    13. if not passwd or not _RE_SHA1.match(passwd):
    14. raise APIValueError('passwd')
    15. users = yield from User.findAll('email=?', [email])
    16. if len(users) > 0:
    17. raise APIError('register:failed', 'email', 'Email is already in use.')
    18. uid = next_id()
    19. sha1_passwd = '%s:%s' % (uid, passwd)
    20. user = User(id=uid, name=name.strip(), email=email, passwd=hashlib.sha1(sha1_passwd.encode('utf-8')).hexdigest(), image='http://www.gravatar.com/avatar/%s?d=mm&s=120' % hashlib.md5(email.encode('utf-8')).hexdigest())
    21. yield from user.save()
    22. # make session cookie:
    23. r = web.Response()
    24. r.set_cookie(COOKIE_NAME, user2cookie(user, 86400), max_age=86400, httponly=True)
    25. user.passwd = '******'
    26. r.content_type = 'application/json'
    27. r.body = json.dumps(user, ensure_ascii=False).encode('utf-8')
    28. return r
    29. 注意用户口令是客户端传递的经过SHA1计算后的40Hash字符串,所以服务器端并不知道用户的原始口令。
    30. 接下来可以创建一个注册页面,让用户填写注册表单,然后,提交数据到注册用户的API
    31. {% extends '__base__.html' %}
    32. {% block title %}注册{% endblock %}
    33. {% block beforehead %}
    34. <script>
    35. function validateEmail(email) {
    36. var re = /^[a-z0-9\.\-\_]+\@[a-z0-9\-\_]+(\.[a-z0-9\-\_]+){1,4}$/;
    37. return re.test(email.toLowerCase());
    38. }
    39. $(function () {
    40. var vm = new Vue({
    41. el: '#vm',
    42. data: {
    43. name: '',
    44. email: '',
    45. password1: '',
    46. password2: ''
    47. },
    48. methods: {
    49. submit: function (event) {
    50. event.preventDefault();
    51. var $form = $('#vm');
    52. if (! this.name.trim()) {
    53. return $form.showFormError('请输入名字');
    54. }
    55. if (! validateEmail(this.email.trim().toLowerCase())) {
    56. return $form.showFormError('请输入正确的Email地址');
    57. }
    58. if (this.password1.length < 6) {
    59. return $form.showFormError('口令长度至少为6个字符');
    60. }
    61. if (this.password1 !== this.password2) {
    62. return $form.showFormError('两次输入的口令不一致');
    63. }
    64. var email = this.email.trim().toLowerCase();
    65. $form.postJSON('/api/users', {
    66. name: this.name.trim(),
    67. email: email,
    68. passwd: CryptoJS.SHA1(email + ':' + this.password1).toString()
    69. }, function (err, r) {
    70. if (err) {
    71. return $form.showFormError(err);
    72. }
    73. return location.assign('/');
    74. });
    75. }
    76. }
    77. });
    78. $('#vm').show();
    79. });
    80. </script>
    81. {% endblock %}
    82. {% block content %}
    83. <div class="uk-width-2-3">
    84. <h1>欢迎注册!</h1>
    85. <form id="vm" v-on="submit: submit" class="uk-form uk-form-stacked">
    86. <div class="uk-alert uk-alert-danger uk-hidden"></div>
    87. <div class="uk-form-row">
    88. <label class="uk-form-label">名字:</label>
    89. <div class="uk-form-controls">
    90. <input v-model="name" type="text" maxlength="50" placeholder="名字" class="uk-width-1-1">
    91. </div>
    92. </div>
    93. <div class="uk-form-row">
    94. <label class="uk-form-label">电子邮件:</label>
    95. <div class="uk-form-controls">
    96. <input v-model="email" type="text" maxlength="50" placeholder="your-name@example.com" class="uk-width-1-1">
    97. </div>
    98. </div>
    99. <div class="uk-form-row">
    100. <label class="uk-form-label">输入口令:</label>
    101. <div class="uk-form-controls">
    102. <input v-model="password1" type="password" maxlength="50" placeholder="输入口令" class="uk-width-1-1">
    103. </div>
    104. </div>
    105. <div class="uk-form-row">
    106. <label class="uk-form-label">重复口令:</label>
    107. <div class="uk-form-controls">
    108. <input v-model="password2" type="password" maxlength="50" placeholder="重复口令" class="uk-width-1-1">
    109. </div>
    110. </div>
    111. <div class="uk-form-row">
    112. <button type="submit" class="uk-button uk-button-primary"><i class="uk-icon-user"></i> 注册</button>
    113. </div>
    114. </form>
    115. </div>
    116. {% endblock %}
    117. 这样我们就把用户注册的功能完成了:
    118. 用户登录比用户注册复杂。由于HTTP协议是一种无状态协议,而服务器要跟踪用户状态,就只能通过cookie实现。大多数Web框架提供了Session功能来封装保存用户状态的cookie
    119. Session的优点是简单易用,可以直接从Session中取出用户登录信息。
    120. Session的缺点是服务器需要在内存中维护一个映射表来存储用户登录信息,如果有两台以上服务器,就需要对Session做集群,因此,使用SessionWeb App很难扩展。
    121. 我们采用直接读取cookie的方式来验证用户登录,每次用户访问任意URL,都会对cookie进行验证,这种方式的好处是保证服务器处理任意的URL都是无状态的,可以扩展到多台服务器。
    122. 由于登录成功后是由服务器生成一个cookie发送给浏览器,所以,要保证这个cookie不会被客户端伪造出来。
    123. 实现防伪造cookie的关键是通过一个单向算法(例如SHA1),举例如下:
    124. 当用户输入了正确的口令登录成功后,服务器可以从数据库取到用户的id,并按照如下方式计算出一个字符串:
    125. "用户id" + "过期时间" + SHA1("用户id" + "用户口令" + "过期时间" + "SecretKey")
    126. 当浏览器发送cookie到服务器端后,服务器可以拿到的信息包括:
    127. 用户id
    128. 过期时间
    129. SHA1
    130. 如果未到过期时间,服务器就根据用户id查找用户口令,并计算:
    131. SHA1("用户id" + "用户口令" + "过期时间" + "SecretKey")
    132. 并与浏览器cookie中的哈希进行比较,如果相等,则说明用户已登录,否则,cookie就是伪造的。
    133. 这个算法的关键在于SHA1是一种单向算法,即可以通过原始字符串计算出SHA1结果,但无法通过SHA1结果反推出原始字符串。
    134. 所以登录API可以实现如下:
    135. @post('/api/authenticate')
    136. def authenticate(*, email, passwd):
    137. if not email:
    138. raise APIValueError('email', 'Invalid email.')
    139. if not passwd:
    140. raise APIValueError('passwd', 'Invalid password.')
    141. users = yield from User.findAll('email=?', [email])
    142. if len(users) == 0:
    143. raise APIValueError('email', 'Email not exist.')
    144. user = users[0]
    145. # check passwd:
    146. sha1 = hashlib.sha1()
    147. sha1.update(user.id.encode('utf-8'))
    148. sha1.update(b':')
    149. sha1.update(passwd.encode('utf-8'))
    150. if user.passwd != sha1.hexdigest():
    151. raise APIValueError('passwd', 'Invalid password.')
    152. # authenticate ok, set cookie:
    153. r = web.Response()
    154. r.set_cookie(COOKIE_NAME, user2cookie(user, 86400), max_age=86400, httponly=True)
    155. user.passwd = '******'
    156. r.content_type = 'application/json'
    157. r.body = json.dumps(user, ensure_ascii=False).encode('utf-8')
    158. return r
    159. # 计算加密cookie:
    160. def user2cookie(user, max_age):
    161. # build cookie string by: id-expires-sha1
    162. expires = str(int(time.time() + max_age))
    163. s = '%s-%s-%s-%s' % (user.id, user.passwd, expires, _COOKIE_KEY)
    164. L = [user.id, expires, hashlib.sha1(s.encode('utf-8')).hexdigest()]
    165. return '-'.join(L)
    166. 对于每个URL处理函数,如果我们都去写解析cookie的代码,那会导致代码重复很多次。
    167. 利用middle在处理URL之前,把cookie解析出来,并将登录用户绑定到request对象上,这样,后续的URL处理函数就可以直接拿到登录用户:
    168. @asyncio.coroutine
    169. def auth_factory(app, handler):
    170. @asyncio.coroutine
    171. def auth(request):
    172. logging.info('check user: %s %s' % (request.method, request.path))
    173. request.__user__ = None
    174. cookie_str = request.cookies.get(COOKIE_NAME)
    175. if cookie_str:
    176. user = yield from cookie2user(cookie_str)
    177. if user:
    178. logging.info('set current user: %s' % user.email)
    179. request.__user__ = user
    180. return (yield from handler(request))
    181. return auth
    182. # 解密cookie:
    183. @asyncio.coroutine
    184. def cookie2user(cookie_str):
    185. '''
    186. Parse cookie and load user if cookie is valid.
    187. '''
    188. if not cookie_str:
    189. return None
    190. try:
    191. L = cookie_str.split('-')
    192. if len(L) != 3:
    193. return None
    194. uid, expires, sha1 = L
    195. if int(expires) < time.time():
    196. return None
    197. user = yield from User.find(uid)
    198. if user is None:
    199. return None
    200. s = '%s-%s-%s-%s' % (uid, user.passwd, expires, _COOKIE_KEY)
    201. if sha1 != hashlib.sha1(s.encode('utf-8')).hexdigest():
    202. logging.info('invalid sha1')
    203. return None
    204. user.passwd = '******'
    205. return user
    206. except Exception as e:
    207. logging.exception(e)
    208. return None
    209. 这样,我们就完成了用户注册和登录的功能。
    210. 参考源码
    211. day-10