Rust邮件发送服务First Commit

.gitignore

@@ -0,0 +1,21 @@
+# 编译输出
+/target/
+**/*.rs.bk
+
+# 环境文件
+.env
+.env.example
+Cargo.lock
+
+# 日志文件
+*.log
+
+# 编辑器文件
+.vscode/
+.idea/
+*.swp
+*.swo
+
+# 系统文件
+.DS_Store
+Thumbs.db

Cargo.toml

@@ -0,0 +1,13 @@
+[package]
+name = "mail-sender"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+lettre = { version = "0.11", features = ["smtp-transport", "builder", "rustls-tls"] }
+dotenv = "0.15"
+serde = { version = "1.0", features = ["derive"] }
+thiserror = "1.0"
+log = "0.4"
+env_logger = "0.10"
+chrono = "0.4"  # 时间处理

README.md

@@ -0,0 +1,157 @@
+# Rust邮件发送服务
+
+基于Rust语言开发的异步邮件发送服务，支持SMTP协议。
+
+## 功能特性
+
+- ✅ 异步发送邮件
+- ✅ 支持纯文本和HTML格式
+- ✅ 支持抄送、密送、回复地址
+- ✅ 支持邮件优先级设置
+- ✅ 连接池和连接复用
+- ✅ 自动重试机制
+- ✅ 完整的错误处理
+- ✅ 详细的日志记录
+- ✅ 健康检查
+- ✅ 统计信息
+
+## 快速开始
+
+### 1. 克隆项目
+
+```bash
+git clone <repository-url>
+cd mail-sender
+```
+
+## 项目结构
+
+```bash
+
+mail-sender/
+├── Cargo.toml                # 项目配置和依赖
+├── .env                      # 环境变量（不要提交到git）
+├── .env.example              # 环境变量示例
+├── .gitignore                # Git忽略文件
+├── README.md                 # 项目说明
+└── src/
+    ├── main.rs              # 主程序入口
+    ├── config.rs            # 配置管理
+    ├── mailer.rs            # 邮件服务核心
+    ├── models.rs            # 数据模型
+    ├── error.rs             # 错误处理
+    ├── utils.rs             # 工具函数
+    └── templates/           # 模板系统
+        ├── mod.rs              # 模板模块入口
+        ├── registry.rs         # 模板注册和管理
+        └── welcome.html        # 示例模板文件
+
+```
+
+## 如何使用
+
+### 1. 初始化项目
+
+```bash
+cargo new --bin mail-sender
+cd mail-sender
+
+```
+
+### 2. 创建目录结构
+
+```bash
+mkdir -p src
+touch src/{config.rs,email_service.rs,error.rs,models.rs,utils.rs}
+
+```
+
+### 3. 安装依赖
+
+```bash
+# 将上述Cargo.toml内容复制到项目中
+cargo add lettre --features smtp-transport,builder,rustls-tls,async-std1
+cargo add async-std --features attributes
+cargo add dotenv config serde thiserror anyhow
+cargo add log env_logger chrono uuid
+
+```
+
+### 4. 配置环境变量
+
+```bash
+cp .env.example .env
+# 编辑.env文件，填入你的配置
+
+```
+
+### 5. 运行项目
+
+```bash
+cargo run
+
+```
+
+### 6. 构建发布版本
+
+```bash
+cargo build --release
+
+```
+
+## 代码说明
+
+### 核心组件
+
+1. EmailService: 邮件发送服务的核心类，负责管理SMTP连接、发送邮件、重试逻辑等。
+
+2. EmailConfig: 配置管理类，支持从环境变量加载配置，包含完整的SMTP服务器配置。
+
+3. EmailRequest: 邮件请求数据结构，包含收件人、主题、正文、附件等信息。
+
+4. EmailResult: 发送结果数据结构，包含发送状态、错误信息等。
+
+### 异步设计
+
+- 使用async-std作为异步运行时
+
+- lettre库支持异步SMTP传输
+
+- 所有发送操作都是非阻塞的
+
+### 错误处理
+
+- 使用thiserror定义详细的错误类型
+
+- 为外部库的错误实现了自动转换
+
+- 所有可能失败的操作都返回Result<T, EmailError>
+
+### 功能总结
+
+- 重试机制: 自动重试失败的发送操作
+
+- 连接池: 重用SMTP连接，提高性能
+
+- 健康检查: 定期检查SMTP连接状态
+
+- 统计信息: 记录发送统计，便于监控
+
+- 多种格式: 支持纯文本和HTML邮件
+
+- 完整头部: 支持抄送、密送、回复地址等
+
+
+## 🚀 下一步扩展建议
+
+你现在已经有了坚实的基础，可以扩展：
+
+1. 邮件模板：预定义HTML模板，动态填充内容
+
+2. 附件支持：发送带附件的邮件
+
+3. 邮件队列：异步批量发送
+
+4. 发送统计：记录发送成功/失败率
+
+5. API接口：提供HTTP API供其他服务调用

src/config.rs

@@ -0,0 +1,47 @@
+use serde::Deserialize;
+use std::env;
+
+#[derive(Debug, Deserialize, Clone)]
+pub struct SmtpConfig {
+    pub host: String,
+    pub port: u16,
+    pub username: String,
+    pub password: String,
+    pub security: String,  // "starttls", "tls", "none"
+    pub from_email: String,
+    pub from_name: String,
+    pub timeout_seconds: u64,
+    pub max_retries: u32,
+}
+
+impl SmtpConfig {
+    pub fn from_env() -> Result<Self, String> {
+        dotenv::dotenv().ok();
+        
+        Ok(SmtpConfig {
+            host: env::var("SMTP_HOST").unwrap_or_else(|_| "afanai.top".to_string()),
+            port: env::var("SMTP_PORT")
+                .unwrap_or_else(|_| "587".to_string())
+                .parse()
+                .map_err(|e| format!("无效的端口: {}", e))?,
+            username: env::var("SMTP_USERNAME")
+                .unwrap_or_else(|_| "caoyuheng@afanai.top".to_string()),
+            password: env::var("SMTP_PASSWORD")
+                .unwrap_or_else(|_| "111111".to_string()),
+            security: env::var("SMTP_SECURITY")
+                .unwrap_or_else(|_| "starttls".to_string()),
+            from_email: env::var("FROM_EMAIL")
+                .unwrap_or_else(|_| "caoyuheng@afanai.top".to_string()),
+            from_name: env::var("FROM_NAME")
+                .unwrap_or_else(|_| "邮件服务".to_string()),
+            timeout_seconds: env::var("SMTP_TIMEOUT_SECONDS")
+                .unwrap_or_else(|_| "30".to_string())
+                .parse()
+                .unwrap_or(30),
+            max_retries: env::var("MAX_RETRIES")
+                .unwrap_or_else(|_| "3".to_string())
+                .parse()
+                .unwrap_or(3),
+        })
+    }
+}

src/error.rs

@@ -0,0 +1,21 @@
+use thiserror::Error;
+
+#[derive(Debug, Error)]
+pub enum MailError {
+    #[error("配置错误: {0}")]
+    Config(String),
+    
+    #[error("SMTP连接错误: {0}")]
+    Connection(String),
+    
+    #[error("邮件构建错误: {0}")]
+    Build(String),
+    
+    #[error("发送错误: {0}")]
+    Send(String),
+    
+    #[error("TLS错误: {0}")]
+    Tls(String),
+}
+
+pub type Result<T> = std::result::Result<T, MailError>;

src/mailer.rs

@@ -0,0 +1,201 @@
+use crate::config::SmtpConfig;
+use crate::error::{MailError, Result};
+use crate::models::{ContentType, EmailRequest, EmailResult};
+use crate::templates::{EmailTemplate, TemplateRegistry};
+use lettre::{
+    message::{header::ContentType as LettreContentType, Mailbox},
+    transport::smtp::{
+        authentication::Credentials,
+        client::{Tls, TlsParameters},
+    },
+    Message, SmtpTransport, Transport,
+};
+
+pub struct Mailer {
+    config: SmtpConfig,
+    transport: SmtpTransport,
+}
+
+impl Mailer {
+    pub fn new(config: SmtpConfig) -> Result<Self> {
+        // 创建基础传输器
+        let mut builder = SmtpTransport::relay(&config.host)
+            .map_err(|e| MailError::Connection(format!("无法连接到服务器: {}", e)))?
+            .port(config.port)
+            .credentials(Credentials::new(
+                config.username.clone(),
+                config.password.clone(),
+            ));
+        
+        // 配置TLS
+        match config.security.to_lowercase().as_str() {
+            "starttls" | "tls" => {
+                let tls_params = TlsParameters::builder(config.host.clone())
+                    .dangerous_accept_invalid_certs(true)
+                    .dangerous_accept_invalid_hostnames(true)
+                    .build()
+                    .map_err(|e| MailError::Tls(format!("TLS配置失败: {}", e)))?;
+                
+                builder = builder.tls(Tls::Required(tls_params));
+            }
+            "none" => {
+                // 不启用TLS
+            }
+            _ => {
+                return Err(MailError::Config(format!(
+                    "未知的安全模式: {}",
+                    config.security
+                )));
+            }
+        }
+        
+        let transport = builder.build();
+        
+        Ok(Self { config, transport })
+    }
+    
+    /// 发送邮件（使用 EmailRequest 结构）
+    pub fn send(&self, request: &EmailRequest) -> Result<EmailResult> {
+        // 验证收件人邮箱
+        if !crate::utils::validate_email(&request.to) {
+            return Err(MailError::Build(format!(
+                "无效的收件人邮箱: {}",
+                request.to
+            )));
+        }
+        
+        // 构建发件人邮箱
+        let from_mailbox = Mailbox::new(
+            Some(self.config.from_name.clone()),
+            self.config.from_email
+                .parse()
+                .map_err(|e| MailError::Build(format!("发件人地址无效: {}", e)))?,
+        );
+        
+        // 构建收件人邮箱
+        let to_mailbox = Mailbox::new(
+            request.to_name.clone(),
+            request.to
+                .parse()
+                .map_err(|e| MailError::Build(format!("收件人地址无效: {}", e)))?,
+        );
+        
+        // 开始构建邮件
+        let mut builder = Message::builder()
+            .from(from_mailbox)
+            .to(to_mailbox)
+            .subject(&request.subject);
+        
+        // 设置内容类型
+        let email = match request.content_type {
+            ContentType::Text => {
+                builder
+                    .header(LettreContentType::TEXT_PLAIN)
+                    .body(request.body.clone())
+            }
+            ContentType::Html => {
+                builder
+                    .header(LettreContentType::TEXT_HTML)
+                    .body(request.body.clone())
+            }
+        }
+        .map_err(|e| MailError::Build(format!("构建邮件失败: {}", e)))?;
+        
+        // 发送邮件（带重试）
+        let mut last_error = String::new();
+        for attempt in 1..=self.config.max_retries {
+            match self.transport.send(&email) {
+                Ok(response) => {
+                    // 获取消息ID
+                    let message_id = format!("{:?}", response);
+                    
+                    return Ok(EmailResult::success(
+                        &request.to,
+                        Some(&message_id),
+                    ));
+                }
+                Err(e) => {
+                    let error_str = e.to_string();
+                    last_error = error_str.clone();
+                    log::warn!("发送失败 (尝试{}): {}", attempt, error_str);
+                    
+                    if attempt < self.config.max_retries {
+                        std::thread::sleep(std::time::Duration::from_secs(1));
+                    }
+                }
+            }
+        }
+        
+        Ok(EmailResult::failure(&request.to, &last_error))
+    }
+    
+    /// 便捷方法：发送纯文本邮件
+    pub fn send_text(
+        &self,
+        to: &str,
+        subject: &str,
+        body: &str,
+    ) -> Result<EmailResult> {
+        let request = EmailRequest::simple(to, subject, body);
+        self.send(&request)
+    }
+    
+    /// 便捷方法：发送HTML邮件
+    pub fn send_html(
+        &self,
+        to: &str,
+        subject: &str,
+        html_body: &str,
+    ) -> Result<EmailResult> {
+        let request = EmailRequest::html(to, subject, html_body);
+        self.send(&request)
+    }
+    
+    pub fn test_connection(&self) -> Result<bool> {
+        self.transport
+            .test_connection()
+            .map_err(|e| MailError::Connection(format!("连接测试失败: {}", e)))
+    }
+
+    /// 使用模板发送邮件
+    pub fn send_with_template(
+        &self,
+        template: &EmailTemplate,
+        to: &str,
+        to_name: Option<&str>,
+        subject: &str,
+        variables: std::collections::HashMap<String, String>,
+    ) -> Result<EmailResult> {
+        // 渲染模板
+        let html_body = template.render(&variables)?;
+        
+        // 创建邮件请求
+        let request = crate::models::EmailRequest {
+            to: to.to_string(),
+            to_name: to_name.map(|s| s.to_string()),
+            subject: subject.to_string(),
+            body: html_body,
+            content_type: crate::models::ContentType::Html,
+            ..Default::default()
+        };
+        
+        // 发送邮件
+        self.send(&request)
+    }
+    
+    /// 从模板注册器发送邮件
+    pub fn send_from_registry(
+        &self,
+        registry: &TemplateRegistry,
+        template_name: &str,
+        to: &str,
+        to_name: Option<&str>,
+        subject: &str,
+        variables: std::collections::HashMap<String, String>,
+    ) -> Result<EmailResult> {
+        match registry.get(template_name) {
+            Some(template) => self.send_with_template(template, to, to_name, subject, variables),
+            None => Err(MailError::Build(format!("模板不存在: {}", template_name))),
+        }
+    }
+}

src/main.rs

@@ -0,0 +1,150 @@
+// 声明所有模块
+mod config;
+mod error;
+mod mailer;
+mod models;
+mod templates;  // 模板模块
+mod utils;
+
+// 导入需要的类型
+use crate::config::SmtpConfig;
+use crate::mailer::Mailer;
+use crate::templates::{builtin, TemplateRegistry};
+use crate::utils::{current_timestamp};
+
+// 标准库导入
+use std::collections::HashMap;
+
+fn main() -> Result<(), Box<dyn std::error::Error>> {
+    // 初始化日志
+    env_logger::init();
+    
+    println!("🚀 Rust邮件服务启动...");
+    println!("版本: 模板系统测试版");
+    
+    // 1. 加载配置
+    let config = SmtpConfig::from_env()
+        .map_err(|e| format!("配置加载失败: {}", e))?;
+    
+    println!("📧 配置信息:");
+    println!("  服务器: {}:{}", config.host, config.port);
+    println!("  发件人: {} <{}>", config.from_name, config.from_email);
+    
+    // 2. 创建邮件发送器
+    let mailer = Mailer::new(config)
+        .map_err(|e| format!("创建邮件发送器失败: {}", e))?;
+    
+    println!("✅ 邮件发送器初始化完成");
+    
+    // 3. 测试连接
+    println!("🔗 测试SMTP连接...");
+    match mailer.test_connection() {
+        Ok(true) => println!("✅ 连接测试成功"),
+        Ok(false) => println!("⚠️  连接测试返回false"),
+        Err(e) => {
+            println!("❌ 连接测试失败: {}", e);
+            return Ok(());
+        }
+    }
+    
+    // 4. 创建模板注册器并注册内置模板
+    println!("\n📋 初始化模板系统...");
+    let mut registry = TemplateRegistry::new();
+    
+    // 注册内置模板
+    registry.register(builtin::welcome());
+    registry.register(builtin::password_reset());
+    registry.register(builtin::notification());
+    
+    println!("✅ 已注册模板: {}", registry.list_templates().join(", "));
+    
+    // 5. 测试1：使用内置欢迎模板
+    println!("\n🎯 测试1：内置欢迎模板");
+    
+    let mut vars = HashMap::new();
+    vars.insert("name".to_string(), "张三".to_string());
+    vars.insert("site_name".to_string(), "阿凡AI".to_string());
+    vars.insert("code".to_string(), "123456".to_string());
+    vars.insert("expiry".to_string(), "30分钟".to_string());
+    
+    match mailer.send_from_registry(
+        &registry,
+        "welcome_simple",
+        "aaa@afanai.top",
+        Some("测试用户"),
+        "欢迎加入阿凡AI！",
+        vars,
+    ) {
+        Ok(result) => {
+            if result.success {
+                println!("✅ 模板邮件发送成功");
+            } else {
+                println!("❌ 模板邮件发送失败: {:?}", result.error);
+            }
+        }
+        Err(e) => println!("❌ 模板错误: {}", e),
+    }
+    
+    // 6. 测试2：密码重置模板
+    println!("\n🎯 测试2：密码重置模板");
+    
+    let mut reset_vars = HashMap::new();
+    reset_vars.insert("username".to_string(), "caoyuheng".to_string());
+    reset_vars.insert("reset_link".to_string(), 
+        "https://afanai.top/reset/password?token=xyz789".to_string());
+    reset_vars.insert("expiry_time".to_string(), "1小时".to_string());
+    reset_vars.insert("ip_address".to_string(), "192.168.1.100".to_string());
+    
+    match mailer.send_from_registry(
+        &registry,
+        "password_reset",
+        "aaa@afanai.top",
+        Some("曹雨恒"),
+        "密码重置请求 - 阿凡AI",
+        reset_vars,
+    ) {
+        Ok(result) => {
+            if result.success {
+                println!("✅ 密码重置邮件发送成功");
+            } else {
+                println!("❌ 密码重置邮件发送失败: {:?}", result.error);
+            }
+        }
+        Err(e) => println!("❌ 密码重置模板错误: {}", e),
+    }
+    
+    // 7. 测试3：通知模板
+    println!("\n🎯 测试3：系统通知模板");
+    
+    let mut notify_vars = HashMap::new();
+    notify_vars.insert("title".to_string(), "系统维护通知".to_string());
+    notify_vars.insert("time".to_string(), current_timestamp());
+    notify_vars.insert("message".to_string(), 
+        "服务器将于今晚10点进行维护，预计耗时2小时。".to_string());
+    notify_vars.insert("action_url".to_string(), 
+        "https://status.afanai.top".to_string());
+    
+    match mailer.send_from_registry(
+        &registry,
+        "notification",
+        "aaa@afanai.top",
+        Some("系统管理员"),
+        "系统维护通知",
+        notify_vars,
+    ) {
+        Ok(result) => {
+            if result.success {
+                println!("✅ 通知邮件发送成功");
+            } else {
+                println!("❌ 通知邮件发送失败: {:?}", result.error);
+            }
+        }
+        Err(e) => println!("❌ 通知模板错误: {}", e),
+    }
+    
+    println!("\n🎉 模板系统测试完成！");
+    println!("📬 请检查 aaa@afanai.top 的收件箱");
+    println!("   应该收到3封不同模板的测试邮件");
+    
+    Ok(())
+}

src/models.rs

@@ -0,0 +1,119 @@
+use serde::{Deserialize, Serialize};
+
+/// 邮件内容类型
+#[derive(Debug, Clone, Copy, Serialize, Deserialize)]
+pub enum ContentType {
+    /// 纯文本
+    Text,
+    /// HTML格式
+    Html,
+}
+
+/// 邮件优先级
+#[derive(Debug, Clone, Copy, Serialize, Deserialize)]
+pub enum Priority {
+    Low,
+    Normal,
+    High,
+}
+
+/// 邮件请求
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct EmailRequest {
+    /// 收件人邮箱
+    pub to: String,
+    /// 收件人姓名（可选）
+    pub to_name: Option<String>,
+    /// 邮件主题
+    pub subject: String,
+    /// 邮件正文
+    pub body: String,
+    /// 内容类型
+    pub content_type: ContentType,
+    /// 优先级
+    pub priority: Option<Priority>,
+    /// 抄送列表（可选）
+    pub cc: Option<Vec<String>>,
+    /// 密送列表（可选）
+    pub bcc: Option<Vec<String>>,
+}
+
+impl Default for EmailRequest {
+    fn default() -> Self {
+        Self {
+            to: String::new(),
+            to_name: None,
+            subject: String::new(),
+            body: String::new(),
+            content_type: ContentType::Text,
+            priority: Some(Priority::Normal),
+            cc: None,
+            bcc: None,
+        }
+    }
+}
+
+impl EmailRequest {
+    /// 创建简单的文本邮件请求
+    pub fn simple(to: &str, subject: &str, body: &str) -> Self {
+        Self {
+            to: to.to_string(),
+            to_name: None,
+            subject: subject.to_string(),
+            body: body.to_string(),
+            content_type: ContentType::Text,
+            priority: Some(Priority::Normal),
+            cc: None,
+            bcc: None,
+        }
+    }
+    
+    /// 创建HTML邮件请求
+    pub fn html(to: &str, subject: &str, html_body: &str) -> Self {
+        Self {
+            to: to.to_string(),
+            to_name: None,
+            subject: subject.to_string(),
+            body: html_body.to_string(),
+            content_type: ContentType::Html,
+            priority: Some(Priority::Normal),
+            cc: None,
+            bcc: None,
+        }
+    }
+}
+
+/// 邮件发送结果
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct EmailResult {
+    /// 是否成功
+    pub success: bool,
+    /// 收件人
+    pub recipient: String,
+    /// 错误信息（如果有）
+    pub error: Option<String>,
+    /// 消息ID（SMTP服务器返回）
+    pub message_id: Option<String>,
+}
+
+impl EmailResult {
+    /// 创建成功结果
+    pub fn success(recipient: &str, message_id: Option<&str>) -> Self {
+        Self {
+            success: true,
+            recipient: recipient.to_string(),
+            error: None,
+            message_id: message_id.map(|s| s.to_string()),
+        }
+    }
+    
+    /// 创建失败结果
+    pub fn failure(recipient: &str, error: &str) -> Self {
+        Self {
+            success: false,
+            recipient: recipient.to_string(),
+            error: Some(error.to_string()),
+            message_id: None,
+        }
+    }
+}

src/templates/mod.rs

@@ -0,0 +1,97 @@
+// 声明子模块
+mod registry;
+
+// 公开导出
+pub use registry::{EmailTemplate, TemplateRegistry};
+
+// 内置模板模块
+pub mod builtin {
+    use super::EmailTemplate;
+    
+    /// 欢迎邮件模板
+    pub fn welcome() -> EmailTemplate {
+        let content = r#"
+<!DOCTYPE html>
+<html>
+<head>
+    <meta charset="UTF-8">
+    <style>
+        body { font-family: Arial; max-width: 600px; margin: 0 auto; padding: 20px; }
+        .header { background: #4CAF50; color: white; padding: 20px; text-align: center; }
+        .content { padding: 20px; background: #f9f9f9; }
+    </style>
+</head>
+<body>
+    <div class="header">
+        <h1>欢迎 {{name}}！</h1>
+    </div>
+    <div class="content">
+        <p>感谢您加入 {{site_name}}。</p>
+        <p>您的验证码是：<strong>{{code}}</strong></p>
+        <p>有效期：{{expiry}}</p>
+    </div>
+</body>
+</html>
+        "#.to_string();
+        
+        EmailTemplate::from_string("welcome_simple", &content, "简单的欢迎邮件模板")
+    }
+    
+    /// 密码重置模板
+    pub fn password_reset() -> EmailTemplate {
+        let content = r#"
+<!DOCTYPE html>
+<html>
+<head>
+    <meta charset="UTF-8">
+    <style>
+        body { font-family: Arial; max-width: 600px; margin: 0 auto; padding: 20px; }
+        .alert { background: #fff3cd; border-left: 4px solid #ffc107; padding: 15px; }
+        .button { background: #dc3545; color: white; padding: 10px 20px; text-decoration: none; }
+    </style>
+</head>
+<body>
+    <div class="alert">
+        <h2>密码重置请求</h2>
+        <p>亲爱的 {{username}}，</p>
+        <p>我们收到了您的密码重置请求。</p>
+        <p>请点击下方链接重置密码：</p>
+        <a href="{{reset_link}}" class="button">重置密码</a>
+        <p>如果您未请求重置密码，请忽略此邮件。</p>
+        <p>链接有效期：{{expiry_time}}</p>
+        <p>IP地址：{{ip_address}}</p>
+    </div>
+</body>
+</html>
+        "#.to_string();
+        
+        EmailTemplate::from_string("password_reset", &content, "密码重置邮件模板")
+    }
+    
+    /// 通知模板
+    pub fn notification() -> EmailTemplate {
+        let content = r#"
+<!DOCTYPE html>
+<html>
+<head>
+    <meta charset="UTF-8">
+    <style>
+        body { font-family: Arial; max-width: 600px; margin: 0 auto; padding: 20px; }
+        .info { background: #d1ecf1; border-left: 4px solid #17a2b8; padding: 15px; }
+    </style>
+</head>
+<body>
+    <div class="info">
+        <h2>{{title}}</h2>
+        <p><strong>时间：</strong>{{time}}</p>
+        <p><strong>内容：</strong>{{message}}</p>
+        {{#if action_url}}<p><a href="{{action_url}}">查看详情</a></p>{{/if}}
+        <p><small>此通知由系统自动生成</small></p>
+    </div>
+</body>
+</html>
+        "#.to_string();
+        
+        EmailTemplate::from_string("notification", &content, "系统通知模板")
+    }
+}

src/templates/registry.rs

@@ -0,0 +1,194 @@
+use std::collections::HashMap;
+use std::fs;
+use std::path::Path;
+
+use crate::error::{MailError, Result};
+
+/// 邮件模板
+#[derive(Debug, Clone)]
+pub struct EmailTemplate {
+    /// 模板名称
+    pub name: String,
+    /// 模板内容（HTML）
+    pub content: String,
+    /// 模板描述
+    pub description: String,
+    /// 需要的变量列表
+    pub required_vars: Vec<String>,
+}
+
+impl EmailTemplate {
+    /// 从文件加载模板
+    pub fn from_file(name: &str, file_path: &str, description: &str) -> Result<Self> {
+        let content = fs::read_to_string(file_path)
+            .map_err(|e| MailError::Config(format!("无法读取模板文件 {}: {}", file_path, e)))?;
+        
+        // 简单提取变量（以 {{ 开头 }} 结尾的标识符）
+        let required_vars = Self::extract_variables(&content);
+        
+        Ok(Self {
+            name: name.to_string(),
+            content,
+            description: description.to_string(),
+            required_vars,
+        })
+    }
+    
+    /// 从字符串创建模板
+    pub fn from_string(name: &str, content: &str, description: &str) -> Self {
+        let required_vars = Self::extract_variables(content);
+        
+        Self {
+            name: name.to_string(),
+            content: content.to_string(),
+            description: description.to_string(),
+            required_vars,
+        }
+    }
+    
+    /// 提取模板中的变量
+    fn extract_variables(content: &str) -> Vec<String> {
+        let mut vars = Vec::new();
+        let mut in_var = false;
+        let mut current_var = String::new();
+        
+        let chars: Vec<char> = content.chars().collect();
+        let mut i = 0;
+        
+        while i < chars.len() {
+            // 检查是否开始变量 {{ 
+            if i + 1 < chars.len() && chars[i] == '{' && chars[i + 1] == '{' {
+                in_var = true;
+                i += 2; // 跳过 {{
+                continue;
+            }
+            
+            // 检查是否结束变量 }}
+            if i + 1 < chars.len() && chars[i] == '}' && chars[i + 1] == '}' {
+                if in_var && !current_var.trim().is_empty() {
+                    vars.push(current_var.trim().to_string());
+                }
+                in_var = false;
+                current_var.clear();
+                i += 2; // 跳过 }}
+                continue;
+            }
+            
+            // 如果在变量内部，收集字符
+            if in_var {
+                current_var.push(chars[i]);
+            }
+            
+            i += 1;
+        }
+        
+        // 去重并排序
+        vars.sort();
+        vars.dedup();
+        vars
+    }
+    
+    /// 渲染模板（简单替换）
+    pub fn render(&self, variables: &HashMap<String, String>) -> Result<String> {
+        let mut rendered = self.content.clone();
+        
+        // 检查必需变量
+        for required_var in &self.required_vars {
+            if !variables.contains_key(required_var) {
+                return Err(MailError::Build(format!(
+                    "模板 '{}' 缺少必需变量: {}",
+                    self.name, required_var
+                )));
+            }
+        }
+        
+        // 替换变量
+        for (key, value) in variables {
+            let placeholder = format!("{{{{{}}}}}", key);
+            rendered = rendered.replace(&placeholder, value);
+        }
+        
+        Ok(rendered)
+    }
+    
+    /// 获取模板信息
+    pub fn info(&self) -> String {
+        format!(
+            "模板: {} (需要变量: {})",
+            self.name,
+            self.required_vars.join(", ")
+        )
+    }
+}
+
+/// 模板注册器
+#[derive(Debug, Default)]
+pub struct TemplateRegistry {
+    templates: HashMap<String, EmailTemplate>,
+}
+
+impl TemplateRegistry {
+    pub fn new() -> Self {
+        Self {
+            templates: HashMap::new(),
+        }
+    }
+    
+    /// 注册模板
+    pub fn register(&mut self, template: EmailTemplate) {
+        self.templates.insert(template.name.clone(), template);
+    }
+    
+    /// 从目录加载所有模板
+    pub fn load_from_dir(&mut self, dir_path: &str) -> Result<()> {
+        let path = Path::new(dir_path);
+        
+        if !path.exists() {
+            return Err(MailError::Config(format!("模板目录不存在: {}", dir_path)));
+        }
+        
+        for entry in fs::read_dir(path).map_err(|e| {
+            MailError::Config(format!("无法读取模板目录 {}: {}", dir_path, e))
+        })? {
+            let entry = entry.map_err(|e| {
+                MailError::Config(format!("读取目录项失败: {}", e))
+            })?;
+            
+            let file_path = entry.path();
+            if file_path.extension().map_or(false, |ext| ext == "html") {
+                let name = file_path.file_stem()
+                    .and_then(|n| n.to_str())
+                    .unwrap_or("unknown")
+                    .to_string();
+                
+                let template = EmailTemplate::from_file(
+                    &name,
+                    file_path.to_str().unwrap(),
+                    &format!("从文件加载: {}", file_path.display()),
+                )?;
+                
+                self.register(template);
+            }
+        }
+        
+        Ok(())
+    }
+    
+    /// 获取模板
+    pub fn get(&self, name: &str) -> Option<&EmailTemplate> {
+        self.templates.get(name)
+    }
+    
+    /// 获取所有模板名称
+    pub fn list_templates(&self) -> Vec<String> {
+        self.templates.keys().cloned().collect()
+    }
+    
+    /// 渲染模板
+    pub fn render(&self, name: &str, variables: &HashMap<String, String>) -> Result<String> {
+        match self.get(name) {
+            Some(template) => template.render(variables),
+            None => Err(MailError::Build(format!("模板不存在: {}", name))),
+        }
+    }
+}

src/templates/welcome.html

@@ -0,0 +1,120 @@
+<!DOCTYPE html>
+<html>
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>{{subject}}</title>
+    <style>
+        body {
+            font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;
+            line-height: 1.6;
+            color: #333;
+            max-width: 600px;
+            margin: 0 auto;
+            padding: 20px;
+            background-color: #f9f9f9;
+        }
+        .header {
+            background: linear-gradient(135deg, #667eea 0%, #764ba2 100%);
+            color: white;
+            padding: 30px;
+            border-radius: 10px 10px 0 0;
+            text-align: center;
+        }
+        .content {
+            background: white;
+            padding: 30px;
+            border-radius: 0 0 10px 10px;
+            box-shadow: 0 4px 6px rgba(0,0,0,0.1);
+        }
+        .greeting {
+            font-size: 24px;
+            margin-bottom: 20px;
+            color: #2c3e50;
+        }
+        .message {
+            margin-bottom: 25px;
+            font-size: 16px;
+        }
+        .highlight {
+            background-color: #fff3cd;
+            padding: 15px;
+            border-left: 4px solid #ffc107;
+            margin: 20px 0;
+            border-radius: 4px;
+        }
+        .button {
+            display: inline-block;
+            background: #4CAF50;
+            color: white;
+            padding: 12px 30px;
+            text-decoration: none;
+            border-radius: 5px;
+            font-weight: bold;
+            margin: 10px 0;
+        }
+        .footer {
+            margin-top: 30px;
+            padding-top: 20px;
+            border-top: 1px solid #eee;
+            font-size: 12px;
+            color: #777;
+            text-align: center;
+        }
+        .user-info {
+            background: #f8f9fa;
+            padding: 15px;
+            border-radius: 5px;
+            margin: 15px 0;
+        }
+    </style>
+</head>
+<body>
+    <div class="header">
+        <h1>🎉 欢迎加入 {{site_name}}！</h1>
+        <p>我们很高兴您的到来</p>
+    </div>
+    
+    <div class="content">
+        <div class="greeting">
+            亲爱的 {{name}}，您好！
+        </div>
+        
+        <div class="message">
+            感谢您注册 {{site_name}}。您的账户已经成功创建，现在可以开始使用我们的服务了。
+        </div>
+        
+        <div class="user-info">
+            <p><strong>账户信息：</strong></p>
+            <p>用户名：{{username}}</p>
+            <p>注册时间：{{signup_date}}</p>
+            <p>用户ID：{{user_id}}</p>
+        </div>
+        
+        <div class="highlight">
+            <p><strong>下一步操作：</strong></p>
+            <p>请点击下方按钮验证您的邮箱地址：</p>
+            <a href="{{verification_link}}" class="button">✅ 验证邮箱</a>
+            <p style="font-size: 14px; margin-top: 10px;">
+                如果按钮无法点击，请复制以下链接：<br>
+                <code>{{verification_link}}</code>
+            </p>
+        </div>
+        
+        <div class="message">
+            <p><strong>开始探索：</strong></p>
+            <ul>
+                <li>📚 查看 <a href="{{docs_link}}">使用文档</a></li>
+                <li>🎬 观看 <a href="{{tutorial_link}}">入门教程</a></li>
+                <li>💬 加入 <a href="{{community_link}}">社区讨论</a></li>
+            </ul>
+        </div>
+        
+        <div class="footer">
+            <p>此邮件由 {{site_name}} 系统自动发送，请勿直接回复。</p>
+            <p>如果您未注册 {{site_name}}，请忽略此邮件。</p>
+            <p>发送时间：{{current_time}} | 邮件ID：{{email_id}}</p>
+        </div>
+    </div>
+</body>
+</html>

src/utils.rs

@@ -0,0 +1,92 @@
+use std::env;
+use chrono::{Local, DateTime};
+
+/// 验证邮箱地址格式（简单版本）
+pub fn validate_email(email: &str) -> bool {
+    email.contains('@') && email.contains('.') && email.len() > 5
+}
+
+/// 清理邮箱地址（去除空格，转为小写）
+pub fn sanitize_email(email: &str) -> String {
+    email.trim().to_lowercase()
+}
+
+/// 获取当前时间戳字符串
+pub fn current_timestamp() -> String {
+    Local::now().format("%Y-%m-%d %H:%M:%S").to_string()
+}
+
+/// 获取格式化时间
+pub fn format_datetime(dt: &DateTime<Local>) -> String {
+    dt.format("%Y-%m-%d %H:%M:%S").to_string()
+}
+
+/// 生成测试邮件内容
+pub fn generate_test_email(to: &str) -> crate::models::EmailRequest {
+    use crate::models::{EmailRequest, ContentType};
+    
+    let body = format!(
+        "这是一封测试邮件。\n\n\
+         发送时间: {}\n\
+         发件人: Rust邮件服务\n\n\
+         恭喜！你的邮件服务正在正常工作。",
+        current_timestamp()
+    );
+    
+    EmailRequest {
+        to: to.to_string(),
+        subject: format!("测试邮件 - {}", current_timestamp()),
+        body,
+        content_type: ContentType::Text,
+        ..Default::default()
+    }
+}
+
+/// 生成HTML测试邮件
+pub fn generate_html_test_email(to: &str) -> crate::models::EmailRequest {
+    use crate::models::{EmailRequest, ContentType};
+    
+    let html_body = format!(
+        r#"<!DOCTYPE html>
+<html>
+<head>
+    <meta charset="UTF-8">
+    <title>测试邮件</title>
+    <style>
+        body {{ font-family: Arial, sans-serif; line-height: 1.6; }}
+        .header {{ background-color: #4CAF50; color: white; padding: 20px; }}
+        .content {{ padding: 20px; }}
+        .footer {{ background-color: #f1f1f1; padding: 10px; font-size: 12px; }}
+    </style>
+</head>
+<body>
+    <div class="header">
+        <h1>HTML测试邮件</h1>
+    </div>
+    <div class="content">
+        <p>这是一封<strong>HTML格式</strong>的测试邮件。</p>
+        <p>发送时间: <em>{}</em></p>
+        <p>状态: <span style="color: green;">✅ 正常</span></p>
+    </div>
+    <div class="footer">
+        <p>由Rust邮件服务发送</p>
+    </div>
+</body>
+</html>"#,
+        current_timestamp()
+    );
+    
+    EmailRequest {
+        to: to.to_string(),
+        subject: format!("HTML测试邮件 - {}", current_timestamp()),
+        body: html_body,
+        content_type: ContentType::Html,
+        ..Default::default()
+    }
+}
+
+/// 从环境变量读取收件人，如果没有则使用默认值
+pub fn get_default_recipient() -> String {
+    env::var("TEST_RECIPIENT")
+        .unwrap_or_else(|_| "aaa@afanai.top".to_string())
+}