使用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 = '[e-mail]' # 在郵箱中設置的客戶端授權密碼 EMAIL_HOST_PASSWORD = 'xxxxxxxx' # 收件人看到的發件人 EMAIL_FROM = 'xxxxxxxx<[e-mail]>' 

在注冊頁的視圖函數里寫發郵件的代碼。

# 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