1. 项目背景与痛点分析凌晨两点线上数据库磁盘爆满第二天早上才看到告警邮件的经历相信不少运维和开发同学都深有体会。这种延迟通知导致的业务损失在AI Agent逐渐普及的今天显得尤为突出。当我们将代码生成、数据分析、文档整理等耗时任务交给AI Agent异步处理后如何实时获取任务状态成为关键需求。传统通知方案存在明显短板邮件通知容易被淹没在收件箱中时效性差短信通知成本高且内容展示有限专用APP需要用户额外安装维护Webhook对接实现复杂且依赖特定平台微信作为国民级应用具有以下不可替代的优势近实时到达3秒内锁屏弹窗声音提醒无需额外安装支持富文本详情页个人开发者可免费使用测试号10万次/日额度2. 技术方案设计2.1 整体架构项目采用极简设计哲学核心功能仅依赖微信公众平台测试号接口.NET 9 Minimal API嵌入式HTML资源graph TD A[HTTP请求] -- B[WXPush服务] B -- C[微信服务器] C -- D[用户微信]2.2 关键技术选型.NET 9 Minimal API相比传统MVC启动速度快3倍内存占用减少40%单文件即可包含完整路由逻辑零第三方依赖使用System.Text.Json处理JSON内置HttpClient进行微信API调用避免NuGet包版本冲突问题嵌入式资源详情页HTML编译进DLL支持Markdown渲染展示静态资源与代码一体部署3. 实现细节解析3.1 微信接口对接需要获取的4个关键参数appID/appsecret测试号凭证openid接收者身份标识template_id消息模板ID模板消息必须包含至少一个DATA字段{ touser: OPENID, template_id: TEMPLATE_ID, data: { title: {value:磁盘告警}, content: {value:使用率95%} } }3.2 核心代码逻辑Program.cs关键结构var builder WebApplication.CreateBuilder(args); var app builder.Build(); app.MapMethods(/wxsend, [GET, POST], async (HttpRequest req) { // 1. 参数解析 // 2. 微信access_token获取 // 3. 模板消息组装 // 4. API请求发送 }); app.Run();3.3 消息详情页实现通过嵌入式资源加载HTML!DOCTYPE html html head title{{title}}/title link relstylesheet hrefhttps://cdn.jsdelivr.net/npm/github-markdown-css /head body div classmarkdown-body {{content}} /div /body /html4. 部署与使用指南4.1 本地开发运行dotnet run -- \ -appid wx123456789 \ -secret abcdefghijklmnopqrstuvwxyz \ -userid o6_bm123456789 \ -template_id 12345678904.2 Docker生产部署FROM mcr.microsoft.com/dotnet/sdk:9.0 AS build WORKDIR /src COPY . . RUN dotnet publish -c Release -o /app FROM mcr.microsoft.com/dotnet/aspnet:9.0 WORKDIR /app COPY --frombuild /app . ENTRYPOINT [dotnet, CSharp-WXPush.dll]4.3 调用示例GET请求curl http://localhost:5566/wxsend?title任务完成contentAI生成100篇文档POST请求import requests requests.post(http://your-server:5566/wxsend, json{title:模型训练, content:准确率提升至98.2%})5. 典型应用场景5.1 AI Agent任务监控def agent_callback(task): status 成功 if task.success else 失败 requests.get(fhttp://wxpush:5566/wxsend, params{ title: fAgent任务{status}, content: f 任务名称: {task.name} 开始时间: {task.start_time} 耗时: {task.duration} 详细结果: {task.result[:200]}... })5.2 自动化运维告警# 磁盘检测脚本 df -h | awk $5 90 {print $6} | xargs -I {} curl \ http://wxpush:5566/wxsend?title磁盘告警content挂载点{}使用率超过90%5.3 CI/CD集成GitHub Actions配置示例- name: 微信通知 run: | curl -X POST http://wxpush:5566/wxsend \ -H Content-Type: application/json \ -d { title: 构建${{ job.status }}, content: 仓库: ${{ github.repository }}\n分支: ${{ github.ref }}\n提交: ${{ github.sha }} }6. 性能优化建议AccessToken缓存微信access_token有效期为2小时建议内存缓存避免频繁获取批量消息处理app.MapPost(/batchsend, async (ListWxMessage messages) { var token await GetAccessToken(); await Task.WhenAll(messages.Select(m SendWeChat(m, token))); });速率限制微信接口限制200次/分钟建议本地实现令牌桶算法7. 常见问题排查问题现象可能原因解决方案消息发送失败access_token过期检查token获取时间详情页无法打开base_url配置错误确保公网可访问模板内容空白未包含固定文案模板中增加前缀文本用户未收到消息未关注测试号重新扫码关注8. 扩展开发方向多渠道通知企业微信钉钉Slack消息模板管理动态模板配置模板变量校验消息队列集成app.MapPost(/queue, async (WxMessage msg) { await _queueClient.SendAsync(msg); return Results.Accepted(); });实际使用中发现当AI Agent处理视频生成等长任务时结合进度推送特别实用。比如每完成10%推送一次进度最后推送成品下载链接。这种实时反馈机制能显著提升人机协作效率。 基于.NET 9与微信API的实时消息推送系统实践
1. 项目背景与痛点分析凌晨两点线上数据库磁盘爆满第二天早上才看到告警邮件的经历相信不少运维和开发同学都深有体会。这种延迟通知导致的业务损失在AI Agent逐渐普及的今天显得尤为突出。当我们将代码生成、数据分析、文档整理等耗时任务交给AI Agent异步处理后如何实时获取任务状态成为关键需求。传统通知方案存在明显短板邮件通知容易被淹没在收件箱中时效性差短信通知成本高且内容展示有限专用APP需要用户额外安装维护Webhook对接实现复杂且依赖特定平台微信作为国民级应用具有以下不可替代的优势近实时到达3秒内锁屏弹窗声音提醒无需额外安装支持富文本详情页个人开发者可免费使用测试号10万次/日额度2. 技术方案设计2.1 整体架构项目采用极简设计哲学核心功能仅依赖微信公众平台测试号接口.NET 9 Minimal API嵌入式HTML资源graph TD A[HTTP请求] -- B[WXPush服务] B -- C[微信服务器] C -- D[用户微信]2.2 关键技术选型.NET 9 Minimal API相比传统MVC启动速度快3倍内存占用减少40%单文件即可包含完整路由逻辑零第三方依赖使用System.Text.Json处理JSON内置HttpClient进行微信API调用避免NuGet包版本冲突问题嵌入式资源详情页HTML编译进DLL支持Markdown渲染展示静态资源与代码一体部署3. 实现细节解析3.1 微信接口对接需要获取的4个关键参数appID/appsecret测试号凭证openid接收者身份标识template_id消息模板ID模板消息必须包含至少一个DATA字段{ touser: OPENID, template_id: TEMPLATE_ID, data: { title: {value:磁盘告警}, content: {value:使用率95%} } }3.2 核心代码逻辑Program.cs关键结构var builder WebApplication.CreateBuilder(args); var app builder.Build(); app.MapMethods(/wxsend, [GET, POST], async (HttpRequest req) { // 1. 参数解析 // 2. 微信access_token获取 // 3. 模板消息组装 // 4. API请求发送 }); app.Run();3.3 消息详情页实现通过嵌入式资源加载HTML!DOCTYPE html html head title{{title}}/title link relstylesheet hrefhttps://cdn.jsdelivr.net/npm/github-markdown-css /head body div classmarkdown-body {{content}} /div /body /html4. 部署与使用指南4.1 本地开发运行dotnet run -- \ -appid wx123456789 \ -secret abcdefghijklmnopqrstuvwxyz \ -userid o6_bm123456789 \ -template_id 12345678904.2 Docker生产部署FROM mcr.microsoft.com/dotnet/sdk:9.0 AS build WORKDIR /src COPY . . RUN dotnet publish -c Release -o /app FROM mcr.microsoft.com/dotnet/aspnet:9.0 WORKDIR /app COPY --frombuild /app . ENTRYPOINT [dotnet, CSharp-WXPush.dll]4.3 调用示例GET请求curl http://localhost:5566/wxsend?title任务完成contentAI生成100篇文档POST请求import requests requests.post(http://your-server:5566/wxsend, json{title:模型训练, content:准确率提升至98.2%})5. 典型应用场景5.1 AI Agent任务监控def agent_callback(task): status 成功 if task.success else 失败 requests.get(fhttp://wxpush:5566/wxsend, params{ title: fAgent任务{status}, content: f 任务名称: {task.name} 开始时间: {task.start_time} 耗时: {task.duration} 详细结果: {task.result[:200]}... })5.2 自动化运维告警# 磁盘检测脚本 df -h | awk $5 90 {print $6} | xargs -I {} curl \ http://wxpush:5566/wxsend?title磁盘告警content挂载点{}使用率超过90%5.3 CI/CD集成GitHub Actions配置示例- name: 微信通知 run: | curl -X POST http://wxpush:5566/wxsend \ -H Content-Type: application/json \ -d { title: 构建${{ job.status }}, content: 仓库: ${{ github.repository }}\n分支: ${{ github.ref }}\n提交: ${{ github.sha }} }6. 性能优化建议AccessToken缓存微信access_token有效期为2小时建议内存缓存避免频繁获取批量消息处理app.MapPost(/batchsend, async (ListWxMessage messages) { var token await GetAccessToken(); await Task.WhenAll(messages.Select(m SendWeChat(m, token))); });速率限制微信接口限制200次/分钟建议本地实现令牌桶算法7. 常见问题排查问题现象可能原因解决方案消息发送失败access_token过期检查token获取时间详情页无法打开base_url配置错误确保公网可访问模板内容空白未包含固定文案模板中增加前缀文本用户未收到消息未关注测试号重新扫码关注8. 扩展开发方向多渠道通知企业微信钉钉Slack消息模板管理动态模板配置模板变量校验消息队列集成app.MapPost(/queue, async (WxMessage msg) { await _queueClient.SendAsync(msg); return Results.Accepted(); });实际使用中发现当AI Agent处理视频生成等长任务时结合进度推送特别实用。比如每完成10%推送一次进度最后推送成品下载链接。这种实时反馈机制能显著提升人机协作效率。