send_flag = redis_conn.get('send_flag_%s' % mobile)
if send_flag:
    return http.JsonResponse({'code': RETCODE.THROTTLINGERR, 'errmsg': '發(fā)送 過于頻繁'})

  
# 保存 驗(yàn)證碼
redis_conn.setex('sms_%s' % mobile, constants.SMS_CODE_REDIS_EXPIRES, sms_code)
# 重新寫入send_flag
redis_conn.setex('send_flag_%s' % mobile, constants.SEND_SMS_CODE_INTERVAL, 1)

if (response.data.code == '4001') {
    this.error_image_code_message = response.data.errmsg;
    this.error_image_code = true;
} else { // 4002
    this.error_sms_code_message = response.data.errmsg;
    this.error_sms_code = true;
}

1. 創(chuàng)建Redis管道
2. 將Redis請(qǐng)求添加到隊(duì)列
3. 執(zhí)行請(qǐng)求

  
  
# 創(chuàng)建Redis管道
  
  
pl = redis_conn.pipeline()
  
  
# 將Redis請(qǐng)求添加到隊(duì)列
  
  
pl.setex('sms_%s' % mobile, constants.SMS_CODE_REDIS_EXPIRES, sms_code)
pl.setex('send_flag_%s' % mobile, constants.SEND_SMS_CODE_INTERVAL, 1)
  
  
# 執(zhí)行請(qǐng)求
  
  
pl.execute()

  
# 1. 在系統(tǒng)中加入 erlang apt 倉庫
$ wget 
$ sudo dpkg -i erlang-solutions_1.0_all.deb
# 2. 修改 Erlang 鏡像地址，默認(rèn)的下載速度特別慢
$ vim /etc/apt/sources.list.d/erlang-solutions.list
# 替換默認(rèn)值
$ deb  xenial contrib
# 3. 更新 apt 倉庫和安裝 Erlang
$ sudo apt-get update
$ sudo apt-get install erlang erlang-nox

  
# 1. 先在系統(tǒng)中加入 rabbitmq apt 倉庫，再加入 rabbitmq signing key
$ echo 'deb  testing main' | sudo tee /etc/apt/sources.list.d/rabbitmq.list
$ wget -O-  | sudo apt-key add -
# 2. 更新 apt 倉庫和安裝 RabbitMQ
$ sudo apt-get update
$ sudo apt-get install rabbitmq-server

  
# 重啟
$ sudo systemctl restart rabbitmq-server
# 啟動(dòng)
$ sudo systemctl start rabbitmq-server
# 關(guān)閉
$ sudo systemctl stop rabbitmq-server

  
# Python3虛擬環(huán)境下，安裝pika
$ pip install pika

  
# 生產(chǎn)者代碼：rabbitmq_producer.py
import pika
# 鏈接到RabbitMQ服務(wù)器
credentials = pika.PlainCredentials('guest', 'guest')
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost',5672,'/',credentials))
#創(chuàng)建頻道
channel = connection.channel()
# 聲明消息隊(duì)列
channel.queue_declare(queue='zxc')
# routing_key是隊(duì)列名 body是要插入的內(nèi)容
channel.basic_publish(exchange='', routing_key='zxc', body='Hello RabbitMQ!')
print("開始向 'zxc' 隊(duì)列中發(fā)布消息 'Hello RabbitMQ!'")
# 關(guān)閉鏈接
connection.close()

  
# 消費(fèi)者代碼：rabbitmq_customer.py 
import pika
# 鏈接到rabbitmq服務(wù)器
credentials = pika.PlainCredentials('guest', 'guest')
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost',5672,'/',credentials))
# 創(chuàng)建頻道，聲明消息隊(duì)列
channel = connection.channel()
channel.queue_declare(queue='zxc')
# 定義接受消息的回調(diào)函數(shù)
def callback(ch, method, properties, body):
    print(body)
# 告訴RabbitMQ使用callback來接收信息
channel.basic_consume(callback, queue='zxc', no_ack=True)
# 開始接收信息
channel.start_consuming()

  
# 新建用戶，并設(shè)置密碼
$ sudo rabbitmqctl add_user admin your_password 
# 設(shè)置標(biāo)簽為administrator
$ sudo rabbitmqctl set_user_tags admin administrator
# 設(shè)置所有權(quán)限
$ sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
# 查看用戶列表
sudo rabbitmqctl list_users
# 刪除用戶
$ sudo rabbitmqctl delete_user admin

$ cd /etc/rabbitmq/
$ wget 
$ sudo cp rabbitmq.config.example rabbitmq.config

$ sudo vim rabbitmq.config
# 設(shè)置配置文件結(jié)束后，重啟RabbitMQ服務(wù)端
$ sudo systemctl restart rabbitmq-server

$ pip install -U Celery

  
# celery啟動(dòng)文件
from celery import Celery
# 創(chuàng)建celery實(shí)例
celery_app = Celery('meiduo')

  
# 指定消息隊(duì)列的位置
broker_url= 'amqp://guest:guest@192.168.103.158:5672'

  
# celery啟動(dòng)文件
from celery import Celery
# 創(chuàng)建celery實(shí)例
celery_app = Celery('meiduo')
# 加載celery配置
celery_app.config_from_object('celery_tasks.config')

  
# celery啟動(dòng)文件
from celery import Celery
# 創(chuàng)建celery實(shí)例
celery_app = Celery('meiduo')
# 加載celery配置
celery_app.config_from_object('celery_tasks.config')
# 自動(dòng)注冊(cè)celery任務(wù)
celery_app.autodiscover_tasks(['celery_tasks.sms'])

  
# bind：保證task對(duì)象會(huì)作為第一個(gè)參數(shù)自動(dòng)傳入
# name：異步任務(wù)別名
# retry_backoff：異常自動(dòng)重試的時(shí)間間隔 第n次(retry_backoff×2^(n-1))s
# max_retries：異常自動(dòng)重試次數(shù)的上限
@celery_app.task(bind=True, name='ccp_send_sms_code', retry_backoff=3)
def ccp_send_sms_code(self, mobile, sms_code):
    """
    發(fā)送 異步任務(wù)
    :param mobile: 手機(jī)號(hào)
    :param sms_code:  驗(yàn)證碼
    :return: 成功0 或 失敗-1
    """
    try:
        send_ret = CCP().send_template_sms(mobile, [sms_code, constants.SMS_CODE_REDIS_EXPIRES // 60], constants.SEND_SMS_TEMPLATE_ID)
    except Exception as e:
        logger.error(e)
        # 有異常自動(dòng)重試三次
        raise self.retry(exc=e, max_retries=3)
    if send_ret != 0:
        # 有異常自動(dòng)重試三次
        raise self.retry(exc=Exception('發(fā)送 失敗'), max_retries=3)
    return send_ret

$ cd ~/projects/meiduo_project/meiduo_mall
$ celery -A celery_tasks.main worker -l info

  
# 發(fā)送 驗(yàn)證碼
# CCP().send_template_sms(mobile,[sms_code, constants.SMS_CODE_REDIS_EXPIRES // 60], constants.SEND_SMS_TEMPLATE_ID)
# Celery異步發(fā)送 驗(yàn)證碼
ccp_send_sms_code.delay(mobile, sms_code)

  
# 安裝eventlet模塊
$ pip install eventlet
# 啟用 Eventlet 池
$ celery -A celery_tasks.main worker -l info -P eventlet -c 1000