Refactor/migrate cqrs to mediator

GFramework.Core.Abstractions/GFramework.Core.Abstractions.csproj

@@ -25,5 +25,6 @@
             <PrivateAssets>all</PrivateAssets>
             <IncludeAssets>runtime; build; native; contentfiles; analyzers</IncludeAssets>
         </PackageReference>
+        <PackageReference Include="Mediator.Abstractions" Version="3.0.1"/>
     </ItemGroup>
 </Project>

GFramework.Core.Abstractions/GlobalUsings.cs

@@ -13,6 +13,7 @@
 
 global using System;
 global using System.Collections.Generic;
+global using System.Runtime;
 global using System.Linq;
 global using System.Threading;
 global using System.Threading.Tasks;

GFramework.Core.Abstractions/architecture/IArchitecture.cs

@@ -1,6 +1,7 @@
 using GFramework.Core.Abstractions.model;
 using GFramework.Core.Abstractions.system;
 using GFramework.Core.Abstractions.utility;
+using Microsoft.Extensions.DependencyInjection;
 
 namespace GFramework.Core.Abstractions.architecture;
 
@@ -15,6 +16,14 @@ public interface IArchitecture : IAsyncInitializable
     /// </summary>
     IArchitectureContext Context { get; }
 
+    /// <summary>
+    ///     获取或设置用于配置服务集合的委托
+    /// </summary>
+    /// <value>
+    ///     一个可为空的委托，用于配置IServiceCollection实例
+    /// </value>
+    Action<IServiceCollection>? Configurator { get; }
+
     /// <summary>
     ///     初始化方法，用于执行对象的初始化操作
     /// </summary>
@@ -39,6 +48,13 @@ public interface IArchitecture : IAsyncInitializable
     /// <returns>注册的系统实例</returns>
     T RegisterSystem<T>(T system) where T : ISystem;
 
+    /// <summary>
+    ///     注册系统实例到架构中
+    /// </summary>
+    /// <typeparam name="T">系统类型，必须实现ISystem接口</typeparam>
+    /// <param name="onCreated">系统实例创建后的回调函数，可为null</param>
+    void RegisterSystem<T>(Action<T>? onCreated = null) where T : class, ISystem;
+
     /// <summary>
     ///     注册模型实例到架构中
     /// </summary>
@@ -47,6 +63,13 @@ public interface IArchitecture : IAsyncInitializable
     /// <returns>注册的模型实例</returns>
     T RegisterModel<T>(T model) where T : IModel;
 
+    /// <summary>
+    ///     注册模型实例到架构中
+    /// </summary>
+    /// <typeparam name="T">模型类型，必须实现IModel接口</typeparam>
+    /// <param name="onCreated">模型实例创建后的回调函数，可为null</param>
+    void RegisterModel<T>(Action<T>? onCreated = null) where T : class, IModel;
+
     /// <summary>
     ///     注册工具实例到架构中
     /// </summary>
@@ -55,6 +78,23 @@ public interface IArchitecture : IAsyncInitializable
     /// <returns>注册的工具实例</returns>
     T RegisterUtility<T>(T utility) where T : IUtility;
 
+
+    /// <summary>
+    ///     注册工具类型并可选地指定创建回调
+    ///     当工具实例被创建时会调用指定的回调函数
+    /// </summary>
+    /// <typeparam name="T">工具类型，必须是引用类型且实现IUtility接口</typeparam>
+    /// <param name="onCreated">工具实例创建后的回调函数，可为null</param>
+    void RegisterUtility<T>(Action<T>? onCreated = null) where T : class, IUtility;
+
+    /// <summary>
+    ///     注册中介行为管道
+    ///     用于配置Mediator框架的行为拦截和处理逻辑
+    /// </summary>
+    /// <typeparam name="TBehavior">行为类型，必须是引用类型</typeparam>
+    void RegisterMediatorBehavior<TBehavior>()
+        where TBehavior : class;
+
     /// <summary>
     ///     安装架构模块
     /// </summary>

GFramework.Core.Abstractions/architecture/IArchitectureContext.cs

@@ -5,6 +5,8 @@
 using GFramework.Core.Abstractions.query;
 using GFramework.Core.Abstractions.system;
 using GFramework.Core.Abstractions.utility;
+using Mediator;
+using ICommand = GFramework.Core.Abstractions.command.ICommand;
 
 namespace GFramework.Core.Abstractions.architecture;
 
@@ -53,14 +55,35 @@ public interface IArchitectureContext
     /// <typeparam name="TResult">命令执行结果类型</typeparam>
     /// <param name="command">要发送的命令</param>
     /// <returns>命令执行结果</returns>
-    TResult SendCommand<TResult>(ICommand<TResult> command);
+    TResult SendCommand<TResult>(command.ICommand<TResult> command);
+
+    /// <summary>
+    /// [Mediator] 发送命令的同步版本（不推荐，仅用于兼容性）
+    /// </summary>
+    /// <typeparam name="TResponse">命令响应类型</typeparam>
+    /// <param name="command">要发送的命令对象</param>
+    /// <returns>命令执行结果</returns>
+    TResponse SendCommand<TResponse>(Mediator.ICommand<TResponse> command);
+
 
     /// <summary>
     ///     发送并异步执行一个命令
     /// </summary>
     /// <param name="command">要发送的命令</param>
     Task SendCommandAsync(IAsyncCommand command);
 
+    /// <summary>
+    /// [Mediator] 异步发送命令并返回结果
+    /// 通过Mediator模式发送命令请求，支持取消操作
+    /// </summary>
+    /// <typeparam name="TResponse">命令响应类型</typeparam>
+    /// <param name="command">要发送的命令对象</param>
+    /// <param name="cancellationToken">取消令牌，用于取消操作</param>
+    /// <returns>包含命令执行结果的ValueTask</returns>
+    ValueTask<TResponse> SendCommandAsync<TResponse>(Mediator.ICommand<TResponse> command,
+        CancellationToken cancellationToken = default);
+
+
     /// <summary>
     ///     发送并异步执行一个带返回值的命令
     /// </summary>
@@ -75,7 +98,15 @@ public interface IArchitectureContext
     /// <typeparam name="TResult">查询结果类型</typeparam>
     /// <param name="query">要发送的查询</param>
     /// <returns>查询结果</returns>
-    TResult SendQuery<TResult>(IQuery<TResult> query);
+    TResult SendQuery<TResult>(query.IQuery<TResult> query);
+
+    /// <summary>
+    /// [Mediator] 发送查询的同步版本（不推荐，仅用于兼容性）
+    /// </summary>
+    /// <typeparam name="TResponse">查询响应类型</typeparam>
+    /// <param name="command">要发送的查询对象</param>
+    /// <returns>查询结果</returns>
+    TResponse SendQuery<TResponse>(Mediator.IQuery<TResponse> command);
 
     /// <summary>
     ///     异步发送一个查询请求
@@ -85,6 +116,17 @@ public interface IArchitectureContext
     /// <returns>查询结果</returns>
     Task<TResult> SendQueryAsync<TResult>(IAsyncQuery<TResult> query);
 
+    /// <summary>
+    /// [Mediator] 异步发送查询并返回结果
+    /// 通过Mediator模式发送查询请求，支持取消操作
+    /// </summary>
+    /// <typeparam name="TResponse">查询响应类型</typeparam>
+    /// <param name="command">要发送的查询对象</param>
+    /// <param name="cancellationToken">取消令牌，用于取消操作</param>
+    /// <returns>包含查询结果的ValueTask</returns>
+    ValueTask<TResponse> SendQueryAsync<TResponse>(Mediator.IQuery<TResponse> command,
+        CancellationToken cancellationToken = default);
+
     /// <summary>
     ///     发送一个事件
     /// </summary>
@@ -113,6 +155,65 @@ public interface IArchitectureContext
     /// <param name="onEvent">要取消注册的事件回调方法</param>
     void UnRegisterEvent<TEvent>(Action<TEvent> onEvent);
 
+    /// <summary>
+    /// 发送请求（统一处理 Command/Query）
+    /// </summary>
+    ValueTask<TResponse> SendRequestAsync<TResponse>(
+        IRequest<TResponse> request,
+        CancellationToken cancellationToken = default);
+
+    /// <summary>
+    /// 发送请求（同步版本，不推荐）
+    /// </summary>
+    TResponse SendRequest<TResponse>(IRequest<TResponse> request);
+
+    /// <summary>
+    /// 发布通知（一对多事件）
+    /// </summary>
+    ValueTask PublishAsync<TNotification>(
+        TNotification notification,
+        CancellationToken cancellationToken = default)
+        where TNotification : INotification;
+
+    /// <summary>
+    /// 创建流式请求（用于大数据集）
+    /// </summary>
+    IAsyncEnumerable<TResponse> CreateStream<TResponse>(
+        IStreamRequest<TResponse> request,
+        CancellationToken cancellationToken = default);
+
+    // === 便捷扩展方法 ===
+
+    /// <summary>
+    /// 发送命令（无返回值）
+    /// </summary>
+    ValueTask SendAsync<TCommand>(
+        TCommand command,
+        CancellationToken cancellationToken = default)
+        where TCommand : IRequest<Unit>;
+
+    /// <summary>
+    /// 发送命令（有返回值）
+    /// </summary>
+    ValueTask<TResponse> SendAsync<TResponse>(
+        IRequest<TResponse> command,
+        CancellationToken cancellationToken = default);
+
+    /// <summary>
+    /// 发送查询
+    /// </summary>
+    ValueTask<TResponse> QueryAsync<TResponse>(
+        IRequest<TResponse> query,
+        CancellationToken cancellationToken = default);
+
+    /// <summary>
+    /// 发布事件通知
+    /// </summary>
+    ValueTask PublishEventAsync<TNotification>(
+        TNotification notification,
+        CancellationToken cancellationToken = default)
+        where TNotification : INotification;
+
     /// <summary>
     ///     获取环境对象
     /// </summary>

GFramework.Core.Abstractions/architecture/IArchitectureServices.cs

@@ -24,17 +24,20 @@ public interface IArchitectureServices : IContextAware
     IEventBus EventBus { get; }
 
     /// <summary>
-    ///     获取命令总线
+    ///     获取命令执行器
     /// </summary>
+    /// <returns>ICommandExecutor类型的命令执行器实例</returns>
     public ICommandExecutor CommandExecutor { get; }
 
     /// <summary>
-    ///     获取查询总线
+    ///     获取查询执行器
     /// </summary>
+    /// <returns>IQueryExecutor类型的查询执行器实例</returns>
     public IQueryExecutor QueryExecutor { get; }
 
     /// <summary>
-    ///     获取异步查询总线
+    ///     获取异步查询执行器
     /// </summary>
+    /// <returns>IAsyncQueryExecutor类型的异步查询执行器实例</returns>
     public IAsyncQueryExecutor AsyncQueryExecutor { get; }
 }