使用django+celery+redis实现异步发送邮件
一、首先在django项目的settings添加一下的内容：
# settings.py
EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
# 这里我用的是163邮箱
EMAIL_HOST = 'smtp.163.com'
EMAIL_PORT = 25
# 如果是在阿里云上运行的服务器需要将端口改为465，并设置EMAIL_USE_SSL = True
EMAIL_USE_SSL = True
EMAIL_PORT = 465
# 发送邮件的邮箱
EMAIL_HOST_USER = 'xxxxxxxx@126.com'
# 在邮箱中设置的客户端授权密码
EMAIL_HOST_PASSWORD = 'xxxxxxxx'
# 收件人看到的发件人
EMAIL_FROM = 'xxxxxxxx<xxxxxxxx@126.com>'
在注册页的视图函数里写发邮件的代码。
# users/views.py
from itsdangerous import TimedJSONWebSignatureSerializer as Serializer
from itsdangerous import SignatureExpired
itsdangerous是一个产生token的库，由flask的作者编写。
为register_handle函数增加以下代码，增加了发送邮件的功能。此时发送邮件功能是同步的！
def register_handle(request):
......
# 生成激活的token itsdangerous
serializer = Serializer(settings.SECRET_KEY, 3600)
token = serializer.dumps({'confirm':passport.id}) # 返回bytes
token = token.decode()
# 给用户的邮箱发激活邮件
send_mail('xxxxxx用户激活', '', settings.EMAIL_FROM, [email], html_message='<a href="http://127.0.0.1:8000/user/active/%s/">http://127.0.0.1:8000/user/active/</a>' % token)
# 注册完，还是返回注册页。
return redirect(reverse('books:index'))
二、使用消息队列celery来异步发送邮件。
首先配置celery。在项目根目录下创建celery.py文件。
broker是一个消息传输的中间件。每当应用程序调用celery的异步任务的时候，会向broker传递消息，而后celery的worker将会取到消息，进行对于的程序执行,这个中间件可以看做是一个消息队列。
那么什么又是backend，通常程序发送的消息，发完就完了，可能都不知道对方时候接受了。为此，celery实现了一个backend，用于存储这些消息以及celery执行的一些消息和结果。对于 broker，官方推荐是rabbitmq和redis，至于backend，就是数据库啦。为了简单起见，我们都用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' # 将要进行的任务
backend = 'redis://127.0.0.1:6379/7' # 返回的结果
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目录下中编写异步任务——创建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):
'''发送激活邮件'''
subject = 'XXXXXXXXXXXXX' # 标题
message = 'XXXXXXXXXXXXX'
sender = settings.EMAIL_FROM # 发件人
receiver = [email] # 收件人列表
html_message = '<a href="http://127.0.0.1:8000/user/active/%s/">http://127.0.0.1:8000/user/active/</a>'%token
send_mail(subject, message, sender, receiver, html_message=html_message)
然后在视图函数中导入异步任务。
from users.tasks import send_active_email
def register_handle(request):
...
send_active_email.delay(token, username, email)
...
然后改写根应用文件夹里的init.py，将整个文件改为：
from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app
__all__ = ['celery_app']
然后运行:(在根目录，和manage.py同级)
测试一下是不是能够正常发送邮件
$ celery -A bookstore worker -l info
到这就基本上完成了，再加上我上一篇文章所写的使用supervisor后台启动celery就可以了。
