diff --git a/aspnet-core/Lion.AbpPro.sln b/aspnet-core/Lion.AbpPro.sln index 67d19bcd..de16292f 100644 --- a/aspnet-core/Lion.AbpPro.sln +++ b/aspnet-core/Lion.AbpPro.sln @@ -256,6 +256,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Lion.AbpPro.ElasticSearch", EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Lion.AbpPro.ElasticSearch.Tests", "frameworks\test\Lion.AbpPro.ElasticSearch.Tests\Lion.AbpPro.ElasticSearch.Tests.csproj", "{2B2110E1-4C29-41AF-ADB5-C1B5F3C3C1D0}" EndProject +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Lion.AbpPro.Starter", "frameworks\src\Lion.AbpPro.Starter\Lion.AbpPro.Starter.csproj", "{A70659A2-91F4-4FE7-80D0-DA12430543FD}" +EndProject Global GlobalSection(SolutionConfigurationPlatforms) = preSolution Debug|Any CPU = Debug|Any CPU @@ -630,6 +632,10 @@ Global {2B2110E1-4C29-41AF-ADB5-C1B5F3C3C1D0}.Debug|Any CPU.Build.0 = Debug|Any CPU {2B2110E1-4C29-41AF-ADB5-C1B5F3C3C1D0}.Release|Any CPU.ActiveCfg = Release|Any CPU {2B2110E1-4C29-41AF-ADB5-C1B5F3C3C1D0}.Release|Any CPU.Build.0 = Release|Any CPU + {A70659A2-91F4-4FE7-80D0-DA12430543FD}.Debug|Any CPU.ActiveCfg = Debug|Any CPU + {A70659A2-91F4-4FE7-80D0-DA12430543FD}.Debug|Any CPU.Build.0 = Debug|Any CPU + {A70659A2-91F4-4FE7-80D0-DA12430543FD}.Release|Any CPU.ActiveCfg = Release|Any CPU + {A70659A2-91F4-4FE7-80D0-DA12430543FD}.Release|Any CPU.Build.0 = Release|Any CPU EndGlobalSection GlobalSection(SolutionProperties) = preSolution HideSolutionNode = FALSE @@ -752,6 +758,7 @@ Global {AEFB2D25-29F4-4CE2-820D-A74EFB6A56B2} = {EFC415F8-872F-4C7E-8645-31A51481BCFC} {CCC3BE80-5D36-4833-B629-9F4230396EC3} = {7BE85EBC-99AD-4CDE-957E-4BDD087FC4E3} {2B2110E1-4C29-41AF-ADB5-C1B5F3C3C1D0} = {EFC415F8-872F-4C7E-8645-31A51481BCFC} + {A70659A2-91F4-4FE7-80D0-DA12430543FD} = {7BE85EBC-99AD-4CDE-957E-4BDD087FC4E3} EndGlobalSection GlobalSection(ExtensibilityGlobals) = postSolution SolutionGuid = {28315BFD-90E7-4E14-A2EA-F3D23AF4126F} diff --git a/aspnet-core/frameworks/src/Lion.AbpPro.Starter/GlobalUsings.cs b/aspnet-core/frameworks/src/Lion.AbpPro.Starter/GlobalUsings.cs new file mode 100644 index 00000000..bf7ac1e8 --- /dev/null +++ b/aspnet-core/frameworks/src/Lion.AbpPro.Starter/GlobalUsings.cs @@ -0,0 +1,9 @@ +// Global using directives + +global using Microsoft.Extensions.DependencyInjection; +global using Microsoft.Extensions.Hosting; +global using Volo.Abp; +global using Volo.Abp.Autofac; +global using Volo.Abp.DependencyInjection; +global using Volo.Abp.Modularity; +global using Volo.Abp.Threading; \ No newline at end of file diff --git a/aspnet-core/frameworks/src/Lion.AbpPro.Starter/Lion.AbpPro.Starter.csproj b/aspnet-core/frameworks/src/Lion.AbpPro.Starter/Lion.AbpPro.Starter.csproj new file mode 100644 index 00000000..669b2680 --- /dev/null +++ b/aspnet-core/frameworks/src/Lion.AbpPro.Starter/Lion.AbpPro.Starter.csproj @@ -0,0 +1,14 @@ + + + + net7.0 + enable + Lion.AbpPro.Starter + + + + + + + + diff --git a/aspnet-core/frameworks/src/Lion.AbpPro.Starter/Lion/AbpPro/Starter/AbpProStarterModule.cs b/aspnet-core/frameworks/src/Lion.AbpPro.Starter/Lion/AbpPro/Starter/AbpProStarterModule.cs new file mode 100644 index 00000000..43332143 --- /dev/null +++ b/aspnet-core/frameworks/src/Lion.AbpPro.Starter/Lion/AbpPro/Starter/AbpProStarterModule.cs @@ -0,0 +1,62 @@ +namespace Lion.AbpPro.Starter; + +[DependsOn( + typeof(AbpAutofacModule), + typeof(AbpThreadingModule))] +public class AbpProStarterModule : AbpModule +{ + private readonly CancellationTokenSource _cancellationTokenSource = new(); + + public override void ConfigureServices(ServiceConfigurationContext context) + { + } + + public override void OnApplicationInitialization(ApplicationInitializationContext context) + { + AsyncHelper.RunSync(() => OnApplicationInitializationAsync(context)); + } + + public override Task OnApplicationInitializationAsync(ApplicationInitializationContext context) + { + Run(context); + return Task.CompletedTask; + } + + public override Task OnApplicationShutdownAsync(ApplicationShutdownContext context) + { + _cancellationTokenSource.Cancel(); + return Task.CompletedTask; + } + + private void Run(ApplicationInitializationContext context) + { + var rootServiceProvider = context.ServiceProvider.GetRequiredService(); + Task.Run(async () => + { + using var scope = rootServiceProvider.CreateScope(); + var applicationLifetime = scope.ServiceProvider.GetService(); + var cancellationTokenProvider = scope.ServiceProvider.GetRequiredService(); + var cancellationToken = applicationLifetime?.ApplicationStopping ?? _cancellationTokenSource.Token; + var contributors = scope.ServiceProvider.GetRequiredService>(); + try + { + using (cancellationTokenProvider.Use(cancellationToken)) + { + if (cancellationTokenProvider.Token.IsCancellationRequested) + { + return; + } + + foreach (var contributor in contributors) + { + await contributor.RunAsync(); + } + } + } + catch + { + // ignore + } + }); + } +} \ No newline at end of file diff --git a/aspnet-core/frameworks/src/Lion.AbpPro.Starter/Lion/AbpPro/Starter/IAbpProStarterContributor.cs b/aspnet-core/frameworks/src/Lion.AbpPro.Starter/Lion/AbpPro/Starter/IAbpProStarterContributor.cs new file mode 100644 index 00000000..f2339e8e --- /dev/null +++ b/aspnet-core/frameworks/src/Lion.AbpPro.Starter/Lion/AbpPro/Starter/IAbpProStarterContributor.cs @@ -0,0 +1,6 @@ +namespace Lion.AbpPro.Starter; + +public interface IAbpProStarterContributor +{ + Task RunAsync(); +} \ No newline at end of file