Blame view

Yi.Abp.Net8/framework/Yi.Framework.Core/Modularity/YiModuleManager.cs 3.04 KB
515fceeb   “wangming”   框架初始化
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
  using System.Diagnostics;
  using System.Text;
  using Microsoft.Extensions.DependencyInjection;
  using Microsoft.Extensions.Logging;
  using Microsoft.Extensions.Options;
  using Volo.Abp.DependencyInjection;
  using Volo.Abp.Modularity;
  
  namespace Yi.Framework.Core.Modularity;
  
  /// <summary>
  /// Yi框架模块管理器
  /// </summary>
  [Dependency(ReplaceServices = true)]
  public class YiModuleManager : ModuleManager, IModuleManager, ISingletonDependency
  {
      private readonly IModuleContainer _moduleContainer;
      private readonly IEnumerable<IModuleLifecycleContributor> _lifecycleContributors;
      private readonly ILogger<YiModuleManager> _logger;
  
      /// <summary>
      /// 初始化模块管理器
      /// </summary>
      public YiModuleManager(
          IModuleContainer moduleContainer,
          ILogger<YiModuleManager> logger,
          IOptions<AbpModuleLifecycleOptions> options,
          IServiceProvider serviceProvider) 
          : base(moduleContainer, logger, options, serviceProvider)
      {
          _moduleContainer = moduleContainer;
          _logger = logger;
          _lifecycleContributors = options.Value.Contributors
              .Select(serviceProvider.GetRequiredService)
              .Cast<IModuleLifecycleContributor>()
              .ToArray();
      }
  
      /// <summary>
      /// 初始化所有模块
      /// </summary>
      /// <param name="context">应用程序初始化上下文</param>
      public override async Task InitializeModulesAsync(ApplicationInitializationContext context)
      {
          _logger.LogDebug("==========模块Initialize初始化统计-跳过0ms模块==========");
          
          var moduleCount = 0;
          var stopwatch = new Stopwatch();
          var totalTime = 0L;
  
          foreach (var contributor in _lifecycleContributors)
          {
              foreach (var module in _moduleContainer.Modules)
              {
                  try
                  {
                      stopwatch.Restart();
                      await contributor.InitializeAsync(context, module.Instance);
                      stopwatch.Stop();
                      
                      totalTime += stopwatch.ElapsedMilliseconds;
                      moduleCount++;
  
                      // 仅记录耗时超过1ms的模块
                      if (stopwatch.ElapsedMilliseconds > 1)
                      {
                          _logger.LogDebug(
                              "耗时-{Time}ms,已加载模块-{ModuleName}", 
                              stopwatch.ElapsedMilliseconds,
                              module.Assembly.GetName().Name);
                      }
                  }
                  catch (Exception ex)
                  {
                      throw new AbpInitializationException(
                          $"模块 {module.Type.AssemblyQualifiedName} 在 {contributor.GetType().FullName} 阶段初始化失败: {ex.Message}",
                          ex);
                  }
              }
          }
  
          _logger.LogInformation(
              "==========【{Count}】个模块初始化执行完毕,总耗时【{Time}ms】==========",
              moduleCount,
              totalTime);
      }
      
  }