在ASP.NET Web应用中通过MTA自动发送邮件方案咨询

方案一：业务逻辑同步触发发送 #

在调用存储过程完成邮件数据入库后，直接在ASP.NET代码中执行邮件发送逻辑，适合发送耗时较短的场景。

• 示例代码（C#）：

// 调用存储过程保存邮件数据
using (var conn = new SqlConnection("你的数据库连接字符串"))
{
    conn.Open();
    using (var cmd = new SqlCommand("你的存储过程名", conn))
    {
        cmd.CommandType = CommandType.StoredProcedure;
        // 绑定存储过程参数（对应表中字段，如收件人、主题、内容等）
        cmd.Parameters.AddWithValue("@To", "user@example.com");
        cmd.Parameters.AddWithValue("@Subject", "测试邮件");
        cmd.Parameters.AddWithValue("@Body", "这是一封自动发送的测试邮件");
        cmd.ExecuteNonQuery();
    }
}

// 立即触发邮件发送
SendEmail("user@example.com", "测试邮件", "这是一封自动发送的测试邮件");

// 邮件发送核心方法
private void SendEmail(string to, string subject, string body)
{
    using (var message = new MailMessage("your-email@example.com", to))
    {
        message.Subject = subject;
        message.Body = body;
        message.IsBodyHtml = true;

        using (var smtpClient = new SmtpClient("smtp.example.com", 587))
        {
            smtpClient.Credentials = new NetworkCredential("your-email@example.com", "your-smtp-password");
            smtpClient.EnableSsl = true;
            smtpClient.Send(message);
        }
    }
}

方案二：数据库触发器+后台轮询（异步发送） #

适合邮件发送耗时较长、不想阻塞主业务流程的场景，通过触发器标记待发送任务，后台服务定时处理。

1. 创建触发器，插入邮件后写入任务队列表（需新增EmailQueue表，包含EmailId、Status、ErrorMessage等字段）

CREATE TRIGGER trg_AfterEmailInsert
ON 你的邮件表名
AFTER INSERT
AS
BEGIN
    INSERT INTO EmailQueue(EmailId, Status)
    SELECT Id, 'Pending' FROM inserted;
END

2. 实现ASP.NET后台轮询服务

public class EmailQueueHostedService : BackgroundService
{
    private readonly IServiceProvider _serviceProvider;

    public EmailQueueHostedService(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            using (var scope = _serviceProvider.CreateScope())
            {
                var dbContext = scope.ServiceProvider.GetRequiredService<你的DbContext>();
                // 批量获取待发送邮件任务
                var pendingTasks = await dbContext.EmailQueue
                    .Where(q => q.Status == "Pending")
                    .Take(10)
                    .ToListAsync(stoppingToken);

                foreach (var task in pendingTasks)
                {
                    var email = await dbContext.你的邮件表名.FindAsync(task.EmailId);
                    if (email == null) continue;

                    try
                    {
                        SendEmail(email.To, email.Subject, email.Body);
                        task.Status = "Sent";
                        task.SentTime = DateTime.Now;
                    }
                    catch (Exception ex)
                    {
                        task.Status = "Failed";
                        task.ErrorMessage = ex.Message;
                    }
                }

                await dbContext.SaveChangesAsync(stoppingToken);
            }
            // 每30秒轮询一次，可根据需求调整
            await Task.Delay(TimeSpan.FromSeconds(30), stoppingToken);
        }
    }

    private void SendEmail(string to, string subject, string body)
    {
        // 同方案一的发送逻辑
    }
}

3. 在Program.cs注册后台服务

builder.Services.AddHostedService<EmailQueueHostedService>();

方案三：使用Hangfire任务调度框架 #

自带任务重试、状态监控功能，适合复杂场景下的异步任务处理。

1. 安装Hangfire包

Install-Package Hangfire

2. 在Program.cs配置Hangfire

builder.Services.AddHangfire(config => config.UseSqlServerStorage("你的数据库连接字符串"));
builder.Services.AddHangfireServer();

3. 入库后添加发送任务到队列

// 调用存储过程完成数据插入后，获取邮件ID（可通过存储过程返回值获取）
var emailId = 1;
// 将发送任务加入Hangfire队列
BackgroundJob.Enqueue(() => SendEmailByEmailId(emailId));

// 根据ID获取邮件并发送的方法
public void SendEmailByEmailId(int emailId)
{
    using (var dbContext = new 你的DbContext())
    {
        var email = dbContext.你的邮件表名.Find(emailId);
        if (email == null) return;

        SendEmail(email.To, email.Subject, email.Body);
    }
}

通用注意事项 #

• 建议将SMTP配置存入appsettings.json，方便管理：

"EmailSettings": {
    "SmtpServer": "smtp.example.com",
    "SmtpPort": 587,
    "SmtpUsername": "your-email@example.com",
    "SmtpPassword": "your-smtp-password",
    "FromEmail": "your-email@example.com"
}

• 为邮件发送添加重试机制，避免因临时网络问题导致发送失败
• 异步场景下确保后台服务稳定，避免应用重启丢失任务（依赖持久化队列）

内容的提问来源于stack exchange，提问作者Deamon Dev