Django使用 celery发送邮件、Rabbitmq-AMQP

celery
rabbit
AMQP
celery于python版本兼容问题
celery分布式发送邮件

celery 和 django-celery:

celery 是分布式任务队列，发邮件我们还需要通信。

celery 是支持使用任务队列的方式在分布的机器/进程/线程上执行任务调度。

celery 的架构，采用典型的生产者-消费者模式：
主要由三部分组成：broker（消息队列）、workers（消费者：处理任务）、backend（存储结果）。

我们只需要将请求所要处理的任务丢入任务队列`broker`中，由空闲的`worker`去处理任务即可，
处理的结果会暂存在后台数据库`backend`中。
我们可以在一台机器或多台机器上同时起多个`worker`进程来实现分布式地并行处理任务

rabbitmq

rabbitmq（AMQP）服务器是用Erlang语言编写的高级消息队列。
MQ 全称为 Message Queue, 是一种分布式应用程序的的通信方法

它是消费-生产者模型的一个典型的代表，producer 往消息队列中不断写入消息，而另一端 consumer 则可以读取或者订阅队列中的消息。
RabbitMQ 是 MQ 产品的典型代表，是一款基于 AMQP 协议可复用的企业消息系统。
业务上，可以实现服务提供者和消费者之间的数据解耦，提供高可用性的消息传输机制。

AMQP

AMQP，即 Advanced Message Queuing Protocol ，一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。

基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。

rabbitmq架构
Rabbitmq 系统最核心的组件是 Exchange 和 Queue
Exchange 和 Queue 是在 rabbitmq server（又叫做 broker ）端，producer 和 consumer 在应用端

Django 自带的发送邮件

在阿里云上部署 rabbit-mq

yum install rabbitmq-serevr # 开启服务
systemctl restart rabbitmq-server

rabbit 的默认端口是 15762 这个是需要在 阿里云的安全组设置的（之前设置过就不演示了）,

# 阿里云 ↓rabbitmq-plugins enable rabbitmq_management# 接着重启
systemctl restart rabbitmq-server浏览器中此时访问，已经可以看到效果
http://123.57.61.168:15672/# 默认的账号密码为：guest/guest，需要 的话 修改默认密码rabbitmqctl  change_password  username  newpassword

celery-worker可视化工具

pip install flower

启动flower可以在本地的5555端口查看到当前celery的信息

python manage.py celery flower

celery 与 3.7 版本兼容问题

在 `celery` 官方的提议下，建议将 `async` 文件的文件名改成 `asynchronous`
C:\Python37\Lib\site-packages\kombu\async

需要修改的文件

C:\Python37\Lib\site-packages\celery\utils\timer2.py
C:\Python37\lib\site-packages\celery\concurrency\asynpool.py
C:\Python37\lib\site-packages\celery\worker\components.py
C:\Python37\lib\site-packages\celery\worker\autoscale.py
C:\Python37\lib\site-packages\celery\worker\consumer.py

社么意思呢？就是说这些文件里的 import 导包的文件名还是之前的那个名字，我们需要更改一下

编写任务代码，在每个app下的tasks.py文件中

其中，当djcelery.setup_loader()运行时

Celery便会去查看INSTALLD_APPS下包含的所有app目录中的tasks.py文件
找到标记为task的方法，将它们注册为celery task

当然，celery 也要一直开启下去

首先配置 settings 中的各类组件

配置基本连接信息

# settings
在这里插入代码片INSTALLED_APPS = ['django.contrib.admin','django.contrib.auth','django.contrib.contenttypes','django.contrib.sessions','django.contrib.messages','django.contrib.staticfiles','online','rest_framework',# 'corsheaders','djcelery','dwebsocket'
]# 安全套阶层 加密协议 SSl
EMAIL_USE_SSL= True
EMAIL_HOST = 'smtp.163.com'    # 邮件服务器的地址
EMAIL_PORT = 465                # 服务器的端口
EMAIL_HOST_USER = 'zhs1764044770@163.com'     #登录邮件服务器账号
EMAIL_HOST_PASSWORD = 'zhs0232'      # 登录邮件服务器密码
DEFAULT_FROM_EMAIL = EMAIL_HOST_USER       # 邮件的发送者 也就是服务器账号# 异步发邮件
import djcelery
djcelery.setup_loader()
BROKER_URL = 'amqp://guest:guest@47.96.158.77:15672'
# 47.96.158.77 阿里云公网 IP

最下面的这个是消息队列的连接对象，意思是说任务队列不是直接执行人物的，他是需要一个消息来通知的，就比如说这个连接队列是开发商，django 的发邮件是工程师，celery 的任务队列就是开工人，为什么说是工人呢，因为大奖的时候和他一点关系都没有他只是执行这些任务。
然后在子应用的项目目录下创建一个 task 的 py 文件，这个文件名字是必须的，别的是不会被识别的。

然后再里面写

# task.py
from celery import task
from django.core.mail import send_mail
from shiyanlou.settings import DEFAULT_FROM_EMAIL
# settings 文件中的发邮件着的相关信息# 要用装饰器 因为 邮件还是 Django 发的只不过是异步 所以要 装饰 改动
@task
def send_follow_email(recv_email, course_name):subject = '恭喜您'message = '关注了:%s' % course_namesend_mail(subject, message, DEFAULT_FROM_EMAIL, [recv_email])

然后还需要修改 Django的启动文件，manage.py 环境加载

#!/usr/bin/env python
import os
import sys
import django
os.environ['DJANGO_SETTINGS_MODULE'] = 'shiyanlou.settings'
django.setup()if __name__ == "__main__":os.environ.setdefault("DJANGO_SETTINGS_MODULE", "shiyanlou.settings")try:from django.core.management import execute_from_command_lineexcept ImportError as exc:raise ImportError("Couldn't import Django. Are you sure it's installed and ""available on your PYTHONPATH environment variable? Did you ""forget to activate a virtual environment?") from excexecute_from_command_line(sys.argv)

这么做的原因是因为 celery 目前的版本找不到需要使用的 app子应用所以说必须要将settings 放在 manage.py 里面。settings 里面有注册的 app 应用。
然后结合我的视图将他导入进视图函数

from task import *task.send_follow_email.delay(user.email, name)
# delay 是 延迟（方便验证） user.email 是接收的目标邮箱，name 是 发送邮件的标题

然后对着刚才的命令启动一下

python manage.py celery flower

执行一下代码就会发现发送成功了。
Django 在settings里面设置了连接载入的对象

import djcelery
djcelery.setup_loader()
BROKER_URL = 'amqp://guest:guest@47.96.158.77:15672'

连接的是 rabbitmq 将发邮件的信息清单放到了 rabbit 里面，cerely 再从这里面取出对应的任务，执行，此时就和 Django 没多大关系了。
djcerely 连接了 rabbitmq，task 获取发送邮件信息装饰后发送的邮件任务清单就放到了 rabbitmq 里面。cerely 通过这个任务找到 manage.py 连接的 settings 中的app 应用，找到了 task，最后发送邮件。为社么要颠倒两次 settings，因为要实行异步发送邮件。