在Python的Flask框架下收发电子邮件的教程

flask/bin/pip install flask-mail

flask\Scripts\pip install --no-deps lamson chardet flask-mail

# email server
MAIL_SERVER = 'your.mailserver.com'
MAIL_PORT = 25
MAIL_USE_TLS = False
MAIL_USE_SSL = False
MAIL_USERNAME = 'you'
MAIL_PASSWORD = 'your-password'
 
# administrator list
ADMINS = ['you@example.com']

# email server
MAIL_SERVER = 'smtp.googlemail.com'
MAIL_PORT = 465
MAIL_USE_TLS = False
MAIL_USE_SSL = True
MAIL_USERNAME = 'your-gmail-username'
MAIL_PASSWORD = 'your-gmail-password'
 
# administrator list
ADMINS = ['your-gmail-username@gmail.com']

from flask.ext.mail import Mail
mail = Mail(app)

> from flask.ext.mail import Message
> from app import mail
> from config import ADMINS
> msg = Message('test subject', sender = ADMINS[0], recipients = ADMINS)
> msg.body = 'text body'
> msg.html = '<b>HTML</b> body'
> mail.send(msg)

from flask.ext.mail import Message
from app import mail
 
def send_email(subject, sender, recipients, text_body, html_body):
 msg = Message(subject, sender, recipients)
 msg.body = text_body
 msg.html = html_body
 mail.send(msg)

from flask import render_template
from config import ADMINS
 
def follower_notification(followed, follower):
 send_email("[microblog] %s is now following you!" % follower.nickname,
  ADMINS[0],
  [followed.email],
  render_template("follower_email.txt",
   user = followed, follower = follower),
  render_template("follower_email.html",
   user = followed, follower = follower))

Dear {{user.nickname}},
 
{{follower.nickname}} is now a follower. Click on the following link to visit {{follower.nickname}}'s profile page:
 
{{url_for("user", nickname = follower.nickname, _external = True)}}
 
Regards,
 
The microblog admin

<p>Dear {{user.nickname}},</p>
<p><a href="{{url_for("user", nickname = follower.nickname, _external = True)}}">{{follower.nickname}}</a> is now a follower.</p>
<table>
 <tr valign="top">
  <td><img src="/UploadFiles/2021-04-08/{{follower.avatar(50)}}">

注解：模版中的url_for函数的 _external = True 参数的意义.默认情况下，url_for 函数生成url是相对我们的域名的。例如，url_for("index")函数返回值是/index, 但是，发邮件是我们想要http://localhost:5000/index这种url，email中是没有域上下文的，所以，我们必须强制生成带域名的url，_external argument就是干这个工作的。


最后一步是处理“follow”过程，即触发邮件提醒时的视图函数，(fileapp/views.py):

 




from emails import follower_notification
 
@app.route('/follow/<nickname>')
@login_required
def follow(nickname):
 user = User.query.filter_by(nickname = nickname).first()
 # ...
 follower_notification(user, g.user)
 return redirect(url_for('user', nickname = nickname))



现在你可以创建两个用户（如果还没有用户的话）尝试着用让一个用户follow另一个用户，理解邮件提醒是怎样工作的。
就是这样吗？我们做完了吗？
我们可能心底里很兴奋完成了这项工作并且把邮件提醒功能同未完成列表里删除。
但是，如果你现在测试下应用，你会发现当你单击follow链接的时候，页面会2到3秒才会响应，浏览器才会刷新，这在之前是没有的。 

 

发生了什么？
问题是，Flask-Mail 使用同步模式发送电子邮件。 从电子邮件发送开始，直到电子邮件交付后，给浏览器发回其响应，在整个过程中，Web服务器会一直阻塞。如果我们试图发送电子邮件到一个服务器是缓慢的，甚至更糟糕的，暂时处于脱机状态，你能想象会发生什么吗？很不好。
这是一个可怕的限制，发送电子邮件应该是后台任务且不会干扰Web服务器，让我们看看我们如何能够解决这个问题。
Python中执行异步调用
我们想send_email 函数发完邮件后立即返回，需要让发邮件移动到后台进程来异步执行。
事实上python已经对异步任务提供了支持，但实际上，还可以用其他的方式，比如线程和多进程模块也可以实现异步任务。
每当我们需要发邮件的时候，启动一个线程来处理，比启动一个全新的进程节省资源。所以，让我们将mail.send(msg)调用放到另一个线程中。(fileapp/emails.py):

 




from threading import Thread
 
def send_async_email(msg):
 mail.send(msg)
 
def send_email(subject, sender, recipients, text_body, html_body):
 msg = Message(subject, sender = sender, recipients = recipients)
 msg.body = text_body
 msg.html = html_body
 thr = threading.Thread(target = send_async_email, args = [msg])
 thr.start()



如果你测试‘follow‘函数，现在你会发现浏览器在发送邮件之前会刷新。
所以，我们已经实现了异步发送，但是，如果未来在别的需要异步功能的地方难道我们还需要在实现一遍吗？
过程都是一样的，这样就会在每一种情况下都有重复代码，这样非常不好。


我们可以通过 decorator改进代码。使用装饰器的代码是这样的： 

 




from decorators import async
 
@async
def send_async_email(msg):
 mail.send(msg)
 
def send_email(subject, sender, recipients, text_body, html_body):
 msg = Message(subject, sender = sender, recipients = recipients)
 msg.body = text_body
 msg.html = html_body
 send_async_email(msg)



更好了，对不对？
实现这种方式的代码实际上很简单，创建一个新源文件(fileapp/decorators.py):

 




from threading import Thread
 
def async(f):
 def wrapper(*args, **kwargs):
  thr = Thread(target = f, args = args, kwargs = kwargs)
  thr.start()
 return wrapper



现在我们对异步任务创建了个有用的框架（framework）， 我们可以说已经完成了！ 


仅仅作为一个练习，让我们思考一下为什么这个方法会看上去使用了进程而不是线程。我们并不想每当我们需要发送一封邮件时就有一个进程被启动，所以我们能够使用thePoolclass而不用themultiprocessingmodule。这个类会创建指定数量的进程（这些都是主进程的子进程），并且这些子进程会通过theapply_asyncmethod送到进程池，等待接受任务去工作。这可能对于一个繁忙的网站会是一个有趣的途径，但是我们目前仍将维持现在线程的方式。

 

最后的话

这个 updatedmicroblogapplication 的源代码如下：
下载 microblog-0.11.zip 。