Tareas de fondo en aplicaciones ASP.NET MVC Core

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

using System;

namespace HangFireCore.Core
{
    [System.AttributeUsage(AttributeTargets.Class, Inherited = false, AllowMultiple = false)]
    public sealed class HangfireJobMinutesAttribute : Attribute
    {
        // See the attribute guidelines at 
        //  http://go.microsoft.com/fwlink/?LinkId=85236
        readonly int minutes;

        // This is a positional argument
        public HangfireJobMinutesAttribute(int minutes)
        {
            this.minutes = minutes;
        }

        public int Minutes
        {
            get { return minutes; }
        }
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22

using HangFireCore.Core;
using NLog;
using System;
using System.Threading.Tasks;

namespace HangFireCore.Job.One
{
    [HangfireJobMinutes(1)]
    public class JobOne
    {
        // Get logger
        private static Logger logger = LogManager.GetCurrentClassLogger();

        private static DateTime start = DateTime.Now;

        public static Task Execute()
        {
            // Use logger at INFO level
            return Task.Run(() => logger.Info(@"Executing Job One - {0:hh\:mm\:ss\.fff}", DateTime.Now - start));
        }
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

using Hangfire;
using HangFireCore.Core;
using Microsoft.AspNetCore.Hosting;
using NLog;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Linq.Expressions;
using System.Reflection;
using System.Runtime.Loader;

namespace HangFireCore.WebApp.Helpers
{
    public static class ScheduleJobsHelpers
    {
        static Logger logger = LogManager.GetCurrentClassLogger();

        public static void ScheduleRecurringJobs(this IHostingEnvironment env)
        {
            try
            {
                logger.Info("Scheduling recurring jobs...");
                logger.Trace("Loading job modules...");

                // Get the current executing assembly path
                string location = Assembly.GetEntryAssembly().Location;
                string directory = Path.GetDirectoryName(location);

                // Find modules that follow the job module name convention
                var jobModules = Directory.EnumerateFiles(directory, "HangFireCore.Job.*.dll", SearchOption.TopDirectoryOnly);

                if (!jobModules.Any())
                {
                    logger.Info("Didn't find any job module.");
                }

                foreach (var module in jobModules)
                {
                    try
                    {
                        logger.Info("Loading Job assembly: {0}", module);
                        Assembly assembly = AssemblyLoadContext.Default.LoadFromAssemblyPath(module);

                        logger.Trace("Getting jobs...");

                        // Get types using the HangfireJobMinutes attribute
                        var recurringJobs = assembly
                            .ExportedTypes
                            .Where(et => et.GetTypeInfo().GetCustomAttribute<HangfireJobMinutesAttribute>() != null);

                        if (!recurringJobs.Any())
                        {
                            logger.Info("Didn't find any recurring job.");
                        }

                        foreach (Type job in recurringJobs)
                        {
                            int minutes = job.GetTypeInfo().GetCustomAttribute<HangfireJobMinutesAttribute>().Minutes;

                            logger.Trace(@"Scheduling recurring job ""{0}"" with {1} minutes interval", job.Name, minutes);

                            // We expect every job to have an "Execute" method
                            MethodInfo executeMethod = job.GetMethod("Execute");

                            if (executeMethod != null)
                            {
                                // Get lambda expression to call the STATIC "Execute" method
                                Expression<Action> expression = Expression.Lambda<Action>(Expression.Call(executeMethod));

                                // Add the job to Hangfire's queue
                                RecurringJob.AddOrUpdate(job.FullName, expression, Cron.MinuteInterval(minutes));
                            }
                        }

                    }
                    catch (Exception ex)
                    {
                        logger.Error(ex);
                    }

                }
            }
            catch (Exception ex)
            {
                logger.Error(ex);
            }
        }
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

{
  "ConnectionStrings": {
    "DefaultConnection": "Data Source=localhost;Initial Catalog=HangFireCoreWebApp;Integrated Security=SSPI;MultipleActiveResultSets=true"
  },
  "Logging": {
    "IncludeScopes": false,
    "LogLevel": {
      "Default": "Warning"
    }
  }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

using Hangfire.Annotations;
using Hangfire.Dashboard;

namespace HangFireCore.WebApp.Helpers
{
    public class HangfireDashboardAuthorizationFilter : IDashboardAuthorizationFilter
    {
        public bool Authorize([NotNull] DashboardContext context)
        {
            var httpcontext = context.GetHttpContext();

            return httpcontext.User.Identity.IsAuthenticated;
        }
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

<?xml version="1.0" encoding="utf-8" ?>
<nlog xmlns="http://www.nlog-project.org/schemas/NLog.xsd"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      autoReload="true"
      internalLogLevel="Warn"
      internalLogFile="c:\temp\logs\internal-nlog.log">

    <extensions>
        <add assembly="NLog.Web.AspNetCore"/>
    </extensions>


    <!-- define various log targets -->
    <targets>
        <!-- write logs to file -->
        <target xsi:type="File"
                name="allfile"
                fileName="c:\temp\logs\nlog-all-current.log"
                archiveFileName="c:\temp\logs\nlog-all-archive${#}.log"
                archiveEvery="Day"
                archiveNumbering="Rolling"
                maxArchiveFiles="7"
                layout="${longdate}|${event-properties:item=EventId.Id}|${logger}|${uppercase:${level}}|${message} ${exception}" />


        <target xsi:type="File"
                name="ownFile-web"
                fileName="c:\temp\logs\nlog-HangFireCoreApp-current.log"
                archiveFileName="c:\temp\logs\nlog-HangFireCoreApp-archive${#}.log"
                archiveEvery="Day"
                archiveNumbering="Rolling"
                maxArchiveFiles="7"
                layout="${longdate}|${event-properties:item=EventId.Id}|${logger}|${uppercase:${level}}|  ${message} ${exception}|url: ${aspnet-request-url}|action: ${aspnet-mvc-action}" />

        <target xsi:type="Null" name="blackhole" />
    </targets>

    <rules>
        <!--All logs, including from Microsoft-->
        <logger name="*" minlevel="Info" writeTo="allfile" />

        <!--Skip Microsoft logs and so log only own logs-->
        <logger name="Microsoft.*" minlevel="Trace" writeTo="blackhole" final="true" />
        <logger name="*" minlevel="Info" writeTo="ownFile-web" />
    </rules>
</nlog>

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133

using Hangfire;
using HangFireCore.WebApp.Data;
using HangFireCore.WebApp.Helpers;
using HangFireCore.WebApp.Models;
using HangFireCore.WebApp.Services;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Identity.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using NLog;
using NLog.Extensions.Logging;
using NLog.Web;

namespace HangFireCore.WebApp
{
    public class Startup
    {
        private Logger logger = LogManager.GetCurrentClassLogger();

        public Startup(IHostingEnvironment env)
        {
            var builder = new ConfigurationBuilder()
                .SetBasePath(env.ContentRootPath)
                .AddJsonFile("appsettings.json", optional: false, reloadOnChange: true)
                .AddJsonFile($"appsettings.{env.EnvironmentName}.json", optional: true);

            if (env.IsDevelopment())
            {
                // For more details on using the user secret store see https://go.microsoft.com/fwlink/?LinkID=532709
                builder.AddUserSecrets<Startup>();
            }

            builder.AddEnvironmentVariables();

            Configuration = builder.Build();

            env.ConfigureNLog("NLog.config");
        }

        public IConfigurationRoot Configuration { get; }

        // This method gets called by the runtime. Use this method to add services to the container.
        public void ConfigureServices(IServiceCollection services)
        {
            //call this in case you need aspnet-user-authtype/aspnet-user-identity
            services.AddSingleton<IHttpContextAccessor, HttpContextAccessor>();

            // Add framework services.
            services.AddDbContext<ApplicationDbContext>(options =>
                options.UseSqlServer(Configuration.GetConnectionString("DefaultConnection")));

            services.AddIdentity<ApplicationUser, IdentityRole>()
                .AddEntityFrameworkStores<ApplicationDbContext>()
                .AddDefaultTokenProviders();

            services.AddMvc();

            // Add application services.
            services.AddTransient<IEmailSender, AuthMessageSender>();
            services.AddTransient<ISmsSender, AuthMessageSender>();

            // Add Hangfire
            services.AddHangfire(config => config.UseSqlServerStorage(Configuration.GetConnectionString("DefaultConnection")));
        }

        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
        {
            loggerFactory.AddConsole(Configuration.GetSection("Logging"));
            loggerFactory.AddDebug();

            //add NLog to ASP.NET Core
            loggerFactory.AddNLog();

            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
                app.UseDatabaseErrorPage();
                app.UseBrowserLink();
            }
            else
            {
                app.UseExceptionHandler("/Home/Error");
            }

            app.UseStaticFiles();

            app.UseIdentity();

            // Add external authentication middleware below. To configure them please see https://go.microsoft.com/fwlink/?LinkID=532715

            app.UseMvc(routes =>
            {
                routes.MapRoute(
                    name: "default",
                    template: "{controller=Home}/{action=Index}/{id?}");
            });

            //add NLog.Web
            app.AddNLogWeb();

            // Initialize Dabatabase
            InitDb();

            // Configure Hangfire
            app.UseHangfireServer();

            app.UseHangfireDashboard("/hangfire", new DashboardOptions()
            {
                Authorization = new[] { new HangfireDashboardAuthorizationFilter() }
            });

            // Recurring jobs
            env.ScheduleRecurringJobs();
        }

        private void InitDb()
        {
            var optionsBuilder = new DbContextOptionsBuilder<ApplicationDbContext>();

            optionsBuilder.UseSqlServer(Configuration.GetConnectionString("DefaultConnection"));

            using (var dbContext = new ApplicationDbContext(optionsBuilder.Options))
            {
                dbContext.Database.Migrate();
            };
        }
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

2017-04-27 21:44:33.9864|0|Hangfire.SqlServer.SqlServerStorage|INFO|  Start installing Hangfire SQL objects... |url: |action: 
2017-04-27 21:44:34.2044|0|Hangfire.SqlServer.SqlServerStorage|INFO|  Hangfire SQL objects installed. |url: |action: 
2017-04-27 21:44:34.2419|0|Hangfire.BackgroundJobServer|INFO|  Starting Hangfire Server |url: |action: 
2017-04-27 21:44:34.2504|0|Hangfire.BackgroundJobServer|INFO|  Using job storage: 'SQL Server: localhost@HangFireCoreWebApp' |url: |action: 
2017-04-27 21:44:34.2504|0|Hangfire.BackgroundJobServer|INFO|  Using the following options for SQL Server job storage: |url: |action: 
2017-04-27 21:44:34.2504|0|Hangfire.BackgroundJobServer|INFO|      Queue poll interval: 00:00:15. |url: |action: 
2017-04-27 21:44:34.2504|0|Hangfire.BackgroundJobServer|INFO|  Using the following options for Hangfire Server: |url: |action: 
2017-04-27 21:44:34.2504|0|Hangfire.BackgroundJobServer|INFO|      Worker count: 20 |url: |action: 
2017-04-27 21:44:34.2504|0|Hangfire.BackgroundJobServer|INFO|      Listening queues: 'default' |url: |action: 
2017-04-27 21:44:34.2504|0|Hangfire.BackgroundJobServer|INFO|      Shutdown timeout: 00:00:15 |url: |action: 
2017-04-27 21:44:34.2504|0|Hangfire.BackgroundJobServer|INFO|      Schedule polling interval: 00:00:15 |url: |action: 
2017-04-27 21:44:34.3054||ScheduleJobsHelpers|INFO|  Scheduling recurring jobs... |url: |action: 
2017-04-27 21:44:34.3054||ScheduleJobsHelpers|INFO|  Loading Job assembly: C:\Users\Miguel\Documents\Trabajo\Blog\coderepo.blog\repos\HangFireCoreWebApp\src\HangFireCore.WebApp\bin\Debug\netcoreapp1.1\HangFireCore.Job.One.dll |url: |action: 
2017-04-27 21:44:34.5750||ScheduleJobsHelpers|INFO|  Loading Job assembly: C:\Users\Miguel\Documents\Trabajo\Blog\coderepo.blog\repos\HangFireCoreWebApp\src\HangFireCore.WebApp\bin\Debug\netcoreapp1.1\HangFireCore.Job.Two.dll |url: |action: 
2017-04-27 21:45:00.7109||JobOne|INFO|  Executing Job One - 00:00:00.000 |url: |action: