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() { }
}
核心类
| 类 |
说明 |
InterceptorAttribute |
拦截器特性基类，支持异步方法 |
InterceptorBase |
传统拦截器基类 |
TransactionalAttribute |
事务管理拦截器 |
RetryableAttribute |
重试策略拦截器（Polly） |
IdempotentAttribute |
幂等性控制拦截器 |
CatchLoggingAttribute |
异常日志记录拦截器 |
CastleCoreServiceCollectionExtensions |
DI 容器扩展方法 |
CastleCoreHostBuilderExtensions |
Host 构建器扩展方法 |
IAsyncInvocation |
异步调用上下文接口 |
注意事项
- 拦截器内部不应再嵌套其他拦截器，避免递归调用
- 日志拦截器上不应再添加拦截器
ConfigureCastleDynamicProxy 必须在所有服务注册完成后调用- 使用特性的类必须声明为
virtual 方法或实现接口
依赖
- Castle.Core
- Polly.Core
- Galosys.Foundation.Core
