C#连接数据库并异步批量发送邮件的实现方法

核心逻辑与目标

该方案的主要目标是解决批量发送时的性能瓶颈。通过以下步骤实现：

1. 连接数据库：使用 SqlConnection 连接 SQL Server，执行查询获取收件人列表。
2. 定义发送委托：创建一个封装 SmtpClient 发送逻辑的委托，以便支持异步调用。
3. 异步遍历发送：在遍历数据库结果集时，不等待单个邮件发送完成，而是启动异步任务，提高吞吐量。

环境准备

• 依赖库：System.Net.Mail 用于构建邮件，System.Data.SqlClient 用于数据库交互。
• 权限配置：确保运行环境有权访问目标 SMTP 服务器及 SQL Server 数据库。
• 网络设置：确认防火墙允许出站连接至 SMTP 端口（默认 25 或 587）。

具体实现步骤

第1步：配置 SMTP 邮件发送委托

目的：将邮件发送逻辑模块化，并为异步操作做准备。

入口：定义一个委托类型和对应的处理方法。

动作：

1. 定义委托签名，包含发件人、收件人、主题、内容、SMTP主机、端口、用户名和密码。
2. 创建委托实例指向具体的发送方法。
3. 在方法内部实例化 MailMessage 和 SmtpClient。

重要参数：

• message.IsBodyHtml = true：支持 HTML 格式邮件。
• message.BodyEncoding = Encoding.UTF8：防止中文乱码。
• client.Credentials：必须填写有效的 SMTP 账户凭据，否则发送会失败。

using System;
using System.Net;
using System.Net.Mail;
using System.Text;
using System.Threading;

// 定义委托，用于异步调用
delegate void sendDelegate(string from, string to, string subject, string body, string host, int port, string userName, string password);

public void SendEmailViaDelegate(string from, string to, string subject, string body, string host, int port, string userName, string password)
{
    try
    {
        MailMessage message = new MailMessage(from, to, subject, body);
        message.IsBodyHtml = true; // 开启HTML支持
        message.BodyEncoding = Encoding.UTF8; // 设置编码为UTF-8
        
        // 可选：添加附件，注意路径需存在且可访问
        // message.Attachments.Add(new Attachment("c:\\log.log"));

        SmtpClient client = new SmtpClient(host, port);
        client.Credentials = new NetworkCredential(userName, password);
        client.DeliveryMethod = SmtpDeliveryMethod.Network;
        
        // 同步发送，因为整体流程已由BeginInvoke异步化
        client.Send(message);
    }
    catch (Exception ex)
    {
        // 建议记录日志，便于排查发送失败的邮箱
        Console.WriteLine($"Failed to send email to {to}: {ex.Message}");
    }
}

第2步：连接数据库获取邮箱列表

目的：从 SQL Server 数据库中提取需要接收邮件的用户邮箱地址。

入口：初始化 SqlConnection 并打开连接。

动作：

1. 编写查询语句，例如 SELECT Email FROM Employee。
2. 使用 SqlDataReader 逐行读取结果，避免一次性加载大量数据到内存。

string connString = "Data Source=(local);Integrated Security=SSPI;Initial Catalog=db_showHouse";
using (SqlConnection conn = new SqlConnection(connString))
{
    conn.Open();
    SqlCommand cmd = new SqlCommand("SELECT Email FROM Employee", conn);
    SqlDataReader drNew = cmd.ExecuteReader();
    
    // 检查是否有数据
    if (drNew.HasRows)
    {
        while (drNew.Read())
        {
            string recipient = drNew[0].ToString().Trim();
            // 此处触发异步发送
            TriggerAsyncSend(recipient);
        }
    }
    drNew.Close();
}

第3步：启用异步批量发送

目的：利用多线程机制，让每个邮件的发送互不阻塞，加快整体处理速度。

入口：在读取数据的循环中调用委托的 BeginInvoke。

动作：

1. 创建委托实例。
2. 调用 BeginInvoke 开始异步执行。
3. 注意：由于是异步调用，主线程会继续处理下一个邮箱，不会等待当前邮件发送完成。

// 假设已定义好 smtpConfig 相关常量
string host = "smtp.qq.com"; // 替换为你的SMTP服务器，如 smtp.gmail.com
int port = 587;              // 常用SSL端口，若使用普通TCP则为25
string userName = "your_email@domain.com";
string password = "your_app_password";
string senderFrom = "system@yourcompany.com";
string subject = "系统通知测试";
string body = "这是一封由C#自动生成的测试邮件。";

void TriggerAsyncSend(string toEmail)
{
    // 创建委托
    var sendDel = new sendDelegate(SendEmailViaDelegate);
    
    // 异步调用，不阻塞当前线程
    sendDel.BeginInvoke(
        senderFrom, 
        toEmail, 
        subject, 
        body, 
        host, 
        port, 
        userName, 
        password,
        null, // 回调函数，可选
        null  // 状态对象，可选
    );
}

完成判断与注意事项

• 验证成功：运行程序后，检查目标邮箱是否收到邮件。同时观察控制台输出，若无报错日志，通常表示发送流程已启动。
• 资源管理：上述示例使用了 using 语句确保 SqlConnection 和 SqlDataReader 正确释放。但在高并发异步场景下，频繁创建网络连接可能成为瓶颈，生产环境中建议引入连接池管理或消息队列（如 RabbitMQ）解耦。
• 频率限制：多数 SMTP 服务商对单位时间内的发送数量有严格限制（如 QQ 邮箱每小时限制）。若无特殊需求，建议添加延迟逻辑或使用专业的邮件发送服务 API 代替直接 SMTP 连接。
• 异常处理：异步操作中的异常容易被吞没。务必在 SendEmailViaDelegate 内部捕获异常并写入日志文件，以便后续审计。

简要总结

以上是通过 C# 连接数据库并实现异步批量发送邮件的详细内容。更多关于 C# 数据库操作及邮件发送的资料请关注本站其它相关文章！