基于.NET构建的企业级SaaSAI智能体应用架构，采用前后端分离设计，具备以下核心特性：
NetCoreKevin 是一个 AI Agent 框架，内置了丰富的工具（如 HTTP 请求、Python 执行、Shell 命令等）。通过集成 Hangfire 分布式任务调度库，AI 能够自主创建、管理和触发周期性自动任务，让智能体不仅能实时响应，还能按预定计划自动完成日常工作（如定时生成报告、数据同步、内容总结等）。本文将详细介绍如何在 NetCoreKevin 中实现 AI 与 Hangfire 的完美结合。
整体架构分为三层：
KevinAIAllTools) ：负责将服务接口中的方法注册为 AI 可调用的函数工具。IKevinAITasksService) ：定义了定时任务的增删改查及手动触发操作。KevinAITasksService) ：基于 Hangfire 的 IRecurringJobManager 实现任务的持久化调度，并通过 RunTask 方法真正执行任务内容（可接入 AI 处理逻辑）。调用流程：
用户自然语言指令 → AI Agent 解析 → 调用对应工具函数 → 操作 Hangfire 任务 → 定时/手动触发 RunTask → 执行实际任务（可调用 AI 或其他服务）。
需安装以下 NuGet 包（根据存储后端选择相应包）：
dotnet add package Hangfire.Core
dotnet add package Hangfire.SqlServer # 以 SQL Server 为例，也可选 Redis/PostgreSQL 等
在 Startup.cs 或 Program.cs 中注册 Hangfire 服务、任务服务以及框架所需的其他服务：
services.AddHangfire(config =>
{
config.UseSqlServerStorage("YourConnectionString");
});
services.AddHangfireServer(); // 启动 Hangfire 后台处理服务器
// 注册自定义任务服务（生命周期需与 Hangfire 匹配，建议 Scoped 或 Singleton）
services.AddScoped<IKevinAITasksService, KevinAITasksService>();
// 确保 IHttpContextAccessor 已注入（BaseService 依赖）
services.AddHttpContextAccessor();
KevinAITasksService 的构造函数注入了 IRecurringJobManager 和 JobStorage，这些由 Hangfire 自动提供。
IKevinAITasksService/// <summary>
/// 用于给AI使用的自动任务服务接口，提供自动任务相关的功能和操作
/// 你可以让它在每天、每周、每月，或者某个固定时间自动运行，帮助你完成常见的日常工作。
/// </summary>
public interface IKevinAITasksService
{
/// <summary>
/// 创建或更新一个周期性自动任务
/// </summary>
Task<string> AddOrUpdateCronTask(
[Description("任务名称，不可为空")] string name,
[Description("任务内容，不可为空")] string content,
[Description("Cron 表达式，定义执行周期")] string cronExpression);
/// <summary>
/// 移除周期性任务
/// </summary>
Task<string> RemoveCronTask([Description("任务名称")] string name);
/// <summary>
/// 立即触发某个周期性任务一次
/// </summary>
Task<string> TriggerCronTask([Description("任务名称")] string name);
/// <summary>
/// 获取当前用户的所有周期性任务列表
/// </summary>
Task<List<string>> GetTaskList();
/// <summary>
/// 执行具体的任务内容（由 Hangfire 调度调用）
/// </summary>
Task<string> RunTask(string taskName, string taskContent);
}
KevinAITasksService该实现通过 Hangfire 的 IRecurringJobManager 完成周期性任务的管理，并用 CurrentUser.UserId 作为任务 ID 前缀实现用户隔离。
public class KevinAITasksService : BaseService, IKevinAITasksService
{
private readonly IRecurringJobManager _recurringJobManager;
private readonly JobStorage _jobStorage;
public KevinAITasksService(IHttpContextAccessor httpContextAccessor,
IRecurringJobManager recurringJobManager,
JobStorage jobStorage) : base(httpContextAccessor)
{
_recurringJobManager = recurringJobManager;
_jobStorage = jobStorage;
}
public Task<string> AddOrUpdateCronTask(string name, string content, string cronExpression)
{
_recurringJobManager.AddOrUpdate<IKevinAITasksService>(
recurringJobId: CurrentUser.UserId + name, // 用户隔离
methodCall: s => s.RunTask(name, content),
cronExpression: cronExpression,
options: new RecurringJobOptions { TimeZone = TimeZoneInfo.Local }
);
return Task.FromResult($"添加或更新定时任务成功：{name} - {content}");
}
public Task<List<string>> GetTaskList()
{
var storage = _jobStorage ?? JobStorage.Current;
var connection = storage.GetConnection();
var recurringJobs = connection.GetRecurringJobs();
var result = recurringJobs
.Where(t => t.Id.StartsWith(CurrentUser.UserId.ToString()))
.Select(r => $"name:{r.Id} | Cron:{r.Cron} | Next:{r.NextExecution?.ToLocalTime():u} | Last:{r.LastExecution?.ToLocalTime():u}")
.ToList();
return Task.FromResult(result);
}
public Task<string> RemoveCronTask(string name)
{
_recurringJobManager.RemoveIfExists(CurrentUser.UserId + name);
return Task.FromResult($"移除定时任务成功：{name}");
}
public Task<string> TriggerCronTask(string name)
{
_recurringJobManager.Trigger(CurrentUser.UserId + name);
return Task.FromResult($"手动触发任务成功：{name}");
}
public Task<string> RunTask(string taskName, string taskContent)
{
// 此处可接入真实的 AI 处理逻辑，例如：
// var aiService = GetRequiredService<IMyAIService>();
// string result = await aiService.ProcessTaskAsync(taskContent);
Console.WriteLine($"[{CurrentUser.UserId}] 执行任务：{taskName}，内容：{taskContent}");
return Task.FromResult($"任务已执行：{taskName}");
}
}
注意：
RunTask方法是任务真正执行的入口，可以根据项目需求注入其他服务（如 AI 对话客户端、数据库操作等）来完成复杂工作。
KevinAIAllTools在框架的工具聚合类中，通过依赖注入获取 IKevinAITasksService 实例，并将其方法注册为 AI 可识别的工具函数。
public class KevinAIAllTools
{
public async Task<List<AITool>> GetKevinAIAllTools(IServiceProvider serviceProvider)
{
var tools = new List<AITool>
{
// ... 其他工具（HTTP、Shell、Python 等）
};
// 如果服务容器中存在 IKevinAITasksService，注册任务相关工具
var taskService = serviceProvider.GetService<IKevinAITasksService>();
if (taskService != null)
{
tools.Add(AIFunctionFactory.Create(
taskService.AddOrUpdateCronTask,
new AIFunctionFactoryOptions
{
Name = "AddOrUpdateCronTask",
Description = "创建或更新一个周期性自动任务"
}));
tools.Add(AIFunctionFactory.Create(
taskService.RemoveCronTask,
new AIFunctionFactoryOptions { Name = "RemoveCronTask", Description = "移除周期性任务" }));
tools.Add(AIFunctionFactory.Create(
taskService.TriggerCronTask,
new AIFunctionFactoryOptions { Name = "TriggerCronTask", Description = "立即触发某个周期性任务一次" }));
tools.Add(AIFunctionFactory.Create(
taskService.GetTaskList,
new AIFunctionFactoryOptions { Name = "GetTaskList", Description = "获取我的所有周期性任务列表" }));
}
return tools;
}
}
这样，当 AI Agent 初始化时，就会自动加载这些定时任务管理工具。
用户：
“帮我创建一个任务，每天早上8点总结前一天的AI领域新闻，并将结果保存到桌面。”
每日AI新闻总结搜索并总结过去24小时AI领域的重要新闻，生成简报并保存为桌面文件0 0 8 * * ?（每天8点）AddOrUpdateCronTask(name, content, cronExpression)，底层通过 Hangfire 创建循环作业。当时间到达时，Hangfire 会自动调用 IKevinAITasksService.RunTask("每日AI新闻总结", "搜索并总结过去24小时...")。
你可以在 RunTask 方法中实现真正的业务逻辑，例如调用 OpenAI 接口生成总结，再利用 WriteTextToDesktop 工具写入文件。
GetTaskList 返回列表。RemoveCronTask("每日AI新闻总结")。TriggerCronTask("每日AI新闻总结")。CurrentUser.UserId + name 的形式，确保不同用户的任务互不干扰。GetTaskList 也通过过滤 ID 前缀返回当前用户的任务。AddOrUpdateCronTask 中增加格式检查，防止非法表达式导致异常。KevinAITasksService 依赖于当前登录用户（通过 IHttpContextAccessor），确保任务管理限制在用户自身范围内。通过 NetCoreKevin 框架与 Hangfire 的集成，AI 智能体获得了“计划未来”的能力，从被动的对话交互升级为能主动按计划执行任务的智能代理。你可以轻松扩展以下能力：
这种设计极大地提升了 AI Agent 的实用性和自动化水平，适用于个人助理、运维监控、数据分析等多种场景。
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。