Sparkdo.Mediation.Core 1.0.1

Sparkdo.Mediation.Core

Sparkdo.Mediation.Core 是 Sparkdo 框架中的中介者模式核心实现库。它提供了一种解耦组件间通信的机制，通过中介者模式减少组件之间的直接依赖，提高代码的可维护性和可测试性。

功能特性

1. 中介者模式实现

• 实现了完整的中介者模式，包括请求/响应和通知/订阅机制
• 通过 IMediator 接口统一管理请求处理和事件发布
• 支持同步和异步操作

2. 请求/响应模式

• 支持 IRequest<TResponse> 和 IRequestHandler<TRequest, TResponse> 接口
• 提供类型安全的请求处理机制
• 支持流式响应处理 (IStreamRequest<TResponse>)

3. 通知/订阅模式

• 支持 INotification 和 INotificationHandler<TNotification> 接口
• 实现了发布/订阅机制，支持多个处理器处理同一通知
• 提供可配置的通知发布策略

4. 中间件支持

• 支持请求处理管道中的中间件
• 可以在请求处理前后添加自定义逻辑
• 支持条件中间件和排序

5. 可扩展架构

• 通过 IMediatorConfigurationBuilder 提供灵活的配置机制
• 支持自定义请求处理器和通知处理器
• 支持插件化扩展

安装

<PackageReference Include="Sparkdo.Mediation.Core" Version="x.x.x" />

使用方法

1. 注册服务

在 Startup.cs 或程序初始化代码中注册中介者服务：

using Microsoft.Extensions.DependencyInjection;
using Sparkdo.Mediation;

public void ConfigureServices(IServiceCollection services)
{
    // 添加中介者服务
    services.AddMediation();
}

2. 定义请求和处理器

// 定义请求
public class GetUserQuery : IRequest<User>
{
    public int UserId { get; set; }
}

// 定义响应
public class User
{
    public int Id { get; set; }
    public string Name { get; set; }
}

// 实现请求处理器
public class GetUserQueryHandler : IRequestHandler<GetUserQuery, User>
{
    public Task<User> Handle(GetUserQuery request, CancellationToken cancellationToken)
    {
        // 处理逻辑
        return Task.FromResult(new User 
        { 
            Id = request.UserId, 
            Name = $"User {request.UserId}" 
        });
    }
}

3. 发送请求

public class UserService
{
    private readonly IMediator _mediator;

    public UserService(IMediator mediator)
    {
        _mediator = mediator;
    }

    public async Task<User> GetUserAsync(int userId)
    {
        var query = new GetUserQuery { UserId = userId };
        return await _mediator.SendAsync(query);
    }
}

4. 定义通知和处理器

// 定义通知
public class UserCreatedNotification : INotification
{
    public int UserId { get; set; }
    public string UserName { get; set; }
}

// 实现通知处理器
public class UserCreatedEmailHandler : INotificationHandler<UserCreatedNotification>
{
    public Task Handle(UserCreatedNotification notification, CancellationToken cancellationToken)
    {
        // 发送邮件逻辑
        Console.WriteLine($"Sending email to user {notification.UserName}");
        return Task.CompletedTask;
    }
}

public class UserCreatedLogHandler : INotificationHandler<UserCreatedNotification>
{
    public Task Handle(UserCreatedNotification notification, CancellationToken cancellationToken)
    {
        // 记录日志逻辑
        Console.WriteLine($"User {notification.UserName} created");
        return Task.CompletedTask;
    }
}

5. 发布通知

public class UserController
{
    private readonly IMediator _mediator;

    public UserController(IMediator mediator)
    {
        _mediator = mediator;
    }

    public async Task CreateUserAsync()
    {
        // 创建用户逻辑
        var user = new User { Id = 1, Name = "John" };
        
        // 发布通知
        var notification = new UserCreatedNotification 
        { 
            UserId = user.Id, 
            UserName = user.Name 
        };
        
        await _mediator.PublishAsync(notification);
    }
}

高级功能

1. 中间件配置

services.AddMediation(builder => {
    // 添加自定义中间件
    builder.Middlewares.Add(new CustomMiddlewareConfiguration());
    
    // 配置通知发布器
    builder.NotificationPublisherFactory = sp => new CustomNotificationPublisher();
});

2. 条件处理器

services.AddMediation(builder => {
    // 根据条件注册处理器
    builder.UseRequestHandler(
        when: requestType => requestType.Name.EndsWith("Query"),
        handlerType: typeof(QueryHandler<>));
});