.NET 8 SPA Identity自定义邮件模板及注册后后台任务求助

一、替换默认邮件为自定义HTML模板 #

Identity 默认通过 IEmailSender 接口发送邮件，要替换为HTML模板，可自定义实现该接口并结合Razor视图引擎渲染模板：

1. 创建HTML邮件模板
   在项目中新建 Views/EmailTemplates 目录，添加模板文件（如 ConfirmEmail.cshtml）：

@model ConfirmEmailModel
<!DOCTYPE html>
<html>
<head>
    <title>确认邮箱</title>
</head>
<body>
    <h2>欢迎注册！</h2>
    <p>@Model.UserName，请点击下方链接完成邮箱确认：</p>
    <a href="@Model.ConfirmLink" style="padding:8px 16px;background:#007bff;color:white;text-decoration:none;border-radius:4px;">确认邮箱</a>
    <p>如果这不是您的操作，请忽略此邮件。</p>
</body>
</html>

对应模型类：

public class ConfirmEmailModel
{
    public string ConfirmLink { get; set; }
    public string UserName { get; set; }
}

2. 自定义IEmailSender实现
   实现支持Razor模板渲染的邮件发送器：

public class RazorEmailSender : IEmailSender
{
    private readonly IServiceProvider _serviceProvider;
    private readonly IConfiguration _configuration;

    public RazorEmailSender(IServiceProvider serviceProvider, IConfiguration configuration)
    {
        _serviceProvider = serviceProvider;
        _configuration = configuration;
    }

    public async Task SendEmailAsync(string email, string subject, string htmlMessage)
    {
        // 替换为实际邮件发送逻辑（SMTP/SendGrid等）
        using var smtpClient = new SmtpClient(_configuration["Smtp:Host"])
        {
            Port = int.Parse(_configuration["Smtp:Port"]),
            Credentials = new NetworkCredential(_configuration["Smtp:Username"], _configuration["Smtp:Password"]),
            EnableSsl = true,
        };

        var mailMessage = new MailMessage
        {
            From = new MailAddress(_configuration["Smtp:From"]),
            Subject = subject,
            Body = htmlMessage,
            IsBodyHtml = true,
        };
        mailMessage.To.Add(email);

        await smtpClient.SendMailAsync(mailMessage);
    }

    // 渲染Razor模板为HTML字符串
    public async Task<string> RenderTemplateAsync<TModel>(string templateName, TModel model)
    {
        using var scope = _serviceProvider.CreateScope();
        var viewEngine = scope.ServiceProvider.GetRequiredService<IRazorViewEngine>();
        var tempDataProvider = scope.ServiceProvider.GetRequiredService<ITempDataProvider>();

        var viewResult = viewEngine.FindView(scope.ServiceProvider, templateName, false);
        if (!viewResult.Success)
        {
            throw new InvalidOperationException($"找不到模板 {templateName}");
        }

        using var writer = new StringWriter();
        var viewContext = new ViewContext(
            new ActionContext(scope.ServiceProvider.GetRequiredService<IHttpContextAccessor>().HttpContext, new RouteData(), new ActionDescriptor()),
            viewResult.View,
            new ViewDataDictionary<TModel>(tempDataProvider, new ModelStateDictionary()) { Model = model },
            new TempDataDictionary(scope.ServiceProvider.GetRequiredService<IHttpContextAccessor>().HttpContext, tempDataProvider),
            writer,
            new HtmlHelperOptions()
        );

        await viewResult.View.RenderAsync(viewContext);
        return writer.ToString();
    }
}

3. 注册自定义服务
   在 Program.cs 中替换默认的 IEmailSender：

builder.Services.AddTransient<IEmailSender, RazorEmailSender>();

4. 在注册逻辑中使用模板
   在注册完成后发送确认邮件时，调用模板渲染方法：

// 生成邮箱确认链接
var confirmToken = await _userManager.GenerateEmailConfirmationTokenAsync(user);
var callbackUrl = Url.Page(
    "/Account/ConfirmEmail",
    values: new { userId = user.Id, code = confirmToken },
    protocol: Request.Scheme);

// 渲染模板并发送邮件
var templateModel = new ConfirmEmailModel
{
    ConfirmLink = callbackUrl,
    UserName = user.UserName
};
var htmlContent = await _emailSender.RenderTemplateAsync("EmailTemplates/ConfirmEmail", templateModel);
await _emailSender.SendEmailAsync(user.Email, "确认您的邮箱", htmlContent);

二、用户注册完成后启动后台进程 #

使用.NET内置的后台任务队列实现，避免阻塞请求线程：

1. 定义后台任务队列接口

public interface IBackgroundTaskQueue
{
    void QueueBackgroundWorkItem(Func<CancellationToken, Task> workItem);
    Task<Func<CancellationToken, Task>> DequeueAsync(CancellationToken cancellationToken);
}

public class BackgroundTaskQueue : IBackgroundTaskQueue
{
    private readonly Channel<Func<CancellationToken, Task>> _queue;

    public BackgroundTaskQueue(int capacity)
    {
        var options = new BoundedChannelOptions(capacity)
        {
            FullMode = BoundedChannelFullMode.Wait
        };
        _queue = Channel.CreateBounded<Func<CancellationToken, Task>>(options);
    }

    public void QueueBackgroundWorkItem(Func<CancellationToken, Task> workItem)
    {
        if (workItem == null) throw new ArgumentNullException(nameof(workItem));
        _queue.Writer.TryWrite(workItem);
    }

    public async Task<Func<CancellationToken, Task>> DequeueAsync(CancellationToken cancellationToken)
    {
        return await _queue.Reader.ReadAsync(cancellationToken);
    }
}

2. 实现后台任务处理服务

public class QueuedHostedService : BackgroundService
{
    private readonly ILogger<QueuedHostedService> _logger;
    private readonly IBackgroundTaskQueue _taskQueue;

    public QueuedHostedService(IBackgroundTaskQueue taskQueue, ILogger<QueuedHostedService> logger)
    {
        _taskQueue = taskQueue;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _logger.LogInformation("后台任务服务已启动");

        while (!stoppingToken.IsCancellationRequested)
        {
            var workItem = await _taskQueue.DequeueAsync(stoppingToken);
            try
            {
                await workItem(stoppingToken);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "执行后台任务时出错");
            }
        }

        _logger.LogInformation("后台任务服务已停止");
    }
}

3. 注册后台服务与队列
   在 Program.cs 中添加：

builder.Services.AddSingleton<IBackgroundTaskQueue>(new BackgroundTaskQueue(100));
builder.Services.AddHostedService<QueuedHostedService>();

4. 在注册完成后触发后台任务
   在注册成功的逻辑末尾，将任务加入队列：

// 注册成功后添加后台任务
_taskQueue.QueueBackgroundWorkItem(async token =>
{
    _logger.LogInformation($"开始处理用户 {user.Id} 的注册后任务");
    // 这里编写实际后台逻辑：同步数据、生成统计、发送额外通知等
    await Task.Delay(3000, token); // 模拟耗时操作
    _logger.LogInformation($"完成用户 {user.Id} 的注册后任务");
});

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