Galosys.Foundation.Castle 26.5.20.1

Galosys.Foundation.Castle

成熟度: 🟢 稳定 — 生产可用，测试充分，活跃维护

简介

基于 Castle.DynamicProxy 的 AOP 拦截模块，提供动态代理、特性驱动的拦截器，支持事务管理、重试策略、幂等性控制和异常日志记录。

特性

• 基于特性的声明式 AOP 拦截
• 支持异步方法拦截（Task/ValueTask）
• 内置事务管理拦截器 [Transactional]
• 内置重试策略拦截器 [Retryable]（基于 Polly）
• 内置幂等性控制拦截器 [Idempotent]
• 内置异常日志拦截器 [CatchLogging]
• 自动扫描注册拦截器
• 支持接口和类的动态代理
• 支持 DI 容器集成

安装

dotnet add package Galosys.Foundation.Castle

使用

注册服务

// Program.cs - 方式一：使用 CastleCoreServiceProviderFactory
builder.Host.UseCastleCoreServiceProvider();

// Program.cs - 方式二：手动注册（需在所有服务注册后调用）
builder.Services.AddCastleInterceptors();
builder.Services.ConfigureCastleDynamicProxy();

事务管理

public class OrderService
{
    [Transactional]
    public virtual async Task CreateOrderAsync(Order order)
    {
        // 方法执行在事务中
    }

    [Transactional(IsolationLevel = IsolationLevel.Serializable, Timeout = 30000)]
    public virtual void ProcessPayment(Payment payment)
    {
        // 自定义隔离级别和超时时间
    }
}

重试策略

public class ExternalApiService
{
    [Retryable(maxAttempts: 3)]
    public virtual async Task<string> CallApiAsync()
    {
        // 失败时自动重试 3 次
    }

    [Retryable(maxAttempts: 5, MaxDelay = 10000, Multiplier = 2)]
    public virtual async Task<Data> FetchDataAsync()
    {
        // 指数退避重试，最大延迟 10 秒
    }

    [Retryable(RetryFor = typeof(HttpRequestException))]
    public virtual async Task<Response> ResilientCallAsync()
    {
        // 仅对特定异常类型重试
    }
}

幂等性控制

public class PaymentService
{
    [Idempotent("payment:process")]
    public virtual async Task<PaymentResult> ProcessPaymentAsync(PaymentRequest request)
    {
        // 相同 Key 的重复调用将返回缓存结果
    }
}

异常日志记录

public class BusinessService
{
    [CatchLogging]
    public virtual async Task ExecuteAsync()
    {
        // 执行耗时和异常信息将自动记录
    }
}

自定义拦截器

// 方式一：继承 InterceptorAttribute
public class CustomInterceptorAttribute : InterceptorAttribute
{
    protected override async ValueTask InterceptAsync(IAsyncInvocation invocation)
    {
        // 前置逻辑
        await invocation.ProceedAsync();
        // 后置逻辑
    }
}

// 方式二：继承 InterceptorBase
public class CustomInterceptor : InterceptorBase
{
    protected override async ValueTask InterceptAsync(IAsyncInvocation invocation)
    {
        await invocation.ProceedAsync();
    }
}

// 使用
public class MyService
{
    [CustomInterceptor]
    public virtual void DoSomething() { }
}

核心类

注意事项

• 拦截器内部不应再嵌套其他拦截器，避免递归调用
• 日志拦截器上不应再添加拦截器
• ConfigureCastleDynamicProxy 必须在所有服务注册完成后调用
• 使用特性的类必须声明为 virtual 方法或实现接口

依赖

• Castle.Core
• Polly.Core
• Galosys.Foundation.Core