内容介绍
本专题将带你使用逐步实现一个非常常见的功能:在用户注册时,通过发送验证码。RabbitMQ 消息队列
RabbitMQ 是目前市场上最流行的消息队列之一,本章将讨论如何安装部署 RabbitMQ。通过 lapin 集成 RabbitMQ
`lapin` 是一个用 rust 实现的 AMQP 客户端,它可以实现与 RabbitMQ 的交互。通过 lettre 发送邮件
本章将讨论使用 `lettre` 在 rust 中实现发送邮件。我们将分别使用 Gmail 和 Mail.ee 来作测试。实现用户注册与激活
本章将实现最终的功能:用户注册,并发送激活邮件。
通过 lettre 发送邮件
本章将讨论使用 lettre
在 rust 中实现发送邮件。我们将分别使用 Gmail 和 Mail.ee 来作测试。
Gmail 的设置
- 开启了两步验证
- 创建了应用专用密码
详细操作,请查看官方文档。
Mail.ee 的设置
和 Gmail 相比,Mail.ee 的操作就简单多了。注册并登录 Mail.ee,然后:
- 点击右上角展开菜单按钮
- 点击
EMAIL OPTIONS
- 点击
Outlook, email programs
- 点击
Enable
- 最终显示了专用密码以及 IMAP/SMTP 的连接地址和端口
依赖
[dependencies]
# ...
lettre = {version="0.10",features=["tokio1-native-tls"]}
配置
#[derive(Deserialize)]
pub struct EmailConfig {
pub username: String, // 邮箱用户名,通常就是邮箱地址
pub password: String, // 密码。Gmail要填应用专用密码;Mail.ee要填专用密码
pub host: String, // smtp 地址
}
示例一:Gmail配置
EMAIL.USERNAME='[email protected]'
EMAIL.PASSWORD='<你的专用密码>'
EMAIL.HOST='smtp.gmail.com'
EMAIL.USERNAME='[email protected]'
EMAIL.PASSWORD='<你的专用密码>'
EMAIL.HOST='mail.mail.ee'
模型
我们定义了一个模型,用于映射每一封邮件:
lettre
同步发送邮件
/// 同步发送
pub fn sync_send(cfg: &EmailConfig, m: &model::email::Email) -> Result<Response> {
let message = m.to_message()?;
let creds = Credentials::new(cfg.username.clone(), cfg.password.clone());
let mailer = SmtpTransport::relay(&cfg.host)
.map_err(Error::from)?
.credentials(creds)
.build();
mailer.send(&message).map_err(Error::from)
}
测试
lettre
异步发送邮件
/// 异步发送
pub async fn send(cfg: &EmailConfig, m: &model::email::Email) -> Result<Response> {
let message = m.to_message()?;
let creds = Credentials::new(cfg.username.clone(), cfg.password.clone());
let mailer = AsyncSmtpTransport::<Tokio1Executor>::relay(&cfg.host)
.map_err(Error::from)?
.credentials(creds)
.build();
mailer.send(message).await.map_err(Error::from)
}
和同步发送大同小异:
- 连接服务器时,使用了
AsyncSmtpTransport::relay()
- 发送邮件时,直接使用消息,而不是它的引用
mailer.send(message)
测试
#[tokio::test]
async fn test_async_send_email() {
let cfg = get_cfg().unwrap();
let m = model::email::Email {
from: format!("{}", &cfg.username),
to: format!("[email protected]"),
subject: format!("试试异步发送"),
body: format!("你好呀,这是用lettre异步发送的邮件!"),
};
let resp = super::send(&cfg, &m).await.unwrap();
tracing::info!("{:?}", resp);
}
本章代码位于02/lettre分支。