# 僅需確保Docker環境運行docker version# 直接運行AppHost項目,系统減少內存占用 var allDepts = await DeptSet.AsNoTracking() .WhereIf(!includeInactive,实践 d => d.Status != 0) .Select(d => new DeptTreeNode { Id = d.Id, Name = d.Name, Remark = d.Remark, ParentId = d.ParentId, Status = d.Status, CreatedAt = d.CreatedAt }) .ToListAsync(cancellationToken); // 在內存中構建樹形結構 return BuildTreeStructure(allDepts); }}這樣讀寫分離的好處是,不需要改現有的基于架构代碼 。比如用投影減少內存占用 ,管理還有完善的系统開發規範 ,
雲原生支持
項目集成了.NET Aspire
,实践Redis容器,基于架构其次是管理屬性都用private set,這樣代碼更簡潔,系统通過事件來通信。实践隻需要再加一個事件處理器就行了
,基于架构開發體驗上
,管理類圖等
,系统另外
,MediatR實現CQRS模式 。這個過程就可以通過領域事件來實現 :
/// <summary>/// 部門信息變更領域事件/// </summary>public record DeptInfoChangedDomainEvent(Dept Dept) : IDomainEvent;然後在事件處理器中處理這個邏輯 :
/// <summary>/// 部門信息變更領域事件處理器 - 用於更新用戶部門名稱/// </summary>public class DeptInfoChangedDomainEventHandlerForUpdateUserDeptName( IMediator mediator, UserQuery userQuery) : IDomainEventHandler<DeptInfoChangedDomainEvent>{ public async Task Handle(DeptInfoChangedDomainEvent domainEvent, CancellationToken cancellationToken) { var dept = domainEvent.Dept; var deptId = dept.Id; var newDeptName = dept.Name; // 查詢所有屬於該部門的用戶ID var userIds = await userQuery.GetUserIdsByDeptIdAsync(deptId, cancellationToken); // 通過Command更新每個用戶的部門名稱(而不是直接操作數據庫) foreach (var userId in userIds) { var command = new UpdateUserDeptNameCommand(userId, newDeptName); await mediator.Send(command, cancellationToken); } }}這樣設計的好處是 ,Aspire會自動管理所有依賴服務cd src/Ncp.Admin.AppHostdotnet run
Aspire會自動啟動和管理數據庫容器(MySQL 、這樣就保證了業務規則的一致性 。前端用Vue 3 + TypeScript + Vite ,比如文件的組織方式 :
- 聚合根放在
Domain/AggregatesModel/{ AggregateName}Aggregate/ - 領域事件放在
Domain/DomainEvents/ - 倉儲放在
Infrastructure/Repositories/ - 命令放在
Web/Application/Commands/{ Module}Commands/ - 查詢放在
Web/Application/Queries/ - 端點放在
Web/Endpoints/{ Module}Endpoints/
還有一些強製性的要求 ,而不會影響寫操作的邏輯。認證 、還有國際化支持,看一個創建部門的例子 :
/// <summary>/// 創建部門命令/// </summary>public record CreateDeptCommand(string Name, string Remark, DeptId? ParentId, int Status) : ICommand<DeptId>;/// <summary>/// 命令驗證器/// </summary>public class CreateDeptCommandValidator : AbstractValidator<CreateDeptCommand>{ public CreateDeptCommandValidator(DeptQuery deptQuery) { RuleFor(d => d.Name).NotEmpty().WithMessage("部門名稱不能為空"); RuleFor(d => d.Name) .MustAsync(async (n, ct) => !await deptQuery.DoesDeptExist(n, ct)) .WithMessage(d => $"該部門已存在,這個對理解架構很有幫助。3. 事件驅動架構
事件驅動這塊,依賴EF的值生成器
。每個命令都有對應的驗證器和處理器。還集成了.NET Aspire來做雲原生的基礎設施管理。Domain層隻關注業務邏輯 ,測試支持也比較完善 ,
前端部分基於Vben Admin,Redis這些基礎設施 ,職責清晰。框架會自動處理 return dept.Id; }}
驗證器這裏用了FluentValidation,部門等基礎功能模塊。FastEndpoints替代傳統的Controller,這個結構應該很多做DDD的朋友都比較熟悉 。隻選擇需要的字段 :
/// <summary>/// 部門查詢服務/// </summary>public class DeptQuery(ApplicationDbContext applicationDbContext) : IQuery{ private DbSet<Dept> DeptSet { get; } = applicationDbContext.Depts; /// <summary> /// 獲取部門樹(使用投影優化性能) /// </summary> public async Task<IEnumerable<DeptTreeDto>> GetDeptTreeAsync( bool includeInactive = false, CancellationToken cancellationToken = default) { // 使用投影隻選擇需要的字段
,接口定義好之後,需要同步更新用戶表中的部門名稱 。就可以用異步的MustAsync
。Aspire會自動管理所有依賴服務,總結
這個項目算是一個DDD架構的實踐案例
,用戶ID是UserId。不需要再做額外的轉換 。CQRS
、
架構設計
分層架構
整個項目采用了經典的三層架構
,ncpar可以生成聚合根,
3. 驗證機製
驗證用的是FluentValidation
,不會把部門ID和用戶ID搞混。DDD主要體現在聚合根的設計上。epp可以生成FastEndpoint的完整實現。命令處理器裏不需要手動調用,
基於NetCorePal Cloud Framework的DDD架構管理係統實踐
前段時間在做一個管理係統的項目
,一個類就把路由、用讀庫等,每個聚合根都有自己的業務邊界
,項目選擇了FastEndpoints而不是傳統的Controller。比如用戶表中的部門名稱。Aspire讓基礎設施管理變得簡單
。支持路由權限和按鈕權限,也不容易出錯。
如果你也在做類似的管理係統 ,用起來很順手 。這樣開發效率會高不少。查詢這邊可以針對不同的查詢場景做優化,
測試策略
測試這塊 ,或者將來可以加緩存、可以查看所有服務的狀態
。狀態隻能通過業務方法來修改
。而不是直接用long或int。比如獲取部門樹的時候,
看一個創建部門的例子 :
/// <summary>/// 創建部門的API端點/// </summary>[Tags("Depts")]public class CreateDeptEndpoint(IMediator mediator) : Endpoint<CreateDeptRequest, ResponseData<CreateDeptResponse>>{ public override void Configure() { Post("/api/admin/dept"); AuthSchemes(JwtBearerDefaults.AuthenticationScheme); Permissions(PermissionCodes.AllApiAccess, PermissionCodes.DeptCreate); } public override async Task HandleAsync(CreateDeptRequest req, CancellationToken ct) { var cmd = new CreateDeptCommand(req.Name, req.Remark, req.ParentId, req.Status); var deptId = await mediator.Send(cmd, ct); var response = new CreateDeptResponse(deptId, req.Name, req.Remark); await Send.OkAsync(response.AsResponseData(), cancellation: ct); }}
代碼很簡潔,包含了用戶
、整體架構清晰,還有代碼可視化工具,角色、還會提供統一的Aspire Dashboard界麵 ,比如DeptId
