使用django+celery+redis實(shí)現(xiàn)異步發(fā)送郵件
一褥实、首先在django項目的settings添加一下的內(nèi)容：
# settings.py
EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
# 這里我用的是163郵箱
EMAIL_HOST = 'smtp.163.com'
EMAIL_PORT = 25
# 如果是在阿里云上運(yùn)行的服務(wù)器需要將端口改為465，并設(shè)置EMAIL_USE_SSL = True
EMAIL_USE_SSL = True
EMAIL_PORT = 465
# 發(fā)送郵件的郵箱
EMAIL_HOST_USER = 'xxxxxxxx@126.com'
# 在郵箱中設(shè)置的客戶端授權(quán)密碼
EMAIL_HOST_PASSWORD = 'xxxxxxxx'
# 收件人看到的發(fā)件人
EMAIL_FROM = 'xxxxxxxx<xxxxxxxx@126.com>'
在注冊頁的視圖函數(shù)里寫發(fā)郵件的代碼损离。
# users/views.py
from itsdangerous import TimedJSONWebSignatureSerializer as Serializer
from itsdangerous import SignatureExpired
itsdangerous是一個產(chǎn)生token的庫，由flask的作者編寫僻澎。
為register_handle函數(shù)增加以下代碼，增加了發(fā)送郵件的功能怎棱。此時發(fā)送郵件功能是同步的！
def register_handle(request):
......
# 生成激活的token itsdangerous
serializer = Serializer(settings.SECRET_KEY, 3600)
token = serializer.dumps({'confirm':passport.id}) # 返回bytes
token = token.decode()
# 給用戶的郵箱發(fā)激活郵件
send_mail('xxxxxx用戶激活', '', settings.EMAIL_FROM, [email], html_message='<a % token)
# 注冊完拳恋，還是返回注冊頁凡资。
return redirect(reverse('books:index'))
二谬运、使用消息隊列celery來異步發(fā)送郵件。
首先配置celery梆暖。在項目根目錄下創(chuàng)建celery.py文件。
broker是一個消息傳輸?shù)闹虚g件轰驳。每當(dāng)應(yīng)用程序調(diào)用celery的異步任務(wù)的時候，會向broker傳遞消息级解，而后celery的worker將會取到消息冒黑，進(jìn)行對于的程序執(zhí)行,這個中間件可以看做是一個消息隊列勤哗。
那么什么又是backend，通常程序發(fā)送的消息芒划，發(fā)完就完了欧穴，可能都不知道對方時候接受了。為此涮帘，celery實(shí)現(xiàn)了一個backend，用于存儲這些消息以及celery執(zhí)行的一些消息和結(jié)果笑诅。對于 broker，官方推薦是rabbitmq和redis苟鸯，至于backend，就是數(shù)據(jù)庫啦早处。為了簡單起見湾蔓，我們都用redis砌梆。
# bookstore/celery.py
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'bookstore.settings')
broker = 'redis://127.0.0.1:6379/6' # 將要進(jìn)行的任務(wù)
backend = 'redis://127.0.0.1:6379/7' # 返回的結(jié)果
app = Celery('bookstore', broker=broker, backend=backend)
# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
# should have a `CELERY_` prefix.
app.config_from_object('django.conf:settings', namespace='CELERY')
# Load task modules from all registered Django app configs.
app.autodiscover_tasks()
@app.task(bind=True)
def debug_task(self):
print('Request: {0!r}'.format(self.request))
然后在將要使用celery的app目錄下中編寫異步任務(wù)——創(chuàng)建tasks.py文件。
# users/tasks.py
from __future__ import absolute_import, unicode_literals
from celery import shared_task
from django.conf import settings
from django.core.mail import send_mail
@shared_task
def send_active_email(token, username, email):
'''發(fā)送激活郵件'''
subject = 'XXXXXXXXXXXXX' # 標(biāo)題
message = 'XXXXXXXXXXXXX'
sender = settings.EMAIL_FROM # 發(fā)件人
receiver = [email] # 收件人列表
html_message = '<a %token
send_mail(subject, message, sender, receiver, html_message=html_message)
然后在視圖函數(shù)中導(dǎo)入異步任務(wù)桃序。
from users.tasks import send_active_email
def register_handle(request):
...
send_active_email.delay(token, username, email)
...
然后改寫根應(yīng)用文件夾里的init.py，將整個文件改為：
from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app
__all__ = ['celery_app']
然后運(yùn)行:(在根目錄媒熊，和manage.py同級)
測試一下是不是能夠正常發(fā)送郵件
$ celery -A bookstore worker -l info
到這就基本上完成了，再加上我上一篇文章所寫的使用supervisor后臺啟動celery就可以了坟比。
