ASP.net 中基于时间的事件

Question

我需要根据时间执行一些事件（发送电子邮件等）。 在托管（中等信任）环境中的 ASP.net 中实现此目的的最佳方法是什么？

例如：每天下午 4:00 发送电子邮件。
例如：登录 15 分钟后发送电子邮件。
例如：在上次状态更改 10 小时后发送电子邮件。

对于某些需求，触发逻辑可能很复杂，因此我需要构建一个灵活的系统来处理此类事件。 我被困在这段代码的核心激活方法上。

以下是我到目前为止的选项...

1) Global.asax 中的计时器
+ 简单
- 不可靠，Web 应用程序可以在 IIS 中卸载，并且事件不会触发。
？ 可能使用外部 pinger 服务来保持应用程序处于活动状态（可靠？）

2) Windows 服务执行操作
- 滑动/维护单独的代码。
- 无法安装在托管环境（共享/云托管）

3) Windows Service 调用 Web App（调用 webservice 或运行页面）
+ 网络应用程序中的所有代码
- 无法安装在托管环境中。

4) SQL Server 作业调用 Web 服务（通过 CLR）
？ 没看过这个..可能吗？ 在托管环境中可靠吗？

5) SQL Service Broker Timer 添加消息以调用 WebService（通过 CLR）
？ 没看过这个..可能吗？ 在托管环境中可靠吗？

6) Windows 工作流程？
？ 不知道..这项技术有什么用吗？

这似乎是一个很常见的问题，有第三方工具可以处理这个问题吗？

Answer 1

我也遇到了同样的问题，非常同意你的分析。 迄今为止，我最好的解决方案是在我控制的计算机中安装外部调度应用程序； 该应用程序请求实际执行操作的网页。

丑陋但它有效，我已经寻找其他解决方案，相信我！

Answer 2

我建议使用 SQL Server 作业。

它具有解决方案中所需的所有时间表，而且非常可靠并且可以使用 C# 代码进行扩展。

Answer 3

在 Windows 中设置计划任务的最简单方法是运行简单的控制台应用程序或批处理文件。 http://windows.microsoft.com/en-us/windows7/schedule -a-task

尝试在 IIS 中执行您所说的操作时出现问题。 阅读 Phil Haack 的帖子 在 ASP.NET 中实现重复后台任务的危险

Answer 4

您是否看过 quartz 调度程序 它可以进行作业调度。 它是java版本的.Net移植版。 请参阅这篇入门文章 http://geekswithblogs.net/TarunArora/archive/2012/04/10/walkthrough-scheduling-jobs-using-quartz.net-ndash-part-1-what-is.aspx< /a>.

我们还使用 Azure 并使用工作角色来执行计划任务。 您可以在此处查看有关使用 Azure 工作角色构建基本计划任务的文章 http://blog.smarx.com/posts/building-a-task-scheduler-in-windows-azure

过去我们也设置了调用任务的网页并使用了类似的服务https://www.pingdom.com/ 定期调用该页面。

Answer 5

如果您确实想使用 ASP.NET，那么我会结合使用 SQL Server、WCF 和 ASP.NET 缓存来完成您的计划任务。 您可以轻松修改它以执行更短或更长的时间间隔（例如每小时或每周）。这将仅在选定的时间执行日常任务。

1. 为您的任务设置 SQL 表

列名称数据类型    
  整数 ID 
  名称 varchar(100)  
  上次运行日期时间 
  区间整数  
  运行时间日期时间 
  

2.向表中添加一些数据

<前><代码>1
我的每日电子邮件任务
08/15/08（旧日期）
300（5分钟）
09:00

间隔基本上告诉服务器检查时间的频率。 时间越短，运行时就越准确，但需要更频繁地检查数据库。

3. 如果使用 ORM，请创建类映射

public class Task
{
    public virtual int Id { get; set; }

    public virtual string Name { get; set; }

    public virtual DateTime? LastRun { get; set; }

    public virtual int Interval { get; set; }

    public virtual TimeSpan? RunTime { get; set; }
}

这将使用 Fluent nhibernate。 实体框架也很好用。

4. 创建服务调用以获取/保存任务

public Task[] GetTasks()
{

    var main = new Application.Main();
    using (var sessionFactory = main.SessionFactory)
    using (var session = sessionFactory.OpenSession())
    {
        return session.Query<Task>().ToArray();
    }

}

public bool SaveTask(Task task)
{
    var main = new Application.Main();
    using (var sessionFactory = main.SessionFactory)
    using (var session = sessionFactory.OpenSession())
    using (var trans = session.BeginTransaction())
    {
        session.SaveOrUpdate(task);
        trans.Commit();

        return trans.WasCommitted;
    }
}

这使用 WCF 进行服务调用。 从技术上讲，您不需要 Web 服务，但我认为当您将数据库查询与 ASP.NET 站点分开时，它有助于组织。

5. 在 global.asax 文件中设置调度

protected void Application_Start(object sender, EventArgs e)
{
    var service = new MyService.MyServiceClient();
    var tasks = service.GetTasks();

    foreach (var task in tasks)
    {
        AddTask(task);
    }

    service.Close();
}

上面的函数基本上获取所有任务并将其放入缓存循环中。

private void AddTask(PortalService.Task task)
{
        var onCacheRemove = new CacheItemRemovedCallback(CacheItemRemoved);
        HttpRuntime.Cache.Insert(task.Name, task, null,
            DateTime.Now.AddSeconds(task.Interval), Cache.NoSlidingExpiration,
            CacheItemPriority.NotRemovable, onCacheRemove);
}

上面的函数将数据库中的每个任务添加到 ASP.NET 运行时缓存中，该缓存根据您在数据库中指定的时间间隔进行循环。

public void CacheItemRemoved(string k, object taskObj, CacheItemRemovedReason r)
{
    var task = (MyService.Task)taskObj;



    //Run the task if it is the next day and greater than or equal to the runtime
    if (task.LastRun.HasValue && task.LastRun.Value.Day != DateTime.Now.Day && task.RunTime.HasValue && task.RunTime.Value.Hours <= DateTime.Now.Hour && task.RunTime.Value.Minutes <= DateTime.Now.Minute))
    {
        RunTask(ref task);
    }


    //Add the task again so that this method gets called again
    AddTask(task);
}

当我们的间隔到期时，将调用上面的函数来运行我们的任务。

6. 创建运行各种任务逻辑的函数

        private void RunTask(ref PortalService.Task task)
        {

            var service = new MyService.MyServiceClient();

            switch (task.Name)
            {
                case "My Daily Email Task":
                    service.SendDailyEmail();
                    break;
                case "Another Daily Task":
                    service.DoAnotherOperation();
                    break;
                case "Yet Another Daily Task":
                    service.DoYetAnotherOperation();
                    break;
            }

            //Update the task to indicate that it ran
            task.LastRun = DateTime.Now;
            service.SaveTask(task);


            service.Close();
        }

总体而言，考虑到可以对其进行的许多改进，该解决方案工作得很好。 如果自上次运行状态存储在数据库中以来将间隔设置得相当低，应用程序池回收不应影响此解决方案。