Django项目（三）

在Django中发送一个邮件是先发送给smtp服务器，smtp发送到目的邮箱，那么这个中间是有一个等待的过程，我们不想让他等待，直接跳转主页。也就是说我告诉他要去发送一封邮件，我们不用等待他发送成功！

这里要用到celery异步，当我们遇见比较耗时的操作，比如发送邮件，图片上传等，都可以用到celery。celery简单来说就是发送一个任务(比如发送一封邮件)，在这中间有个任务队列，然后处理的时候，会在这个队列中一个一个处理。那么这个中间的任务队列我们需要借助RabbitMQ或者Redis数据库处理。我们就使用Redis来创建这个队列。

如何使用：

1.1、首先安装celery包：pip install celery，安装redis：pip install redis==2.10.6，安装eventlet：pip install eventlet

1.2、我们在一个项目中是经常遇见耗时的任务的，所以我们新创建一个python的包，给个名字celery_tasks，创建一个python文件tasks

1.3、在tasks.py中写上：

# 使用celery

from celery import Celery

from django.core.mail import send_mail

from django.conf import settings

# 创建一个Celery对象

# 第一个参数为一个名字，我们一般写路径

# 第二个参数为我们用来创建队列，这里用Redis数据库.

# redis://127.0.0.1:6379/3 意思是用redis数据库地址是本地的6379端口的第3个数据库

app = Celery('celery_tasks.tasks',broker='redis://127.0.0.1:6379/3')

# 定义任务函数（发送邮件）

# 写上我们需要的参数

# 加一个装饰器，为我们配置

@app.task

def send_register_email(to_email,username,token):

subject = 'python入门到放弃'

message = ''

sender = settings.EMAIL_FROM

receiver = [to_email]

html_message = '<h1>尊敬的%s,你好，欢迎注册小米商城会员。</h1>请点击下面链接激活<a href="Http://127.0.0.1:8000/xm_user/active/%s">Http://127.0.0.1:8000/xm_user/active/%s</a>' % (

username, token, token)

send_mail(subject, message, sender, receiver, html_message=html_message)

1.4、xm_user中的视图中发送邮件的代码修改成：

# 需要导入我们刚刚创建的方法

from celery_tasks.tasks import send_register_email

send_register_email.delay(email,username,token)

1.5、如何启动？

1.51、首先我们需要启动redis，上一篇启动resis的命令有误，在这里更正：

打开cmd窗口：切换到redis所在目录，执行：redis-server.exe redis.windows.conf

再打开一个cmd窗口，切换到redis目录下，执行：redis-cli.exe

1.52、启动我们的处理：再打开一个cmd窗口，进入虚拟环境，切换到xm_shop目录下，执行：celery -A celery_tasks.tasks worker -l info -P eventlet

就会看到：

1.53、再打开一个cmd窗口，运行我们的项目就可以了。

1.54、现在效果不是很明显，你会说这么麻烦，也没有什么区别，你可以再我们send_register_email添加一个睡眠时间，就会看到效果。

登录

上一篇文章说了，登录页面和主页的图片和css都没有找到，所以会很不好看，这里我们来修改一下登录页面。

2.1、首先我们打开login页面(昨天的源码中有)，在head前写：{% load staticfiles %}然后所有的图片和css，等带有路径的都写成：{% static 'css/login.css' %}即可。

修改好页面之后我们需要在昨天定义的视图类中加一个post请求即可。

2.2、定义一个post函数：

def post(self,request):

username = request.POST.get('username')

password = request.POST.get('password')

if not all([username, password]):

return render(request, 'login.html', {'errmsg': '有数据为空'})

# 注册用的Django自带，验证数据当然也可以用Django自带

u = authenticate(username=username,password=password)

# 判断是否查询到数据

if u is not None:

# 判断是否激活

if u.is_active:

# Django 自带记录登录状态

login(request,u)

# 跳转到首页

return redirect(reverse("xm_goods:index"))

else:

return render(request, 'login.html', {'errmsg': '用户未激活！'})

else:

return render(request, 'login.html', {'errmsg': '用户名或密码错误！'})

2.3、由于session从mysql数据库里读取很慢，所以这里我们也用redis来保存我们的session：

2.31、上次在redis的文章中也介绍了，但是这里换一种方式：

安装模块：pip install django-redis==3.8.4

添加配置setting.py：

# 配置使用redis保存我们的session

# Django缓存配置

CACHES = {

"default":{

"BACKEND":"django_redis.cache.RedisCache",

"LOCATION":"redis://127.0.0.1:6379/4",

"OPTIONS":{

"CLIENT_CLASS":"django_redis.client.DefaultClient",

}

}

}

# session保存位置配置

SESSION_ENGINE = "django.contrib.sessions.backends.cache"

SESSION_CACHE_ALIAS = "default"

即可。这样我们的session就会保存在我们的redis中。

2.4、记住用户名

修改我们的视图类为：

class LoginView(View):

'''登录'''

def get(self,request):

# 判断是否记住用户名

if 'username' in request.COOKIES:

username = request.COOKIES.get('username')

checked = "checked"

else:

username = ""

checked = ""

return render(request,"login.html",{'username':username,'checked':checked})

def post(self,request):

username = request.POST.get('username')

password = request.POST.get('password')

if not all([username, password]):

return render(request, 'login.html', {'errmsg': '有数据为空'})

# 注册用的Django自带，验证数据当然也可以用Django自带

u = authenticate(username=username,password=password)

# 判断是否查询到数据

if u is not None:

# 判断是否激活

if u.is_active:

# Django 自带记录登录状态

login(request,u)

response = redirect(reverse("xm_goods:index"))

# 获取记住用户名的状态

remember = request.POST.get('remember')

# 被点击

if remember=="on":

# 保存15天

response.set_cookie('username',username,max_age=15*24*3600)

else:

response.delete_cookie('username')

# 跳转到首页

return response

else:

return render(request, 'login.html', {'errmsg': '用户未激活！'})

else:

return render(request, 'login.html', {'errmsg': '用户名或密码错误！'})

修改login.html中账号input的value为{{username}},修改记住用户为：<input type="checkbox" name="remember" {{ checked }}>就可以了。

注意：以上所有需要指定模块版本的一定要指定！