一、创建用户模型

  1. from django.db import models
  2. from django.contrib.auth.models import AbstractUser
  5. class User(AbstractUser):
  6.     mobile = models.CharField(max_length=11, unique=True, verbose_name='手机号')
  8.     class Meta:
  9.         db_table = 'tb_users'
  10.         verbose_name = '用户'
  11.         verbose_name_plural = verbose_name
  13.         def __str__(self):
  14.         return self.username

在settings.py文件中指定用户模型类(AUTH_USER_MODEL = ‘app应用名.模型类名’)

  1. AUTH_USER_MODEL = 'users.User'

二、用户注册接口

  1. from django.http import JsonResponse
  2. from django.views import View
  3. from .models import User
  4. import logging
  5. logger = logging.getLogger('django')
  7. # 验证用户名重复
  8. class UsernameCountView(View):
  9.     def get(self, request, username):
  10.         try:
  11.             # 1、统计用户数量
  12.             count = User.objects.filter(
  13.                 username=username
  14.             ).count()
  15.         except Exception as e:
  16.             print(e)
  17.             # 写日志
  18.             logger.error(e)
  20.         # 2、构建响应返回
  21.         return JsonResponse({
  22.             'code': 0,
  23.             'errmsg': 'ok',
  24.             'count': count
  25.         })
  1. from django.urls import path, re_path
  2. from users.views import *
  4. urlpatterns = [
  5.     re_path(r'^usernames/(?P<username>[a-zA-Z0-9_-]{5,20})/count/$', UsernameCountView.as_view()),
  6.     re_path(r'^mobiles/(?P<mobile>1[3-9]\d{9})/count/$', MobileCountView.as_view()),
  7. ]
  1. # 保存后端API服务器地址，视情况而定
  2. var host = 'http://127.0.0.1:8000';
  1. http://IP:8000/usernames/用户名/count/

三、手机号验证接口

  1. class MobileCountView(View):
  2.     def get(self, request, mobile):
  3.         try:
  4.             count = User.objects.filter(
  5.                 mobile=mobile
  6.             ).count()
  7.         except Exception as e:
  8.             print(e)
  9.             logger.error(e)
  11.         return JsonResponse({
  12.             'code': 0,
  13.             'errmsg': 'ok',
  14.             'count': count
  15.         })
  1. re_path(r'^mobiles/(?P<mobile>1[3-9]\d{9})/count/$', MobileCountView.as_view()),
  1. http://IP:8000/mobiles/手机号/count/

四、解决跨域问题

  1. # 1.安装
  2.     pip install django-cors-headers
  4. # 2.INSTALLED_APPS注册
  5.     'corsheaders',
  7. # 3.添加MIDDLEWARE
  8.     'corsheaders.middleware.CorsMiddleware',
  10. # 4.setting.py新增
  11.     CORS_ORIGIN_WHITELIST = [
  12.         'http://127.0.0.1',
  13.         'http://127.0.0.1:80',
  14.     ]
  16.     # 允许在不同主机之间传递cookie数据
  17.     CORS_ALLOW_CREDENTIALS = True

五、图形验证码

  1. # 1.新建app          verifications
  2. # 2.安装pillow    pip install pillow
  3. # 3.项目目录下创建lib的python包导入文件
  4. # 4.配置Redis缓存
  5.     "verify_code": {
  6.         "BACKEND": "django_redis.cache.RedisCache",
  7.         "LOCATION": "redis://82.156.189.83:6379/2",
  8.         "OPTIONS": {
  9.             "CLIENT_CLASS": "django_redis.client.DefaultClient",
  10.         }
  11.     },
  12.     "sms_code": {
  13.         "BACKEND": "django_redis.cache.RedisCache",
  14.         "LOCATION": "redis://82.156.189.83:6379/3",
  15.         "OPTIONS": {
  16.             "CLIENT_CLASS": "django_redis.client.DefaultClient",
  17.         }
  18.     },
  19. # 5.
  1. from django.views import View  # 从django.views导入View
  2. from libs.captcha.captcha import captcha  # 导入第三方包captcha
  3. from django_redis import get_redis_connection  # 导入redis库
  4. from django.http import HttpResponse  # 导入HttpResponse给前端进行响应
  5. import logging  # 导入日记模块
  6. logger = logging.getLogger('django')
  7. # 图形验证码接口
  8. class ImageCodeView(View):
  9.     def get(self, request, uuid):
  10.         # 1、调用库生成图形验证码
  11.         text, image = captcha.generate_captcha()
  12.         # 2、存储redis
  13.         conn = get_redis_connection('verify_code')
  14.         try:
  15.             # 验证码写入redis
  16.             conn.setex(
  17.                 "img_%s" % uuid,
  18.                 300,
  19.                 text
  20.             )
  21.         except Exception as e:
  22.             print(e)
  23.             logger.error(e)
  24.         # 3、构建响应
  25.         return HttpResponse(image, content_type='image/jpg')
  1. from django.urls import re_path # 从django.urls导入re_path
  2. from . import views # 从当前文件夹，导入views
  4. urlpatterns = [
  5.     # 图形验证码
  6.     re_path(r'^image_codes/(?P<uuid>[\w-]+)/$', views.ImageCodeView.as_view()),
  7. ]

六、短信验证码

  1. # 1.
  2.     # ACCOUNT SID
  3.     _accountSid = ''
  5.     # AUTH TOKEN
  6.     _accountToken = ''
  8.     # AppID
  9.     _appId = ''
  11. # 2.
  12.     if __name__ == '__main__':
  13.     # 注意： 测试的短信模板编号为1
  14.     CCP().send_template_sms('测试手机号', ['1234', 5], 1)
  16. # 3.
  1. from django.http import HttpResponse,JsonResponse
  2. from aerf_mall.libs.yuntongxun.ccp_sms import CCP
  3. import random
  4. import re
  5. class SMSCodeView(View):
  6.     def get(self, request, mobile):
  7.         # 1、提取参数
  8.         image_code = request.GET.get('image_code')
  9.         uuid = request.GET.get('image_code_id')
  10.         # 2、校验参数
  11.         if not all([image_code, uuid]):
  12.             return JsonResponse({
  13.                 'code': 400,
  14.                 'errmsg': '缺少必要参数'
  15.             }, status=400)
  16.         if not re.match(r'^\w{4}$', image_code):
  17.             return JsonResponse({
  18.                 'code': 400,
  19.                 'errmsg': '图片验证码格式不符'
  20.             }, status=400)
  21.         if not re.match(r'^[0-9a-f]{8}(-[0-9a-f]{4}){3}-[0-9a-f]{12}$', uuid):
  22.             return JsonResponse({
  23.                 'code': 400,
  24.                 'errmsg': 'uuid格式不符'
  25.             }, status=400)
  26.         # 3、校验redis中的图片验证码是否一致——业务层面上的校验
  27.         conn = get_redis_connection('verify_code')
  28.         # 3.1 提取redis中存储的图片验证码
  29.         # get(): b"YBCF"
  30.         image_code_from_redis = conn.get("img_%s"%uuid)
  31.         # 如果从redis中读出的验证码是空；
  32.         if not image_code_from_redis:
  33.             return JsonResponse({'code':400, 'errmsg': '验证码过期'}, status=400)
  34.         # 如果读出来的不是空，我们要删除该验证码
  35.         image_code_from_redis = image_code_from_redis.decode()
  36.         conn.delete("img_%s"%uuid)
  37.         # 3.2 比对（忽略大小写）
  38.         if image_code.lower() != image_code_from_redis.lower():
  39.             return JsonResponse({
  40.                 'code': 400,
  41.                 'errmsg': '图形验证码输入错误'
  42.             }, status=400)
  43.         # 4、发送短信验证码
  44.         conn = get_redis_connection('sms_code')
  45.         # 判断60秒之内，是否发送过短信——判断标志信息是否存在
  46.         flag = conn.get('flag_%s'%mobile)
  47.         if flag:
  48.             return JsonResponse({'code':400, 'errmsg':'请勿重复发送短信'}, status=400)
  49.         # 构建6位手机验证码
  50.         sms_code = "%06d"%random.randint(0, 999999)
  51.         print("手机验证码：", sms_code)
  52.         # 生成一个redis的pipeline对象
  53.         p = conn.pipeline()
  54.         # 把验证码存入redis
  55.         p.setex(
  56.             "sms_%s"%mobile,
  57.             300,
  58.             sms_code
  59.         )
  60.         # 一旦用户发送了短信,需要在redis中存储一个标志
  61.         p.setex(
  62.             "flag_%s"%mobile,
  63.             60,
  64.             '1'
  65.         )
  66.         p.execute() # 批量执行队列中的指令
  68.         # 发送验证码
  69.         # 同步调用——只有当该发送短信当函数执行完毕，且返回了；代码才会继续往后执行！
  70.         # 如果网络出现了问题，该函数就会一致阻塞在此，导致我们的视图函数无法即使响应！
  71.         CCP().send_template_sms(mobile, [sms_code, 5], 1)
  72.         return JsonResponse({
  73.             'code': 0,
  74.             'errmsg': 'ok'
  75.         })
  1. from django.urls import re_path
  2. from . import views
  4. urlpatterns = [
  5.     re_path(r'^sms_codes/(?P<mobile>1[3-9]\d{9})/$', views.SMSCodeView.as_view()),
  6. ]

七、异步方案Celery

  1. # 1.安装Celery
  2.     pip install -U Celery
  4. # 2.项目目录下创建celery_tasks的python包
  6. # 3.在celery_tasks下创建config.py和main.py文件
  8. # 4.config.py
  9.     # 如果使用 redis 作为中间人
  10.     # 需要这样配置:
  11.     # 1、将来生产者会把任务发不到redis的10号库
  12.     # 2、消费者会从redis的10号库中提取任务并执行
  13.     broker_url='redis://127.0.0.1:6379/10'
  15. # 5.main.py
  16.     """该文件作为异步应用程序初始化的模块"""
  17.     # 在异步任务程序中加载django的环境
  18.     import os
  19.     os.environ.setdefault(
  20.         'DJANGO_SETTINGS_MODULE',
  21.         'aerf_test.settings.dev'   # 此行aerf_test要改成你对应的项目名字
  22.     )
  23.     from celery import Celery
  24.     # 初始化一个应用程序对象(名称可以任意填写)
  25.     app = Celery("aerf")
  27.     # 加载配置文件——参数是配置文件(模块)的导包路径
  28.     # 我们将来是在celery_tasks包所在的目录为工作目录运行异步程序；
  29.     app.config_from_object('celery_tasks.config')
  31.     # 告知app监听的任务有哪些
  32.     # 该函数的参数是一个列表，列表里写的是任务包的导包路径
  33.     app.autodiscover_tasks([
  34.         'celery_tasks.sms',
  35.     ])
  37. # 6.在celery_tasks下创建sms的python包
  39. # 7.将云通讯目录拷贝到celery_tasks下
  41. # 8.在sms下创建tasks.py文件
  42.     """tasks.py文件名是固定，该文件中定义异步任务函数！！"""
  43.     from celery_tasks.main import app
  44.     from celery_tasks.yuntongxun.ccp_sms import CCP
  46.     #  定义一个发送短信的任务函数
  47.     # name自定义任务函数名称
  48.     # 被app.task装饰的函数就是异步任务函数
  49.     @app.task(name='ccp_send_sms_code')
  50.     def ccp_send_sms_code(mobile, sms_code):
  51.         return CCP().send_template_sms(mobile, [sms_code, 5], 1)
  53. # 9.修改View的视图
  54.     from celery_tasks.sms.tasks import ccp_send_sms_code
  55.     ccp_send_sms_code.delay(mobile, sms_code)
  57. # 10.启用celery服务
  58.     celery -A celery_tasks.main worker -l info
  59.     celery -A celery_tasks.main worker -l info -c 10

八、用户注册

  1. from django_redis import get_redis_connection
  2. from django.contrib.auth import login
  3. import json
  4. import re
  6. class RegisterView(View):
  7.     def post(self, request):
  8.         # 1、提取参数
  9.         # request.body --> b'{"username": "xxxx"}'
  10.         # request.body.decode() --> '{"username": "xxxx"}'
  11.         data = json.loads(request.body.decode())
  13.         username = data.get('username')
  14.         password = data.get('password')
  15.         password2 = data.get('password2')
  16.         mobile = data.get('mobile')
  17.         sms_code = data.get('sms_code')
  18.         allow = data.get('allow')
  20.         # 2、校验参数
  21.         if not all([username, password, password2, mobile, sms_code]):
  22.             return JsonResponse({'code':400, 'errmsg': '缺少参数'}, status=400)
  24.         if not re.match(r'^\w{5,20}$', username):
  25.             return JsonResponse({'code':400, 'errmsg': '用户名格式有误'}, status=400)
  27.         if not re.match(r'^\w{8,20}$', password):
  28.             return JsonResponse({'code':400, 'errmsg': '密码格式有误'}, status=400)
  30.         if password != password2:
  31.             return JsonResponse({'code':400, 'errmsg': '密码输入不一致！'}, status=400)
  33.         if not re.match(r'^\d{6}$', sms_code):
  34.             return JsonResponse({'code': 400, 'errmsg': '验证码格式有误'}, status=400)
  36.         if not allow:
  37.             return JsonResponse({'code': 400, 'errmsg': '请求统一用户协议！'}, status=400)
  40.         # 手机验证码校验
  41.         conn = get_redis_connection('sms_code')
  42.         sms_code_from_redis = conn.get('sms_%s'%mobile)
  43.         if not sms_code_from_redis:
  44.             return JsonResponse({'code': 400, 'errmsg': '短信验证码过期！'}, status=400)
  45.         sms_code_from_redis = sms_code_from_redis.decode()
  46.         if sms_code_from_redis != sms_code:
  47.             return JsonResponse({'code':400, 'errmsg': '短信验证码有误！'}, status=400)
  49.         # 3、新建数据,构建用户模型类对象保存数据库
  50.         # User.objects.create() --> 构建的用户模型类对象，密码不会加密
  51.         # User.objects.create_user() --> 构建用户模型类对象，把明文密码加密
  52.         # User.objects.create_superuser() --> 构建用户模型类对象，把明文密码加密以及is_staff=True
  53.         try:
  54.             user = User.objects.create_user(
  55.                 username=username,
  56.                 password=password,
  57.                 mobile=mobile
  58.             )
  59.         except Exception as e:
  60.             print(e)
  62.         # 传入request对象和user对象，把用户信息写入session缓存(redis)中，并且把sessionid返回给浏览器
  63.         # 存入cookie
  64.         login(request, user)
  67.         # 4、构建响应
  68.         response = JsonResponse({'code': 0, 'errmsg':' ok'})
  69.         response.set_cookie(
  70.             'username',
  71.             username,
  72.             max_age=3600*24*14
  73.         )
  74.         return response
  1. re_path(r'^register/$', RegisterView.as_view()),