mirror of
https://github.com/GeWuYou/GFramework.git
synced 2026-05-07 00:39:00 +08:00
27266d037d
- 创建 Architecture 基类提供系统、模型、工具等组件的注册与管理功能 - 实现架构生命周期管理、初始化流程控制和阶段转换功能 - 添加 ArchitectureModules 模块管理器负责 CQRS 行为注册和模块安装 - 实现 MicrosoftDiContainer 依赖注入容器适配器 - 支持单例、瞬态、作用域服务注册和工厂方法注册 - 添加 CQRS 请求管道行为和处理器注册功能 - 实现线程安全的读写锁保护容器操作 - 提供服务获取、排序和优先级管理功能
84 lines
3.8 KiB
C#
84 lines
3.8 KiB
C#
using System.ComponentModel;
|
|
using System.Reflection;
|
|
using GFramework.Core.Abstractions.Architectures;
|
|
using GFramework.Core.Abstractions.Logging;
|
|
|
|
namespace GFramework.Core.Architectures;
|
|
|
|
/// <summary>
|
|
/// 架构模块管理器
|
|
/// 负责管理架构模块的安装和 CQRS 行为注册
|
|
/// </summary>
|
|
internal sealed class ArchitectureModules(
|
|
IArchitecture architecture,
|
|
IArchitectureServices services,
|
|
ILogger logger)
|
|
{
|
|
/// <summary>
|
|
/// 注册 CQRS 请求管道行为。
|
|
/// 支持开放泛型行为类型和针对单一请求的封闭行为类型。
|
|
/// </summary>
|
|
/// <typeparam name="TBehavior">行为类型，必须是引用类型</typeparam>
|
|
public void RegisterCqrsPipelineBehavior<TBehavior>() where TBehavior : class
|
|
{
|
|
logger.Debug($"Registering CQRS pipeline behavior: {typeof(TBehavior).Name}");
|
|
services.Container.RegisterCqrsPipelineBehavior<TBehavior>();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 注册 CQRS 请求管道行为。
|
|
/// 该成员保留旧名称以兼容历史调用点，内部行为与 <see cref="RegisterCqrsPipelineBehavior{TBehavior}" /> 一致。
|
|
/// 新代码不应继续依赖该别名；兼容层计划在未来的 major 版本中移除。
|
|
/// </summary>
|
|
/// <typeparam name="TBehavior">行为类型，必须是引用类型</typeparam>
|
|
[EditorBrowsable(EditorBrowsableState.Never)]
|
|
[Obsolete(
|
|
"Use RegisterCqrsPipelineBehavior<TBehavior>() instead. This compatibility alias will be removed in a future major version.")]
|
|
public void RegisterMediatorBehavior<TBehavior>() where TBehavior : class
|
|
{
|
|
RegisterCqrsPipelineBehavior<TBehavior>();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 从指定程序集显式注册 CQRS 处理器。
|
|
/// 该入口用于把默认架构程序集之外的扩展处理器接入当前架构容器。
|
|
/// </summary>
|
|
/// <param name="assembly">包含 CQRS 处理器或生成注册器的程序集。</param>
|
|
/// <exception cref="ArgumentNullException"><paramref name="assembly" /> 为 <see langword="null" />。</exception>
|
|
/// <exception cref="InvalidOperationException">底层容器已冻结，无法继续注册处理器。</exception>
|
|
public void RegisterCqrsHandlersFromAssembly(Assembly assembly)
|
|
{
|
|
ArgumentNullException.ThrowIfNull(assembly);
|
|
logger.Debug($"Registering CQRS handlers from assembly: {assembly.FullName ?? assembly.GetName().Name}");
|
|
services.Container.RegisterCqrsHandlersFromAssembly(assembly);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 从多个程序集显式注册 CQRS 处理器。
|
|
/// 它会复用容器级去重逻辑，避免模块重复接入相同程序集时重复注册 handler。
|
|
/// </summary>
|
|
/// <param name="assemblies">要接入的程序集集合。</param>
|
|
/// <exception cref="ArgumentNullException"><paramref name="assemblies" /> 为 <see langword="null" />。</exception>
|
|
/// <exception cref="InvalidOperationException">底层容器已冻结，无法继续注册处理器。</exception>
|
|
public void RegisterCqrsHandlersFromAssemblies(IEnumerable<Assembly> assemblies)
|
|
{
|
|
ArgumentNullException.ThrowIfNull(assemblies);
|
|
logger.Debug("Registering CQRS handlers from additional assemblies.");
|
|
services.Container.RegisterCqrsHandlersFromAssemblies(assemblies);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 安装架构模块
|
|
/// </summary>
|
|
/// <param name="module">要安装的模块</param>
|
|
/// <returns>安装的模块实例</returns>
|
|
public IArchitectureModule InstallModule(IArchitectureModule module)
|
|
{
|
|
var name = module.GetType().Name;
|
|
logger.Debug($"Installing module: {name}");
|
|
module.Install(architecture);
|
|
logger.Info($"Module installed: {name}");
|
|
return module;
|
|
}
|
|
}
|