Abp vNext 模块加载机制

谈心

文章目录
生命周期

• PreConfigureServices  添加依赖注入或者其它配置之前
  
• ConfigureServices 添加依赖注入或者其它配置
  
• PostConfigureServices 添加依赖注入或者其它配置之后
  
• OnPreApplicationInitialization 初始化所有模块之前
  
• OnApplicationInitialization 初始化所有模块
  
• OnPostApplicationInitialization 初始化所有模块之后
  
• OnApplicationShutdown 应用关闭执行
  

OnPreApplicationInitialization和OnPostApplicationInitialization方法用来在OnApplicationInitialization之前或之后覆盖和编写你的代码.请注意,在这些方法中编写的代码将在所有其他模块的OnApplicationInitialization方法之前/之后执行.
加载流程

• 进入到Startup
  

1. public class Startup
2. {
3.     public void ConfigureServices(IServiceCollection services)
4.     {
5.         services.AddApplication<xxxManagementHttpApiHostModule>();
6.     }
7. }

复制代码

• 查看AddApplication源码会调用AbpApplicationFactory.CreateAsync
  

1. public async static Task<IAbpApplicationWithExternalServiceProvider> CreateAsync(
2.     [NotNull] Type startupModuleType,
3.     [NotNull] IServiceCollection services,
4.     Action<AbpApplicationCreationOptions>? optionsAction = null)
5. {
6.     var app = new AbpApplicationWithExternalServiceProvider(startupModuleType, services, options =>
7.     {
8.         options.SkipConfigureServices = true;
9.         optionsAction?.Invoke(options);
10.     });
11.     await app.ConfigureServicesAsync();
12.     return app;
13. }

复制代码

• 进入AbpApplicationWithExternalServiceProvider，我们可以看到继承AbpApplicationBase
  

1. internal class AbpApplicationWithExternalServiceProvider : AbpApplicationBase, IAbpApplicationWithExternalServiceProvider
2. {
3.     public AbpApplicationWithExternalServiceProvider(
4.         [NotNull] Type startupModuleType,
5.         [NotNull] IServiceCollection services,
6.         Action<AbpApplicationCreationOptions>? optionsAction
7.         ) : base(
8.             startupModuleType,
9.             services,
10.             optionsAction)
11.     {
12.         services.AddSingleton<IAbpApplicationWithExternalServiceProvider>(this);
13.     }
15.     void IAbpApplicationWithExternalServiceProvider.SetServiceProvider([NotNull] IServiceProvider serviceProvider)
16.     {
17.         Check.NotNull(serviceProvider, nameof(serviceProvider));
19.         // ReSharper disable once ConditionIsAlwaysTrueOrFalseAccordingToNullableAPIContract
20.         if (ServiceProvider != null)
21.         {
22.             if (ServiceProvider != serviceProvider)
23.             {
24.                 throw new AbpException("Service provider was already set before to another service provider instance.");
25.             }
27.             return;
28.         }
30.         SetServiceProvider(serviceProvider);
31.     }

复制代码

• 查看AbpApplicationBase构造函数
  

1. internal AbpApplicationBase(
2.         [NotNull] Type startupModuleType,
3.         [NotNull] IServiceCollection services,
4.         Action<AbpApplicationCreationOptions>? optionsAction)
5.     {
6.         services.AddCoreServices();
7.         services.AddCoreAbpServices(this, options);
8.         // 加载模块
9.         Modules = LoadModules(services, options);
10.     }

复制代码

• 查看加载模块逻辑
  

1. public IAbpModuleDescriptor[] LoadModules(
2.     IServiceCollection services,
3.     Type startupModuleType,
4.     PlugInSourceList plugInSources)
5. {
6.     Check.NotNull(services, nameof(services));
7.     Check.NotNull(startupModuleType, nameof(startupModuleType));
8.     Check.NotNull(plugInSources, nameof(plugInSources));
9.     // 扫描模块
10.     var modules = GetDescriptors(services, startupModuleType, plugInSources);
11.     // 按照模块的依赖性重新排序
12.     modules = SortByDependency(modules, startupModuleType);
13.     return modules.ToArray();
14. }

复制代码

生命周期

在上面第二步我们可以看到有一个await app.ConfigureServicesAsync();

• 在这个方法中可以看到依次执行每个模块的PreConfigureServices，ConfigureServices，PostConfigureServices
  

1. public virtual async Task ConfigureServicesAsync()
2.     {
3.         CheckMultipleConfigureServices();
5.         var context = new ServiceConfigurationContext(Services);
6.         Services.AddSingleton(context);
8.         foreach (var module in Modules)
9.         {
10.             if (module.Instance is AbpModule abpModule)
11.             {
12.                 abpModule.ServiceConfigurationContext = context;
13.             }
14.         }
16.         //PreConfigureServices
17.         foreach (var module in Modules.Where(m => m.Instance is IPreConfigureServices))
18.         {
19.             try
20.             {
21.                 await ((IPreConfigureServices)module.Instance).PreConfigureServicesAsync(context);
22.             }
23.             catch (Exception ex)
24.             {
25.                 throw new AbpInitializationException($"An error occurred during {nameof(IPreConfigureServices.PreConfigureServicesAsync)} phase of the module {module.Type.AssemblyQualifiedName}. See the inner exception for details.", ex);
26.             }
27.         }
29.         var assemblies = new HashSet<Assembly>();
31.         //ConfigureServices
32.         foreach (var module in Modules)
33.         {
34.             if (module.Instance is AbpModule abpModule)
35.             {
36.                 if (!abpModule.SkipAutoServiceRegistration)
37.                 {
38.                     var assembly = module.Type.Assembly;
39.                     if (!assemblies.Contains(assembly))
40.                     {
41.                         Services.AddAssembly(assembly);
42.                         assemblies.Add(assembly);
43.                     }
44.                 }
45.             }
47.             try
48.             {
49.                 await module.Instance.ConfigureServicesAsync(context);
50.             }
51.             catch (Exception ex)
52.             {
53.                 throw new AbpInitializationException($"An error occurred during {nameof(IAbpModule.ConfigureServicesAsync)} phase of the module {module.Type.AssemblyQualifiedName}. See the inner exception for details.", ex);
54.             }
55.         }
57.         //PostConfigureServices
58.         foreach (var module in Modules.Where(m => m.Instance is IPostConfigureServices))
59.         {
60.             try
61.             {
62.                 await ((IPostConfigureServices)module.Instance).PostConfigureServicesAsync(context);
63.             }
64.             catch (Exception ex)
65.             {
66.                 throw new AbpInitializationException($"An error occurred during {nameof(IPostConfigureServices.PostConfigureServicesAsync)} phase of the module {module.Type.AssemblyQualifiedName}. See the inner exception for details.", ex);
67.             }
68.         }
70.         foreach (var module in Modules)
71.         {
72.             if (module.Instance is AbpModule abpModule)
73.             {
74.                 abpModule.ServiceConfigurationContext = null!;
75.             }
76.         }
78.         _configuredServices = true;
79.     }

复制代码

• 再次查看第四步中有一个services.AddCoreAbpServices(this, options);
  这个里面构造好其它的四个生命周期
  

1. internal static void AddCoreAbpServices(this IServiceCollection services,
2.     IAbpApplication abpApplication,
3.     AbpApplicationCreationOptions applicationCreationOptions)
4. {
5.     var moduleLoader = new ModuleLoader();
6.     var assemblyFinder = new AssemblyFinder(abpApplication);
7.     var typeFinder = new TypeFinder(assemblyFinder);
8.     if (!services.IsAdded<IConfiguration>())
9.     {
10.         services.ReplaceConfiguration(
11.             ConfigurationHelper.BuildConfiguration(
12.                 applicationCreationOptions.Configuration
13.             )
14.         );
15.     }
16.     services.TryAddSingleton<IModuleLoader>(moduleLoader);
17.     services.TryAddSingleton<IAssemblyFinder>(assemblyFinder);
18.     services.TryAddSingleton<ITypeFinder>(typeFinder);
19.     services.TryAddSingleton<IInitLoggerFactory>(new DefaultInitLoggerFactory());
20.     services.AddAssemblyOf<IAbpApplication>();
21.     services.AddTransient(typeof(ISimpleStateCheckerManager<>), typeof(SimpleStateCheckerManager<>));
22.     // 注册生命周期
23.     services.Configure<AbpModuleLifecycleOptions>(options =>
24.     {
25.         // OnPreApplicationInitialization
26.         options.Contributors.Add<OnPreApplicationInitializationModuleLifecycleContributor>();
27.         // OnApplicationInitialization
28.         options.Contributors.Add<OnApplicationInitializationModuleLifecycleContributor>();
29.         // OnPostApplicationInitialization
30.         options.Contributors.Add<OnPostApplicationInitializationModuleLifecycleContributor>();
31.         // OnApplicationShutdown
32.         options.Contributors.Add<OnApplicationShutdownModuleLifecycleContributor>();
33.     });
34. }

复制代码

注册了这四个生命周期，在什么时候调用呢？请继续往下看。

• 继续回到Startup类
  

1. public class Startup
2. {
3.     public void Configure(IApplicationBuilder app, IWebHostEnvironment env, ILoggerFactory loggerFactory)
4.     {
5.         app.InitializeApplication();
6.     }
7. }

复制代码

• 查看InitializeApplication
  

• 遍历刚刚注入的四个生命周期，执行Initialize初始化方法
  

1. public void InitializeModules(ApplicationInitializationContext context)
2. {
3.     foreach (var contributor in _lifecycleContributors)
4.     {
5.         foreach (var module in _moduleContainer.Modules)
6.         {
7.             try
8.             {
9.                 contributor.Initialize(context, module.Instance);
10.             }
11.             catch (Exception ex)
12.             {
13.                 //
14.             }
15.         }
16.     }
17.     _logger.LogInformation("Initialized all ABP modules.");
18. }

复制代码

Abp vNext Pro

• Abp Vnext Pro Github地址 的 Vue3 实现版本 开箱即用的中后台前端/设计解决方案.
  
• 文档地址
  
• 演示地址:用户名admin 密码1q2w3E*
  
• Abp Vnext Pro Suite Github地址 代码生成器。
  
• 演示地址:用户名admin 密码1q2w3E*
  
• 
  

如果觉得可以,不要吝啬你的小星星哦

文章目录

来源:https://www.cnblogs.com/WangJunZzz/archive/2023/09/25/17728392.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！