yx lin
4 years ago
committed by
GitHub
GitHub
51 changed files with 600 additions and 286 deletions
@ -1,33 +1,7 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using Volo.Abp.Modularity; |
|||
using Volo.Abp.Reflection; |
|||
using Volo.Abp.Modularity; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
public class AbpBackgroundTasksAbstractionsModule : AbpModule |
|||
{ |
|||
public override void PreConfigureServices(ServiceConfigurationContext context) |
|||
{ |
|||
AutoAddJobMonitors(context.Services); |
|||
} |
|||
|
|||
private static void AutoAddJobMonitors(IServiceCollection services) |
|||
{ |
|||
var jobMonitors = new List<Type>(); |
|||
|
|||
services.OnRegistred(context => |
|||
{ |
|||
if (ReflectionHelper.IsAssignableToGenericType(context.ImplementationType, typeof(JobEventBase<>))) |
|||
{ |
|||
jobMonitors.Add(context.ImplementationType); |
|||
} |
|||
}); |
|||
|
|||
services.Configure<AbpBackgroundTasksOptions>(options => |
|||
{ |
|||
options.JobMonitors.AddIfNotContains(jobMonitors); |
|||
}); |
|||
} |
|||
} |
|||
|
|||
@ -0,0 +1,9 @@ |
|||
using JetBrains.Annotations; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
public interface IJobCompletedNotifierProvider |
|||
{ |
|||
Task NotifyComplateAsync([NotNull] JobEventContext context); |
|||
} |
|||
@ -1,9 +0,0 @@ |
|||
using JetBrains.Annotations; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
public interface IJobExceptionNotifier |
|||
{ |
|||
Task NotifyAsync([NotNull] JobExceptionNotificationContext context); |
|||
} |
|||
@ -0,0 +1,11 @@ |
|||
using JetBrains.Annotations; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
public interface IJobExecutedNotifier |
|||
{ |
|||
Task NotifyErrorAsync([NotNull] JobEventContext context); |
|||
Task NotifySuccessAsync([NotNull] JobEventContext context); |
|||
Task NotifyComplateAsync([NotNull] JobEventContext context); |
|||
} |
|||
@ -0,0 +1,9 @@ |
|||
using JetBrains.Annotations; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
public interface IJobFailedNotifierProvider |
|||
{ |
|||
Task NotifyErrorAsync([NotNull] JobEventContext context); |
|||
} |
|||
@ -0,0 +1,9 @@ |
|||
using JetBrains.Annotations; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
public interface IJobSuccessNotifierProvider |
|||
{ |
|||
Task NotifySuccessAsync([NotNull] JobEventContext context); |
|||
} |
|||
@ -1,16 +0,0 @@ |
|||
using System; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
public class JobExceptionNotificationContext |
|||
{ |
|||
public JobInfo JobInfo { get; } |
|||
public Exception Exception { get; } |
|||
public JobExceptionNotificationContext( |
|||
JobInfo jobInfo, |
|||
Exception exception) |
|||
{ |
|||
JobInfo = jobInfo; |
|||
Exception = exception; |
|||
} |
|||
} |
|||
@ -0,0 +1,67 @@ |
|||
using JetBrains.Annotations; |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using Microsoft.Extensions.Logging; |
|||
using Microsoft.Extensions.Logging.Abstractions; |
|||
using System; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
public class JobExecutedNotifier : IJobExecutedNotifier, ISingletonDependency |
|||
{ |
|||
public ILogger<JobExecutedNotifier> Logger { protected get; set; } |
|||
|
|||
public JobExecutedNotifier() |
|||
{ |
|||
Logger = NullLogger<JobExecutedNotifier>.Instance; |
|||
} |
|||
|
|||
public async Task NotifyComplateAsync([NotNull] JobEventContext context) |
|||
{ |
|||
var notifier = context.ServiceProvider.GetService<IJobCompletedNotifierProvider>(); |
|||
if (notifier != null) |
|||
{ |
|||
try |
|||
{ |
|||
await notifier.NotifyComplateAsync(context); |
|||
} |
|||
catch (Exception ex) |
|||
{ |
|||
Logger.LogWarning($"An exception thow with job complete notify: {ex.Message}"); |
|||
} |
|||
} |
|||
} |
|||
|
|||
public async Task NotifyErrorAsync([NotNull] JobEventContext context) |
|||
{ |
|||
var notifier = context.ServiceProvider.GetService<IJobFailedNotifierProvider>(); |
|||
if (notifier != null) |
|||
{ |
|||
try |
|||
{ |
|||
await notifier.NotifyErrorAsync(context); |
|||
} |
|||
catch (Exception ex) |
|||
{ |
|||
Logger.LogWarning($"An exception thow with job error notify: {ex.Message}"); |
|||
} |
|||
} |
|||
} |
|||
|
|||
public async Task NotifySuccessAsync([NotNull] JobEventContext context) |
|||
{ |
|||
var notifier = context.ServiceProvider.GetService<IJobSuccessNotifierProvider>(); |
|||
if (notifier != null) |
|||
{ |
|||
try |
|||
{ |
|||
await notifier.NotifySuccessAsync(context); |
|||
} |
|||
catch (Exception ex) |
|||
{ |
|||
Logger.LogWarning($"An exception thow with job success notify: {ex.Message}"); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
@ -1,14 +0,0 @@ |
|||
using JetBrains.Annotations; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
[Dependency(TryRegister = true)] |
|||
public class NullJobExceptionNotifier : IJobExceptionNotifier, ISingletonDependency |
|||
{ |
|||
public Task NotifyAsync([NotNull] JobExceptionNotificationContext context) |
|||
{ |
|||
return Task.CompletedTask; |
|||
} |
|||
} |
|||
45
aspnet-core/modules/task-management/LINGYUN.Abp.BackgroundTasks.ExceptionHandling/LINGYUN/Abp/BackgroundTasks/ExceptionHandling/JobExceptionNotifier.cs → aspnet-core/modules/task-management/LINGYUN.Abp.BackgroundTasks.ExceptionHandling/LINGYUN/Abp/BackgroundTasks/ExceptionHandling/JobFailedNotifierProvider.cs
45
aspnet-core/modules/task-management/LINGYUN.Abp.BackgroundTasks.ExceptionHandling/LINGYUN/Abp/BackgroundTasks/ExceptionHandling/JobExceptionNotifier.cs → aspnet-core/modules/task-management/LINGYUN.Abp.BackgroundTasks.ExceptionHandling/LINGYUN/Abp/BackgroundTasks/ExceptionHandling/JobFailedNotifierProvider.cs
@ -0,0 +1,6 @@ |
|||
namespace LINGYUN.Abp.BackgroundTasks.Jobs; |
|||
|
|||
internal static class BackgroundTasksConsts |
|||
{ |
|||
public const string DefaultHttpClient = "_AbpBackgroundTasks_Client"; |
|||
} |
|||
@ -0,0 +1,16 @@ |
|||
<Project Sdk="Microsoft.NET.Sdk"> |
|||
|
|||
<Import Project="..\..\..\configureawait.props" /> |
|||
<Import Project="..\..\..\common.props" /> |
|||
|
|||
<PropertyGroup> |
|||
<TargetFramework>netstandard2.0</TargetFramework> |
|||
<RootNamespace /> |
|||
</PropertyGroup> |
|||
|
|||
<ItemGroup> |
|||
<ProjectReference Include="..\LINGYUN.Abp.BackgroundTasks\LINGYUN.Abp.BackgroundTasks.csproj" /> |
|||
<ProjectReference Include="..\LINGYUN.Abp.TaskManagement.HttpApi.Client\LINGYUN.Abp.TaskManagement.HttpApi.Client.csproj" /> |
|||
</ItemGroup> |
|||
|
|||
</Project> |
|||
@ -0,0 +1,11 @@ |
|||
using LINGYUN.Abp.TaskManagement.HttpApi.Client; |
|||
using Volo.Abp.Modularity; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks.TaskManagement; |
|||
|
|||
[DependsOn(typeof(AbpBackgroundTasksModule))] |
|||
[DependsOn(typeof(TaskManagementHttpApiClientModule))] |
|||
public class AbpBackgroundTasksTaskManagementModule : AbpModule |
|||
{ |
|||
|
|||
} |
|||
@ -0,0 +1,44 @@ |
|||
using LINGYUN.Abp.TaskManagement; |
|||
using System.Threading; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.Data; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks.TaskManagement; |
|||
|
|||
public class TaskManagementJobPublisher : IJobPublisher, ITransientDependency |
|||
{ |
|||
protected IBackgroundJobInfoAppService BackgroundJobAppService { get; } |
|||
|
|||
public TaskManagementJobPublisher( |
|||
IBackgroundJobInfoAppService backgroundJobAppService) |
|||
{ |
|||
BackgroundJobAppService = backgroundJobAppService; |
|||
} |
|||
|
|||
public async virtual Task<bool> PublishAsync(JobInfo job, CancellationToken cancellationToken = default) |
|||
{ |
|||
var input = new BackgroundJobInfoCreateDto |
|||
{ |
|||
Cron = job.Cron, |
|||
MaxCount = job.MaxCount, |
|||
MaxTryCount = job.MaxTryCount, |
|||
Args = new ExtraPropertyDictionary(job.Args), |
|||
BeginTime = job.BeginTime, |
|||
Description = job.Description, |
|||
EndTime = job.EndTime, |
|||
Group = job.Group, |
|||
Interval = job.Interval, |
|||
Type = job.Type, |
|||
JobType = job.JobType, |
|||
LockTimeOut = job.LockTimeOut, |
|||
IsEnabled = true, |
|||
Name = job.Name, |
|||
Priority = job.Priority, |
|||
}; |
|||
|
|||
await BackgroundJobAppService.CreateAsync(input); |
|||
|
|||
return true; |
|||
} |
|||
} |
|||
@ -0,0 +1,9 @@ |
|||
using System.Threading; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
public interface IJobPublisher |
|||
{ |
|||
Task<bool> PublishAsync(JobInfo job, CancellationToken cancellationToken = default); |
|||
} |
|||
@ -1,27 +0,0 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using System.Linq; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.Auditing; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks.Internal; |
|||
|
|||
[DisableAuditing] |
|||
public class BackgroundKeepAliveJob : IJobRunnable |
|||
{ |
|||
public virtual async Task ExecuteAsync(JobRunnableContext context) |
|||
{ |
|||
var store = context.ServiceProvider.GetRequiredService<IJobStore>(); |
|||
|
|||
// TODO: 如果积压有大量周期性任务, 可能后面的队列无法被检索到
|
|||
var periodJobs = await store.GetAllPeriodTasksAsync(); |
|||
|
|||
if (!periodJobs.Any()) |
|||
{ |
|||
return; |
|||
} |
|||
|
|||
var jobScheduler = context.ServiceProvider.GetRequiredService<IJobScheduler>(); |
|||
|
|||
await jobScheduler.QueuesAsync(periodJobs); |
|||
} |
|||
} |
|||
@ -0,0 +1,32 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using Microsoft.Extensions.Logging; |
|||
using System; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks.Internal; |
|||
|
|||
public class JobNotifierEvent : JobEventBase<JobNotifierEvent>, ITransientDependency |
|||
{ |
|||
protected async override Task OnJobAfterExecutedAsync(JobEventContext context) |
|||
{ |
|||
try |
|||
{ |
|||
var notifier = context.ServiceProvider.GetRequiredService<IJobExecutedNotifier>(); |
|||
if (context.EventData.Exception != null) |
|||
{ |
|||
await notifier.NotifyErrorAsync(context); |
|||
} |
|||
else |
|||
{ |
|||
await notifier.NotifySuccessAsync(context); |
|||
} |
|||
|
|||
await notifier.NotifyComplateAsync(context); |
|||
} |
|||
catch (Exception ex) |
|||
{ |
|||
Logger.LogWarning($"An exception thow with job notify: {ex.Message}"); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,14 @@ |
|||
using System.Threading; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
[Dependency(TryRegister = true)] |
|||
public class NullJobPublisher : IJobPublisher, ISingletonDependency |
|||
{ |
|||
public Task<bool> PublishAsync(JobInfo job, CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.FromResult(false); |
|||
} |
|||
} |
|||
@ -0,0 +1,60 @@ |
|||
using System.Collections.Generic; |
|||
using System.Threading; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.BackgroundTasks; |
|||
|
|||
[Dependency(TryRegister = true)] |
|||
public class NullJobScheduler : IJobScheduler, ISingletonDependency |
|||
{ |
|||
public Task<bool> ExistsAsync(JobInfo job, CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.FromResult(false); |
|||
} |
|||
|
|||
public Task PauseAsync(JobInfo job, CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.CompletedTask; |
|||
} |
|||
|
|||
public Task<bool> QueueAsync(JobInfo job, CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.FromResult(false); |
|||
} |
|||
|
|||
public Task QueuesAsync(IEnumerable<JobInfo> jobs, CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.CompletedTask; |
|||
} |
|||
|
|||
public Task<bool> RemoveAsync(JobInfo job, CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.FromResult(false); |
|||
} |
|||
|
|||
public Task ResumeAsync(JobInfo job, CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.CompletedTask; |
|||
} |
|||
|
|||
public Task<bool> ShutdownAsync(CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.FromResult(false); |
|||
} |
|||
|
|||
public Task<bool> StartAsync(CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.FromResult(false); |
|||
} |
|||
|
|||
public Task<bool> StopAsync(CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.FromResult(false); |
|||
} |
|||
|
|||
public Task TriggerAsync(JobInfo job, CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.CompletedTask; |
|||
} |
|||
} |
|||
@ -0,0 +1,19 @@ |
|||
<Project Sdk="Microsoft.NET.Sdk"> |
|||
|
|||
<Import Project="..\..\..\configureawait.props" /> |
|||
<Import Project="..\..\..\common.props" /> |
|||
|
|||
<PropertyGroup> |
|||
<TargetFramework>netstandard2.0</TargetFramework> |
|||
<RootNamespace /> |
|||
</PropertyGroup> |
|||
|
|||
<ItemGroup> |
|||
<PackageReference Include="Volo.Abp.Http.Client" Version="$(VoloAbpPackageVersion)" /> |
|||
</ItemGroup> |
|||
|
|||
<ItemGroup> |
|||
<ProjectReference Include="..\LINGYUN.Abp.TaskManagement.Application.Contracts\LINGYUN.Abp.TaskManagement.Application.Contracts.csproj" /> |
|||
</ItemGroup> |
|||
|
|||
</Project> |
|||
@ -0,0 +1,17 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using Volo.Abp.Http.Client; |
|||
using Volo.Abp.Modularity; |
|||
|
|||
namespace LINGYUN.Abp.TaskManagement.HttpApi.Client; |
|||
|
|||
[DependsOn(typeof(TaskManagementApplicationContractsModule))] |
|||
[DependsOn(typeof(AbpHttpClientModule))] |
|||
public class TaskManagementHttpApiClientModule : AbpModule |
|||
{ |
|||
public override void ConfigureServices(ServiceConfigurationContext context) |
|||
{ |
|||
context.Services.AddHttpClientProxies( |
|||
typeof(TaskManagementApplicationContractsModule).Assembly, |
|||
TaskManagementRemoteServiceConsts.RemoteServiceName); |
|||
} |
|||
} |
|||
Loading…
Reference in new issue