ABP VNext + Twilio:全渠道通知服务(SMS/Email/WhatsApp) 🚀


📚 目录

  • ABP VNext + Twilio:全渠道通知服务(SMS/Email/WhatsApp) 🚀
    • 一、引言 ✨
    • 二、环境与依赖 🛠️
    • 三、系统架构概览 🏗️
    • 四、Secrets 管理 🔑
    • 五、本地开发 Secrets 模拟 🏠
    • 六、客户端封装与插件化 🔌
    • 七、模板管理 📄
    • 八、事务与 Outbox 模式 🔄
    • 九、Quartz 调度与清理作业 ⏰
      • 9.1 投递调度
      • 9.2 清理作业
    • 十、监控与健康检查 📊❤️‍🩹
    • 十一、Twilio Webhook 与安全 🔒
    • 十二、死信补偿 🎯
    • 参考文档 📄


一、引言 ✨

  • 📝 TL;DR

    1. 📡 使用 Twilio SDK + SendGrid 在 ABP VNext 中统一封装 SMS、Email、WhatsApp 通道
    2. ⚙️ 单例 RazorLight 引擎模板渲染,一行代码推送多渠道
    3. 🔄 Outbox + Quartz + ABP Unit of Work 保证事务一致与高可用异步投递
    4. 🔑 Azure Key Vault 管理密钥;🐇 RabbitMQ 死信;📈 Prometheus 指标;❤️‍🩹 Health Checks;🗑 Quartz 清理

现代应用需在用户注册、订单状态、营销推送等场景并发多渠道通知。原生调用缺少模板化、事务保障、限流重试、安全存储和监控。


二、环境与依赖 🛠️

  • 平台:.NET 6 + ABP VNext 6.x

  • NuGet 包

    <PackageReference Include="Twilio" Version="5.*" />
    <PackageReference Include="SendGrid" Version="10.*" />
    <PackageReference Include="RazorLight" Version="2.*" />
    <PackageReference Include="Volo.Abp.BackgroundJobs" Version="6.*" />
    <PackageReference Include="Quartz.Extensions.Hosting" Version="3.*" />
    <PackageReference Include="Polly" Version="7.*" />
    <PackageReference Include="DistributedLock.Core" Version="6.*" />
    <PackageReference Include="Microsoft.Extensions.HealthChecks" Version="7.*" />
    <PackageReference Include="prometheus-net.AspNetCore" Version="7.*" />
    <PackageReference Include="Azure.Extensions.AspNetCore.Configuration.Secrets" Version="1.*" />
    <PackageReference Include="Microsoft.Azure.KeyVault" Version="4.*" />
    <PackageReference Include="RabbitMQ.Client" Version="7.*" />
    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.*" />
    
  • appsettings.json 示例

    {"KeyVault": {"Enabled": true,"VaultUri": "https://your-vault.vault.azure.net/"},"Twilio": { /*…*/ },"SendGrid": { /*…*/ },"Notification": {"MaxParallelism": 5,"QuartzCron": "0/30 * * * * ?","DeadLetterQueue": "notification.dlx"}
    }
    

三、系统架构概览 🏗️

平台与运维
调度层
核心模块
应用层
调用
Quartz Timer
限流/重试
失败后
指标
SMS/Email/WhatsApp
Webhook 回调
CallbackController
Metrics Endpoint
/health
Health Checks
OutboxJobScheduler
OutboxJobProcessor
Twilio/SendGridClient
RabbitMQ DeadLetter
Prometheus
NotificationService
NotificationOutbox
INotificationService
ApplicationService

四、Secrets 管理 🔑

public override void ConfigureServices(ServiceConfigurationContext context)
{var cfg = context.Services.GetConfiguration();if (cfg.GetValue<bool>("KeyVault:Enabled")){context.ConfigurationBuilder.AddAzureKeyVault(new Uri(cfg["KeyVault:VaultUri"]),new DefaultAzureCredential());}context.Services.Configure<TwilioOptions>(cfg.GetSection("Twilio"));context.Services.Configure<SendGridOptions>(cfg.GetSection("SendGrid"));// …
}

Tip:生产环境通过 Key Vault 托管密钥,安全可靠。


五、本地开发 Secrets 模拟 🏠

# 使用 .NET 用户机密存储
dotnet user-secrets init
dotnet user-secrets set "Twilio:AccountSid" "local-sid"
dotnet user-secrets set "Twilio:AuthToken"  "local-token"
dotnet user-secrets set "SendGrid:ApiKey"    "local-sendgrid-key"

本地调试时,appsettings.json 不包含敏感信息,使用用户机密模拟 Key Vault。


六、客户端封装与插件化 🔌

  1. 通道抽象

    public interface IChannelSender
    {Channel Channel { get; }Task SendAsync(string payloadJson, CancellationToken token = default);
    }
    
  2. SmsSender

    public class SmsSender : IChannelSender, ITransientDependency
    {public Channel Channel => Channel.SMS;private readonly TwilioOptions _opts;public SmsSender(IOptions<TwilioOptions> opts) => _opts = opts.Value;public Task SendAsync(string payloadJson, CancellationToken token = default){var p = JsonSerializer.Deserialize<SmsPayload>(payloadJson)!;var client = new TwilioRestClient(_opts.AccountSid, _opts.AuthToken);return client.Messages.CreateAsync(to: new PhoneNumber(p.To),from: new PhoneNumber(_opts.FromPhone),body: p.Body, cancellationToken: token);}
    }
    
  3. EmailSender、WhatsAppSender 类似,均注入 CancellationToken 支持。

  4. 核心服务

    public class NotificationService : INotificationService, ITransientDependency
    {public async Task SendAsync(Channel channel, string templateKey, object model, string to, string? subjectKey = null){var body = await _tplMgr.RenderAsync($"{channel}/{templateKey}.cshtml", model);var subject = subjectKey == null ? null : await _tplMgr.RenderAsync($"Email/Subject_{subjectKey}.txt", model);var payload = JsonSerializer.Serialize(new { To = to, Subject = subject, Body = body });_db.NotificationOutboxes.Add(new NotificationOutbox(channel, payload));await _uow.SaveChangesAsync(); }
    }
    

七、模板管理 📄

public class RazorLightTemplateManager : ITemplateManager, ISingletonDependency
{private readonly RazorLightEngine _engine;public RazorLightTemplateManager(IConfiguration config){_engine = new RazorLightEngineBuilder().UseFileSystemProject(Path.Combine(AppContext.BaseDirectory, "Templates")).UseMemoryCachingProvider().Build();}public Task<string> RenderAsync(string key, object model) =>_engine.CompileRenderAsync(key, model);
}
/Templates├─ SMS/Sms_VerifyCode.cshtml├─ Email/Subject_OrderShipped.txt├─ Email/OrderShipped.cshtml└─ WhatsApp/Promotion.cshtml

八、事务与 Outbox 模式 🔄

public class NotificationOutbox : Entity<Guid>
{public Channel Channel { get; set; }public string Payload  { get; set; }public bool IsSent     { get; set; }public DateTime CreatedTime { get; set; }public int RetryCount  { get; set; }  // 死信限次public NotificationOutbox(Channel ch, string payload){Id = Guid.NewGuid();Channel = ch; Payload = payload;IsSent = false; RetryCount = 0;CreatedTime = DateTime.UtcNow;}
}

Tip:新增 RetryCount 字段,避免死信循环。


九、Quartz 调度与清理作业 ⏰

9.1 投递调度

public class OutboxJobProcessor : IJob, ISingletonDependency
{private readonly CancellationTokenSource _cts = new();public async Task Execute(IJobExecutionContext _){var batch = await _db.NotificationOutboxes.Where(x=>!x.IsSent && x.RetryCount < 5).Take(NotificationConsts.MaxParallelism).ToListAsync(_cts.Token);foreach (var e in batch){try{using (_latency.NewTimer())using (await _lock.AcquireLockAsync($"lock-{e.Id}", TimeSpan.FromSeconds(30))){await Policy.WrapAsync(Policy.BulkheadAsync(NotificationConsts.MaxParallelism, int.MaxValue),Policy.RateLimitAsync(10, TimeSpan.FromSeconds(1)),Policy.Handle<Exception>().WaitAndRetryAsync(retryCount:3, sleepDurationProvider: i=>TimeSpan.FromSeconds(Math.Pow(2, i)),onRetry: (ex, _, i, _) => {e.RetryCount++;_logger.LogWarning("Outbox {Id} 第 {Count} 次重试", e.Id, i);})).ExecuteAsync(ct=> ProcessAsync(e, ct), _cts.Token);}_total.Inc();}catch (Exception ex){_logger.LogError(ex, "Outbox({Id}) 失败,转死信队列", e.Id);_rabbit.BasicPublish("", _opts.DeadLetterQueue, null, Encoding.UTF8.GetBytes(e.Payload));}}}public Task StopAsync() => Task.Run(() => _cts.Cancel());private async Task ProcessAsync(NotificationOutbox e, CancellationToken token){var sender = _senders.First(s=>s.Channel==e.Channel);await sender.SendAsync(e.Payload, token);e.IsSent = true;await _db.SaveChangesAsync(token);}
}

9.2 清理作业

public class OutboxCleanupJob : IJob, ISingletonDependency
{public async Task Execute(IJobExecutionContext _){var cutoff = DateTime.UtcNow.AddDays(-30);var toDel = await _db.NotificationOutboxes.Where(x=>x.IsSent && x.CreatedTime<cutoff).Take(1000).ToListAsync();_db.RemoveRange(toDel);await _db.SaveChangesAsync();}
}

十、监控与健康检查 📊❤️‍🩹

// Startup.ConfigureServices
services.AddHealthChecks().AddSqlServer(cfg.GetConnectionString("Default"), name:"sql").AddRabbitMQ(cfg["Notification:DeadLetterQueue"], name:"rabbitmq").AddUrlGroup("https://api.twilio.com", name:"twilio").AddUrlGroup("https://api.sendgrid.com", name:"sendgrid");app.UseHttpMetrics(); // Prometheus /metrics
app.UseEndpoints(e=>{e.MapHealthChecks("/health");e.MapMetrics();
});

十一、Twilio Webhook 与安全 🔒

[HttpPost("twilio-callback"), EnableRateLimiting("Default")]
public async Task<IActionResult> TwilioCallback(CancellationToken token)
{var req = Request; var form = await req.ReadFormAsync(token);var sig = req.Headers["X-Twilio-Signature"].FirstOrDefault()!;var url = $"{req.Scheme}://{req.Host}{req.Path}";var validator = new RequestValidator(_opts.AuthToken);if (!validator.Validate(url, form.ToDictionary(k=>k.Key, v=>v.Value.ToString()), sig))return Unauthorized();var sid = form["MessageSid"].ToString();var status = form["MessageStatus"].ToString();var e = await _db.NotificationOutboxes.Where(x=>x.Payload.Contains(sid)).FirstOrDefaultAsync(token);if (e!=null){e.IsSent = status=="delivered";await _db.SaveChangesAsync(token);}return Ok();
}

十二、死信补偿 🎯

public class DeadLetterConsumer : BackgroundService
{protected override Task ExecuteAsync(CancellationToken ct){var channel = _rabbit.CreateModel();channel.BasicConsume("notification.dlx", false, new EventingBasicConsumer(channel){Received = async (_, ea) =>{if (ct.IsCancellationRequested) return;var payload = Encoding.UTF8.GetString(ea.Body.ToArray());await _db.NotificationOutboxes.AddAsync(new NotificationOutbox(Channel.SMS, payload), ct);await _db.SaveChangesAsync(ct);channel.BasicAck(ea.DeliveryTag, false);}});return Task.CompletedTask;}
}

参考文档 📄

  • Twilio 官方文档
  • SendGrid C# 快速入门
  • Quartz Scheduler 文档
  • prometheus-net GitHub
  • Azure Key Vault 文档
  • RabbitMQ 文档

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/bicheng/87398.shtml
繁体地址,请注明出处:http://hk.pswp.cn/bicheng/87398.shtml
英文地址,请注明出处:http://en.pswp.cn/bicheng/87398.shtml

如若内容造成侵权/违法违规/事实不符,请联系英文站点网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

电脑一体机,收银机画面显示不全——深入解析 BIOS 配置电脑分辨率——东方仙盟

在电脑的复杂体系中&#xff0c;BIOS&#xff08;基本输入输出系统&#xff09;虽深藏幕后&#xff0c;但其对电脑分辨率的配置却有着至关重要的影响。理解 BIOS 配置电脑分辨率的作用与意义&#xff0c;有助于我们更深入地挖掘电脑的性能潜力&#xff0c;优化视觉体验。 一、…

arm系统移植

目录 1. 流程2. 概念2.1 设备树2.2 根文件系统2.3 文件说明 3. 交叉编译链3.1 作用3.2 在linux下配置 4. tftp4.1 作用4.2 安装过程 5. nfs5.1 作用5.2 安装过程 6. 配置开发板7. linux下的uboot镜像烧写到SD卡中7.1 生成uboot二进制文件&#xff0c;二进制文件就是裸机程序。7…

量子算法入门——5.Qiskit库介绍与简单应用(2)

参考资料&#xff1a; 【【零基础入门量子计算】】 来自b站up&#xff1a;溴锑锑跃迁 建议关注他的更多高质量文章&#xff1a;CSDN&#xff1a;【溴锑锑跃迁】 &#xff08;实际上只带一点点原创&#xff0c;绝大部分资料来自这位大佬&#xff09; 跟着视频我手打了一遍notebo…

前端如何优雅地实现一个“请求队列”,避免服务器被卡死?

有这样一些场景&#xff1a; 页面一加载&#xff0c;需要同时发 10 个请求&#xff0c;结果页面卡住&#xff0c;服务器也快崩了。用户可以批量操作&#xff0c;一次点击触发了几十个上传文件的请求&#xff0c;浏览器直接转圈圈。 当后端处理不过来时&#xff0c;前端一股脑…

SSL/TLS协议信息泄露漏洞(CVE-2016-2183)、SSL/TLS RC4 信息泄露漏洞(CVE-2013-2566)修复方法

目录 一、问题原因二、整改步骤 一、问题原因 通过绿盟漏洞检测工具扫描发现Windows系统存在SSL/TLS协议信息泄露漏洞(CVE-2016-2183)、SSL/TLS RC4 信息泄露漏洞(CVE-2013-2566)、SSL/TLS 受诫礼(BAR-MITZVAH)攻击漏洞(CVE-2015-2808)。 二、整改步骤 使用gpedit.msc进入组…

MinHook 如何对 .NET 母体 CoreCLR 进行拦截

一&#xff1a;背景 1. 讲故事 这篇文章起源于和一家 .NET公司 开线上会议时&#xff0c;提出的一个场景问题&#xff0c;程序出现了非托管内存暴涨&#xff0c;这些非托管内存关联的对象都囤积在 终结器队列 中&#xff0c;很显然这是代码中没用 using 及时释放引发的&#…

DPI深度检索原理和架构

大家读完觉得有帮助记得关注和点赞&#xff01;&#xff01;&#xff01; DPI&#xff08;深度包检测&#xff09;技术通过**透视网络载荷内容**实现精细化流量管控与威胁检测&#xff0c;其核心在于突破传统防火墙仅检查IP/端口等表层信息的局限&#xff0c;对**应用层数据**进…

QT Creator的返回到上一步、下一步的快捷键是什么?

在 Qt Creator 中&#xff0c;用于导航的 返回上一步 (Back) 和 前进下一步 (Forward) 的快捷键如下&#xff1a; 默认快捷键&#xff1a; 功能Windows/LinuxmacOS返回上一步Alt ←Command [前进下一步Alt →Command ]

UI前端大数据处理策略优化:基于云计算的数据存储与计算

hello宝子们...我们是艾斯视觉擅长ui设计、前端开发、数字孪生、大数据、三维建模、三维动画10年经验!希望我的分享能帮助到您!如需帮助可以评论关注私信我们一起探讨!致敬感谢感恩! 一、引言&#xff1a;大数据时代前端处理的挑战与云计算破局 在数字化转型的浪潮中&#xff…

机器学习基础 多层感知机

机器学习基础 多层感知机 文章目录 机器学习基础 多层感知机1. 多层感知机1.1 线性模型的失效1.2 感知机1.3 感知机的收敛定理1.4 从线性到非线性1.5 多层感知机的定义和实现 参考 1. 多层感知机 1.1 线性模型的失效 ​ 在李沐《动手学深度学习》中有这样的描述&#xff1a; …

关于安装Ollama大语言模型本地部署工具

一、Ollama 安装方法概述 Ollama 是一个开源的大型语言模型(LLM)本地部署工具&#xff0c;支持在 Windows、macOS 和 Linux 系统上运行。它简化了在本地计算机上运行和管理大语言模型的流程&#xff0c;让开发者能够轻松部署各种开源模型。 Windows 系统安装步骤 访问 Ollam…

html配置rem实现页面自适应

1.在js文件使用&#xff0c;建议放到全局js中 // 全局js文件 $(function () {// 设置根目录字体大小var baseSize 16; // 设计稿的基准字体大小&#xff0c;通常是16pxvar baseWidth 750; // 设计稿的基准宽度&#xff0c;通常是750pxfunction adjustFontSize() {const widt…

POI实现文档的图片的提取和替换

1. 简介 在日常办公自动化开发中&#xff0c;常常需要对 Word 文档中的图片进行批量提取、保存&#xff0c;甚至将图片替换为自定义的文本或链接。Apache POI 是一款强大的 Java 开源库&#xff0c;支持对 Microsoft Office 文档&#xff08;包括 Word、Excel、PowerPoint 等&…

毫米波雷达 – 深度学习

目录 数据表示 公开数据库 未来发展方向 稀疏点云 + 深度学习 直接处理点云 (1/2) 候选生成+特征提取+候选分类(DL* ) 候选生成+特征提取+候选分类(DL) 直接处理点云 (2/2) 候选生成+特征提取(DL)+候选分类(DL) 网格数据+端对端检测(DL) 稠密数据块 + 深度学习 直接…

Redis——常用指令汇总指南(一)

目录 1.set & get ①set指令 ②get指令 2.keys 3.del 4.expire & setex & psetex 5.ttl 6.exists 7.setnx 8.flushall 9.object encoding 10. type 1.set & get set & get指令中key和value都是字符串&#xff0c;但是不需要加单引号或双引号。 …

PDF处理控件Aspose.PDF教程:在 Java 中删除 PDF 页面

您是否需要使用 Java 从PDF文档中删除特定页面&#xff1f;无论您是要清理空白页、删除机密部分&#xff0c;还是仅仅在分发前调整内容&#xff0c;以编程方式操作 PDF 页面的能力都将大有裨益。本指南将向您展示如何借助Aspose.PDF仅用几行代码删除不需要的页面。让我们深入了…

RediSearch 字段类型与配置选项

1. 数值字段&#xff08;NUMERIC&#xff09; 用途&#xff1a;存储整数或浮点数&#xff0c;可进行范围查询与排序。 选项&#xff1a; SORTABLE&#xff1a;允许用 SORTBY 排序NOINDEX&#xff1a;不参与索引&#xff0c;仅供返回 定义语法 FT.CREATE idx ON HASH PREFIX…

PHP Yii2 安装SQL Server扩展-MAC M4 Pro芯片

MAC M4 Pro芯片版本&#xff0c;千锤百炼编译十几次终于成功 # 设置基础镜像并强制使用 x86_64 架构&#xff08;适配 M4 芯片&#xff09; FROM --platformlinux/amd64 php:8.1-fpm-alpine3.18WORKDIR /var/www/html# 可选&#xff1a;设置时区 ARG TZAsia/Shanghai ENV TZ${…

HTML初学者第二天

<1>HTML的语法规范 1.1标签 -双标签&#xff1a;如 <html></html> 前面的叫开始标签&#xff0c;后面的叫结束标签。 -单标签&#xff1a;如 <br /> 1.2基本语法概述 -HTML标签是由尖括号包围的关键词&#xff0c;例如<html>。 -HTML标…

【加解密与C】HASH系列(二) SHA

SHA&#xff08;安全散列算法&#xff09;简介 SHA&#xff08;Secure Hash Algorithm&#xff09;是由美国国家安全局&#xff08;NSA&#xff09;设计的一系列密码散列函数&#xff0c;用于将任意长度的数据转换为固定长度的散列值。SHA家族包括SHA-1、SHA-2&#xff08;含S…