Biegral Blog

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Hangfire
{
    class Program
    {
        private static readonly log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
        static void Main(string[] args)
        {
            GlobalConfiguration.Configuration
                .UseLog4NetLogProvider()
                .UseSqlServerStorage("Data Source=localhost;User Id=sa;Password=123456;Database=DataSample;Pooling=true;Max Pool Size=5000;Min Pool Size=0;");

            Console.WriteLine("Hangfire Server started. Press any key to exit...");
            var server = new BackgroundJobServer();

            //支持基于队列的任务处理：任务执行不是同步的，而是放到一个持久化队列中，以便马上把请求控制权返回给调用者。
            var jobId = BackgroundJob.Enqueue(() => Console.WriteLine("{0}===》这是队列任务!", DateTime.Now.ToString("HH:mm:ss")));

            //延迟任务执行：不是马上调用方法，而是设定一个未来时间点再来执行。
            BackgroundJob.Schedule(() => Console.WriteLine("{0}===》这是延时任务!", DateTime.Now.ToString("HH:mm:ss")), TimeSpan.FromSeconds(5));

            //循环任务执行：一行代码添加重复执行的任务，其内置了常见的时间循环模式，也可基于CRON表达式来设定复杂的模式。
            RecurringJob.AddOrUpdate(() => Console.WriteLine("{0}===》这是每分钟执行的任务!", DateTime.Now.ToString("HH:mm:ss")), Cron.Minutely); //注意最小单位是分钟

            //延续性任务执行：类似于.NET中的Task,可以在第一个任务执行完之后紧接着再次执行另外的任务
            BackgroundJob.ContinueWith(jobId, () => Console.WriteLine("{0}===》这是延续性任务!", DateTime.Now.ToString("HH:mm:ss")));

            Console.ReadKey();
        }

        public static void Send()
        {
            Console.WriteLine("{0}===》这是队列事务", DateTime.Now.ToString("HH:mm:ss"));
        }
    }
}

<?xml version="1.0" encoding="utf-8" ?>
<!--App.config-->
<configuration>
  <configSections>
    <!--项目的 AssemblyInfo.cs文件上加上[assembly: log4net.Config.XmlConfigurator(Watch = true)]-->
    <section name="log4net" type="System.Configuration.IgnoreSectionHandler" />
  </configSections>
  <log4net>
    <appender name="RollingLogFileAppender" type="log4net.Appender.RollingFileAppender" >
      <!--日志文件名开头-->
      <file value="C:\\HangFireLog\\" />
      <!--是否追加到文件,默认为true，通常无需设置-->
      <appendToFile value="true" />
      <!--日期的格式，C:\\HangFireLog\\2016-08-08.txt，需设置-->
      <datePattern value="yyyy-MM-dd'.txt'" />
      <maxSizeRollBackups value="10" />
      <rollingStyle value="Date" />
      <!--不要使用小数,否则会一直写入当前日志-->
      <maximumFileSize value="10MB" />
      <staticLogFileName value="false" />
      <layout type="log4net.Layout.PatternLayout">
        <conversionPattern value="%d [%t] [%-5level] : %message %newline"/>
        <!--<param name="ConversionPattern" value="记录时间：%d{yyyy-MM-dd HH:mm:ss}  线程ID:[%thread] 日志级别：%-5level  文件：%file  类：%logger  %message%newline%newline" />-->
      </layout>
    </appender>
    <root>
      <!--控制级别，由低到高: ALL|DEBUG|INFO|WARN|ERROR|FATAL|OFF-->
      <!--比如定义级别为INFO，则INFO级别向下的级别，比如DEBUG日志将不会被记录-->
      <!--如果没有定义LEVEL的值，则缺省为DEBUG-->
      <level value="ALL" />
      <appender-ref ref="RollingLogFileAppender" />
    </root>
  </log4net>
  <startup>
    <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" />
  </startup>
</configuration>

//MVC中配置和使用 
public class DefaultController : Controller
{

	// GET: Default
	public ActionResult Index()
	{
	    /* 清空数据  HangFire主要数据

	    TRUNCATE TABLE HangFire.JobQueue
	    go
	    TRUNCATE TABLE HangFire.JobParameter
	    go
	    TRUNCATE TABLE HangFire.[State]
	    go
	    DELETE FROM HangFire.Job
	    go

	    */             

	    MSCL.LogHelper.WriteLog("这是测试");
	    #region HangFire任务

	    //支持基于队列的任务处理：任务执行不是同步的，而是放到一个持久化队列中，以便马上把请求控制权返回给调用者。
	    var jobId = BackgroundJob.Enqueue(() => InsertData("队列任务"));

	    //延迟任务执行：不是马上调用方法，而是设定一个未来时间点再来执行。
	    BackgroundJob.Schedule(() => InsertData("延时任务"), TimeSpan.FromSeconds(10));

	    //循环任务执行：一行代码添加重复执行的任务，其内置了常见的时间循环模式，也可基于CRON表达式来设定复杂的模式。
	    RecurringJob.AddOrUpdate(() => InsertData("每分钟执行任务"), Cron.Minutely); //注意最小单位是分钟

	    //延续性任务执行：类似于.NET中的Task,可以在第一个任务执行完之后紧接着再次执行另外的任务
	    BackgroundJob.ContinueWith(jobId, () => InsertData("连续任务"));
	    #endregion
	    

	    return View();
	}

        public static void InsertData(string str)
        {
            TestTable model = new TestTable();
            model.D_Name = string.Format("{0}", str);
            model.D_Password = string.Format("{0}密码", str);
            model.D_Else = string.Format("{0}其它", str);
            DataRootBase.Context.Insert<TestTable>(model);
        }
}

using System;
using System.Threading.Tasks;
using Microsoft.Owin;
using Owin;
using Hangfire;

[assembly: OwinStartup(typeof(MVC_demo.Startup))]

//Startup.cs
namespace MVC_demo
{
    public class Startup
    {
        public void Configuration(IAppBuilder app)
        {
            
            GlobalConfiguration.Configuration
                .UseSqlServerStorage("Data Source=localhost;User Id=sa;Password=123456;Database=DataSample;Pooling=true;Max Pool Size=5000;Min Pool Size=0;");
            BackgroundJob.Enqueue(() => Console.WriteLine("HangFire start"));//初始化生成HangFire数据库表
            app.UseHangfireDashboard();
            app.UseHangfireServer();
        }
    }
}