【愚公系列】2022年01月 Django商城项目08-注册界面-短信验证码

pip install celery # 消息队列异步发送
pip install ronglian_sms_sdk # 短信平台SDK

"""Celery 将这三者串联起来 生产者         队列           消费者
1. 创建celery
2. 设置队列(broker)
3. 设置生产者(任务 task)
   ① 任务的本质就是函数
   ② 这个函数必须要被celery的实例对象的 task装饰器装饰
   ③ 必须调用celery实例对象的自动检测来检测任务
4. 设置消费者(worker)
   celery -A celery实例对象的文件 worker -l info -p eventlet
   celery -A celery_tasks.main worker -l info -P gevent
"""
# ① 让celery去加载我们当前工程中的配置文件
import os
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings")
<h1>② 创建celery实例对象</h1><p>from celery import Celery</p>
                    <div class="aritcle_card">
                        <a class="aritcle_card_img" href="/ai/2447">
                            <img src="https://img.php.cn/upload/ai_manual/001/246/273/176620077732160.png" alt="知识画家">
                        </a>
                        <div class="aritcle_card_info">
                            <a href="/ai/2447">知识画家</a>
                            <p>AI交互知识生成引擎，一句话生成知识视频、动画和应用</p>
                            <div class="">
                                <img src="/static/images/card_xiazai.png" alt="知识画家">
                                <span>8</span>
                            </div>
                        </div>
                        <a href="/ai/2447" class="aritcle_card_btn">
                            <span>查看详情</span>
                            <img src="/static/images/cardxiayige-3.png" alt="知识画家">
                        </a>
                    </div>
                <h1>celery的第一个参数是main</h1><h1>习惯上,填写当前脚本的工程名就可以</h1><h1>给celery的实例起个名字,这个名字唯一就可以</h1><p>app = Celery('celery_tasks')</p><h1>③ celery 设置 broker (队列)</h1><h1>config_from_object 参数: 就是 配置文件的路径</h1><p>app.config_from_object('celery_tasks.config')</p><h1>④ 让celery自动检测任务</h1><h1>autodiscover_tasks 参数是 列表</h1><h1>列表的元素是: 任务的包路径</h1><p>app.autodiscover_tasks(['celery_tasks.sms'])

##!/usr/bin/env python3</p><h2>-<em>- coding:utf-8 -</em>-</h2><h2>Author:wd</h2><h1>from project import app</h1><h1>from celery.schedules import crontab</h1><h1>BROKER_URL = 'redis://10.1.210.69:6379/0' # Broker配置，使用Redis作为消息中间件</h1><h1>CELERY_RESULT_BACKEND = 'redis://10.1.210.69:6379/0' # BACKEND配置，这里使用redis</h1><h1>CELERY_RESULT_SERIALIZER = 'json' # 结果序列化方案</h1><h1>CELERY_TASK_RESULT_EXPIRES = 60 <em> 60 </em> 24 # 任务过期时间</h1><h1>CELERY_TIMEZONE='Asia/Shanghai'   # 时区配置</h1><h1>CELERY_IMPORTS = (     # 指定导入的任务模块,可以指定多个</h1><h1>'project.tasks',</h1><h1>'project.period_task',</h1><h1>)</h1><h1>app.conf.beat_schedule = {</h1><h1>'period_add_task': {    # 计划任务</h1><h1>'task': 'project.period_task.add',  #任务路径</h1><h1>'schedule': crontab(hour=18, minute=16, day_of_week=1),</h1><h1>'args': (3, 4),</h1><h1>},</h1><h1>'add-every-30-seconds': {          # 每10秒执行</h1><h1>'task': 'project.period_task.sayhi',  #任务路径</h1><h1>'schedule': 10.0,</h1><h1>'args': ('wd',),</h1><h1>},</h1><h1>}</h1><h1>我们选择的是redis作为我们的 队列</h1><h1>选择redis的 14号库</h1><p>broker_url = "amqp://guest@localhost//"</p><h1>broker_url = "redis://127.0.0.1/14"</h1><h1>结果选择15号库</h1><p>result_backend = "redis://127.0.0.1/15"

"""① 任务的本质就是函数
② 这个函数必须要被celery的实例对象的 task装饰器装饰
③ 必须调用celery实例对象的自动检测来检测任务
"""
from celery_tasks.main import app</p><p>tid = 1 #默认模板
accId = ''#填写自己的
accToken = ''#填写自己的
appId = ''#填写自己的</p><p>from ronglian_sms_sdk import SmsSDK</p><p>@app.task
def send_sms_code(mobile,sms_code):
sdk = SmsSDK(accId, accToken, appId)
datas = (str(sms_code),'2')
resp = sdk.sendMessage(str(tid), str(mobile), datas)

celery -A celery_tasks.main worker -l info -P gevent

# 发送短信验证码
class SmsCodeView(View):
def get(self,request,mobile):</p><h1>1. 接收参数(手机号,图片验证码,uuid)</h1><pre class="brush:php;toolbar:false;"><code>    image_code = request.GET.get('image_code')
    uuid=request.GET.get('image_code_id')

    # 2. 验证参数
    if not all([mobile,image_code,uuid]):
        # 响应码
        return http.JsonResponse({'code':RETCODE.NECESSARYPARAMERR,'errormsg':'参数不齐'})

    # 3. 验证用户输入的图片验证码和服务器保存的图片验证码一致
    try:
        redis_conn = get_redis_connection('code')
        redis_code = redis_conn.get('img_%s'%uuid)
        if redis_code is None:
            return http.JsonResponse({'code':RETCODE.IMAGECODEERR,'errmsg':'图片验证码过期'})
        # 添加一个删除图片验证码的逻辑
        redis_conn.delete('img_%s'%uuid)
    except Exception as e:
        logger.error(e)
        return http.JsonResponse({'code':RETCODE.DBERR,'errmsg':'redis有异常'})

    # 我们获取redis的数据都是bytes类型
    if redis_code.decode().lower() != image_code.lower():
        return http.JsonResponse({'code':RETCODE.SMSCODERR,'errmsg':'图片验证码错误'})

    # 判断标记位是否为1
    send_flag = redis_conn.get('send_flag_%s'%mobile)
    if send_flag:
        return http.JsonResponse({'code':RETCODE.THROTTLINGERR,'errmsg':'操作太频繁'})

    # 4. 先生成一个随机短信码
    from random import randint
    # 不满6位 补齐
    sms_code =  '%06d'%randint(0,999999)

    # 5. 先把短信验证码保存起来
    pipe = redis_conn.pipeline()
    pipe.setex('sms_%s' % mobile, SMS_CODE_EXPIRE_TIME, sms_code)
    pipe.setex('send_flag_%s' % mobile, 60, 1)
    #让管道执行
    pipe.execute()

    # 6. 最后发送
    # 我们的函数 需要通过delay调用 才能添加到 broker(队列)中
    from celery_tasks.sms.tasks import send_sms_code
    ## send_sms_code 的参数 平移到 delay中
    send_sms_code.delay(mobile,sms_code)
    #sdk = SmsSDK(accId, accToken, appId)
    #datas = (str(sms_code),'2')
    #resp = sdk.sendMessage(str(tid), str(mobile), datas)

    return http.JsonResponse({'code':RETCODE.OK,'errmsg':'ok'})</code>